/edit_%s %s", emoji, p.Title, p.Slug, date))
- }
-
- kb := map[string]interface{}{}
- var nav []map[string]interface{}
- if page > 1 {
- nav = append(nav, map[string]interface{}{"text": "◀ 上一页", "callback_data": fmt.Sprintf("list_%d", page-1)})
- }
- if page < totalPages {
- nav = append(nav, map[string]interface{}{"text": "下一页 ▶", "callback_data": fmt.Sprintf("list_%d", page+1)})
- }
- if len(nav) > 0 {
- kb["inline_keyboard"] = []interface{}{nav}
- tgcore.TG("sendMessage", map[string]interface{}{
- "chat_id": chatID,
- "text": strings.Join(lines, "\n"),
- "parse_mode": "HTML",
- "reply_markup": kb,
- "disable_web_page_preview": true,
- })
- return nil
- }
- return tgcore.SendMessage(chatID, strings.Join(lines, "\n"), nil)
-}
-
-func (h *Handlers) List(chatID int64, page string) { h.dispatchList(chatID, page) }
-
-
-func (h *Handlers) Start(chatID int64) {
- ip := helpers.GetLanIP(h.cfg.PreferIface)
- ready := EnsureWriteReady(chatID, h.cfg.WritePort)
- if ready {
- kb := map[string]interface{}{
- "inline_keyboard": []interface{}{
- []map[string]interface{}{
- {"text": "📝 开始写作", "callback_data": "menu_new"},
- {"text": "📋 文章列表", "callback_data": "list_1"},
- },
- []map[string]interface{}{
- {"text": "🔗 友链管理", "callback_data": "links_1"},
- {"text": "📡 订阅源", "callback_data": "feeds_1"},
- },
- []map[string]interface{}{
- {"text": "📊 网站数据", "callback_data": "menu_stats"},
- {"text": "ℹ️ 帮助", "callback_data": "menu_help"},
- },
- },
- }
- tgcore.TG("sendMessage", map[string]interface{}{
- "chat_id": chatID,
- "text": fmt.Sprintf("✅ Write 已就绪\n\n📱 手机: http://%s:%d/\n💻 电脑: http://localhost:%d/\n📰 文章: http://%s:1313/posts/", ip, h.cfg.WritePort, h.cfg.WritePort, ip),
- "parse_mode": "HTML",
- "reply_markup": kb,
- "disable_web_page_preview": true,
- })
- return
- }
- tgcore.SendMessage(chatID, "❌ 启动超时，请查看控制台日志。", nil)
-}
-
-func (h *Handlers) Stop(chatID int64) {
- if writeserver.StopWriteServer() {
- tgcore.SendMessage(chatID, "⚡ Write 已停止。", nil)
- } else {
- tgcore.SendMessage(chatID, "⏸ Write 未运行。", nil)
- }
-}
-
-func (h *Handlers) Status(chatID int64) {
- s := writeserver.GetWriteStatus()
- status := "⏸ 未运行"
- if s["running"].(bool) { status = "✅ 运行中" }
- if s["starting"].(bool) { status = "⏳ 启动中..." }
- lines := []string{"Write 状态: " + status}
- if s["running"].(bool) {
- ip := helpers.GetLanIP(h.cfg.PreferIface)
- lines = append(lines, fmt.Sprintf("🌐 局域网: http://%s:%d", ip, h.cfg.WritePort))
- lines = append(lines, fmt.Sprintf("💻 本地: http://localhost:%d", h.cfg.WritePort))
- }
- tgcore.SendMessage(chatID, strings.Join(lines, "\n"), nil)
-}
-
-func (h *Handlers) IP(chatID int64) {
- ip := helpers.GetLanIP(h.cfg.PreferIface)
- tgcore.SendMessage(chatID, fmt.Sprintf("📱 手机访问: http://%s:%d\n💻 电脑访问: http://localhost:%d", ip, h.cfg.WritePort, h.cfg.WritePort), nil)
-}
-
-func (h *Handlers) Help(chatID int64) {
- kb := map[string]interface{}{
- "inline_keyboard": []interface{}{
- []map[string]interface{}{{"text": "📝 开始写作", "callback_data": "menu_new"}},
- []map[string]interface{}{{"text": "📋 文章列表", "callback_data": "list_1"}},
- []map[string]interface{}{{"text": "🔗 友链", "callback_data": "links_1"}, {"text": "📡 订阅", "callback_data": "feeds_1"}},
- },
- }
- tgcore.TG("sendMessage", map[string]interface{}{
- "chat_id": chatID,
- "text": "🤖 WriteBot 命令\n\n📝 /new 标题 — 开始写作\n✏️ /edit slug — 编辑文章\n📋 /list — 文章列表\n🔍 /view slug — 查看文章\n🗑 /delete slug — 删除文章\n\n✍️ 写作中:\n/publish — 发布\n/draft — 存草稿\n/preview — 预览\n/cancel — 丢弃\n\n🔗 友链 /links\n📡 订阅 /feeds\n📊 /stats 统计",
- "parse_mode": "HTML",
- "reply_markup": kb,
- "disable_web_page_preview": true,
- })
-}
-
-
-// --- Writing commands ---
-
-func (h *Handlers) New(chatID int64, title string) {
- if title == "" {
- tgcore.SendMessage(chatID, "📝 请提供标题：/new 你的标题", nil)
- return
- }
- s := sessions.GetSession(chatID)
- s.Title = title
- s.Slug = helpers.MakeSlug(title)
- s.Content = ""
- s.Categories = nil
- s.Tags = nil
- s.Draft = true
- s.Author = "qunlin"
-
- kb := map[string]interface{}{
- "inline_keyboard": []interface{}{
- []map[string]interface{}{
- {"text": "📂 分类", "callback_data": "session_categories"},
- {"text": "🏷 标签", "callback_data": "session_tags"},
- },
- []map[string]interface{}{
- {"text": "🚀 发布", "callback_data": "session_publish"},
- {"text": "📄 存草稿", "callback_data": "session_draft"},
- },
- []map[string]interface{}{
- {"text": "🔍 预览", "callback_data": "session_preview"},
- {"text": "❌ 丢弃", "callback_data": "session_cancel"},
- },
- },
- }
- tgcore.TG("sendMessage", map[string]interface{}{
- "chat_id": chatID,
- "text": fmt.Sprintf("📝 %s\n\n直接发消息开始写作\n用下方按钮管理文章属性", title),
- "parse_mode": "HTML",
- "reply_markup": kb,
- })
-}
-
-func (h *Handlers) Edit(chatID int64, slug string) {
- if slug == "" {
- tgcore.SendMessage(chatID, "✏️ 用法：/edit slug\n先用 /list 查看 slug。", nil)
- return
- }
- p := posts.GetPost(slug)
- if p == nil {
- tgcore.SendMessage(chatID, "❌ 未找到该文章。", nil)
- return
- }
-
- s := sessions.GetSession(chatID)
- s.Title = p.FrontMatter.Title
- s.Slug = p.FrontMatter.Slug
- s.Content = p.Content
- s.Categories = p.FrontMatter.Categories
- s.Tags = p.FrontMatter.Tags
- s.Author = p.FrontMatter.Author
- if s.Author == "" { s.Author = "qunlin" }
- s.Draft = p.FrontMatter.Draft
-
- summary := helpers.SessionSummary(s.Title, s.Categories, s.Tags, s.Content)
- kb := map[string]interface{}{
- "inline_keyboard": []interface{}{
- []map[string]interface{}{
- {"text": "📂 分类", "callback_data": "session_categories"},
- {"text": "🏷 标签", "callback_data": "session_tags"},
- },
- []map[string]interface{}{
- {"text": "🚀 发布", "callback_data": "session_publish"},
- {"text": "📄 存草稿", "callback_data": "session_draft"},
- },
- []map[string]interface{}{
- {"text": "🔍 预览", "callback_data": "session_preview"},
- {"text": "❌ 丢弃", "callback_data": "session_cancel"},
- },
- },
- }
- tgcore.TG("sendMessage", map[string]interface{}{
- "chat_id": chatID,
- "text": fmt.Sprintf("✏️ %s\n\n%s\n\n直接发消息继续写作", s.Title, summary),
- "parse_mode": "HTML",
- "reply_markup": kb,
- })
-}
-
-func (h *Handlers) Delete(chatID int64, slug string) {
- if slug == "" {
- tgcore.SendMessage(chatID, "🗑 用法：/delete slug\n先用 /list 查看。", nil)
- return
- }
- p := posts.GetPost(slug)
- if p == nil {
- tgcore.SendMessage(chatID, "❌ 未找到该文章。", nil)
- return
- }
- if err := recycle.MoveToRecycle(slug, p.DirPath, p.FrontMatter.Title); err != nil {
- tgcore.SendMessage(chatID, "❌ "+err.Error(), nil)
- return
- }
- tgcore.SendMessage(chatID, "🗑 "+p.FrontMatter.Title+" 已移入回收站（30天后自动清除）。", nil)
-}
-
-func (h *Handlers) View(chatID int64, slug string) {
- if slug == "" {
- tgcore.SendMessage(chatID, "🔍 用法：/view slug", nil)
- return
- }
- p := posts.GetPost(slug)
- if p == nil {
- tgcore.SendMessage(chatID, "❌ 未找到该文章。", nil)
- return
- }
- draftMark := "✅"
- if p.FrontMatter.Draft { draftMark = "📝" }
- header := fmt.Sprintf("%s %s\n📂 %s 🏷 %s ✍️ %s 📅 %s",
- draftMark, p.FrontMatter.Title,
- strings.Join(p.FrontMatter.Categories, "、"),
- strings.Join(p.FrontMatter.Tags, "、"),
- p.FrontMatter.Author,
- p.FrontMatter.Date[:10])
-
- content := p.Content
- if len([]rune(content)) > 3500 {
- content = string([]rune(content)[:3500]) + "\n\n..."
- }
- tgcore.SendMessage(chatID, header+"\n\n"+content, nil)
-}
-
-
-func (h *Handlers) Title(chatID int64, arg string) {
- s := sessions.GetSession(chatID)
- if arg == "" {
- tgcore.SendMessage(chatID, fmt.Sprintf("当前标题：%s\n修改：/title 新标题", s.Title), nil)
- return
- }
- s.Title = arg
- tgcore.SendMessage(chatID, "✅ 标题已更新："+arg+"", nil)
-}
-
-func (h *Handlers) Categories(chatID int64, arg string) {
- s := sessions.GetSession(chatID)
- if arg == "" {
- tgcore.SendMessage(chatID, fmt.Sprintf("当前分类：%s\n修改：/categories 分类1,分类2", strings.Join(s.Categories, "、")), nil)
- return
- }
- s.Categories = nil
- for _, item := range strings.Split(arg, ",") {
- item = strings.TrimSpace(item)
- if item != "" { s.Categories = append(s.Categories, item) }
- }
- tgcore.SendMessage(chatID, "✅ 分类："+strings.Join(s.Categories, "、")+"", nil)
-}
-
-func (h *Handlers) Tags(chatID int64, arg string) {
- s := sessions.GetSession(chatID)
- if arg == "" {
- tgcore.SendMessage(chatID, fmt.Sprintf("当前标签：%s\n修改：/tags 标签1,标签2", strings.Join(s.Tags, "、")), nil)
- return
- }
- s.Tags = nil
- for _, item := range strings.Split(arg, ",") {
- item = strings.TrimSpace(item)
- if item != "" { s.Tags = append(s.Tags, item) }
- }
- tgcore.SendMessage(chatID, "✅ 标签："+strings.Join(s.Tags, "、")+"", nil)
-}
-
-func (h *Handlers) Author(chatID int64, arg string) {
- s := sessions.GetSession(chatID)
- if arg == "" {
- tgcore.SendMessage(chatID, fmt.Sprintf("当前作者：%s\n修改：/author 新作者", s.Author), nil)
- return
- }
- s.Author = arg
- tgcore.SendMessage(chatID, "✅ 作者："+arg+"", nil)
-}
-
-func (h *Handlers) Publish(chatID int64) {
- s := sessions.GetSession(chatID)
- if s.Title == "" {
- tgcore.SendMessage(chatID, "❌ 请先 /new 标题 开始写作。", nil)
- return
- }
- if err := sessions.Save(s, false); err != nil {
- tgcore.SendMessage(chatID, "❌ "+err.Error(), nil)
- return
- }
- sessions.ClearSession(chatID)
- tgcore.SendMessage(chatID, "🚀 "+s.Title+" 已发布！", nil)
-}
-
-func (h *Handlers) Draft(chatID int64) {
- s := sessions.GetSession(chatID)
- if s.Title == "" {
- tgcore.SendMessage(chatID, "❌ 请先 /new 标题 开始写作。", nil)
- return
- }
- if err := sessions.Save(s, true); err != nil {
- tgcore.SendMessage(chatID, "❌ "+err.Error(), nil)
- return
- }
- sessions.ClearSession(chatID)
- tgcore.SendMessage(chatID, "📄 "+s.Title+" 已存为草稿。", nil)
-}
-
-func (h *Handlers) Preview(chatID int64) {
- s := sessions.GetSession(chatID)
- if s.Title == "" {
- tgcore.SendMessage(chatID, "❌ 请先 /new 标题 开始写作。", nil)
- return
- }
- summary := helpers.SessionSummary(s.Title, s.Categories, s.Tags, s.Content)
- preview := s.Content
- if len([]rune(preview)) > 3500 {
- preview = string([]rune(preview)[:3500]) + "\n\n... (内容过长)"
- }
- tgcore.SendMessage(chatID, summary+"\n\n"+preview, nil)
-}
-
-func (h *Handlers) Cancel(chatID int64) {
- sessions.ClearSession(chatID)
- tgcore.SendMessage(chatID, "🗑 已丢弃当前写作内容。", nil)
-}
-
-
-// --- Links ---
-
-func (h *Handlers) Links(chatID int64, page string) { h.dispatchLinks(chatID, page) }
-
-func (h *Handlers) dispatchLinks(chatID int64, pageStr string) error {
- page, _ := strconv.Atoi(pageStr)
- if page < 1 { page = 1 }
- perPage := 8
-
- links, err := rssapi.GetLinks(true)
- if err != nil || len(links) == 0 {
- return tgcore.SendMessage(chatID, "🔗 暂无友链。", nil)
- }
-
- totalPages := int(math.Ceil(float64(len(links)) / float64(perPage)))
- if page > totalPages { page = totalPages }
- start := (page - 1) * perPage
- end := start + perPage
- if end > len(links) { end = len(links) }
-
- lines := []string{fmt.Sprintf("🔗 友链 共%d个 · 第%d/%d页", len(links), page, totalPages)}
- for _, l := range links[start:end] {
- icon := "🌐"
- if l.Hidden { icon = "🔒" }
- lines = append(lines, fmt.Sprintf("%s %s\n %s", icon, l.Name, l.URL))
- }
-
- kb := map[string]interface{}{}
- var nav []map[string]interface{}
- if page > 1 {
- nav = append(nav, map[string]interface{}{"text": "◀", "callback_data": fmt.Sprintf("links_%d", page-1)})
- }
- if page < totalPages {
- nav = append(nav, map[string]interface{}{"text": "▶", "callback_data": fmt.Sprintf("links_%d", page+1)})
- }
- if len(nav) > 0 {
- kb["inline_keyboard"] = []interface{}{nav}
- tgcore.TG("sendMessage", map[string]interface{}{
- "chat_id": chatID, "text": strings.Join(lines, "\n"),
- "parse_mode": "HTML", "reply_markup": kb, "disable_web_page_preview": true,
- })
- return nil
- }
- return tgcore.SendMessage(chatID, strings.Join(lines, "\n"), nil)
-}
-
-func (h *Handlers) LinkAdd(chatID int64, arg string) {
- if arg == "" {
- tgcore.SendMessage(chatID, "用法：/link_add url 名称", nil)
- return
- }
- parts := strings.SplitN(arg, " ", 2)
- url := parts[0]
- name := ""
- if len(parts) > 1 { name = parts[1] }
- if err := rssapi.AddLink(rssapi.Link{URL: url, Name: name}); err != nil {
- tgcore.SendMessage(chatID, "❌ "+err.Error(), nil)
- return
- }
- tgcore.SendMessage(chatID, "✅ 友链已添加："+url, nil)
-}
-
-func (h *Handlers) LinkDel(chatID int64, url string) {
- if url == "" { tgcore.SendMessage(chatID, "用法：/link_del url", nil); return }
- if err := rssapi.DeleteLink(url); err != nil {
- tgcore.SendMessage(chatID, "❌ "+err.Error(), nil)
- return
- }
- tgcore.SendMessage(chatID, "✅ 友链已删除："+url, nil)
-}
-
-func (h *Handlers) LinkToggle(chatID int64, url string) {
- if url == "" { tgcore.SendMessage(chatID, "用法：/link_toggle url", nil); return }
- links, _ := rssapi.GetLinks(true)
- var target *rssapi.Link
- for i := range links {
- if links[i].URL == url { target = &links[i]; break }
- }
- if target == nil { tgcore.SendMessage(chatID, "❌ 未找到该友链。", nil); return }
-
- newHidden := !target.Hidden
- rssapi.UpdateLink(url, map[string]interface{}{"hidden": newHidden})
- label := "🌐 已显示"
- if newHidden { label = "🔒 已隐藏" }
- tgcore.SendMessage(chatID, label+": "+url, nil)
-}
-
-// --- Feeds ---
-
-func (h *Handlers) Feeds(chatID int64, page string) { h.dispatchFeeds(chatID, page) }
-
-func (h *Handlers) dispatchFeeds(chatID int64, pageStr string) error {
- page, _ := strconv.Atoi(pageStr)
- if page < 1 { page = 1 }
- perPage := 8
-
- feeds, err := rssapi.GetFeeds()
- if err != nil || len(feeds) == 0 {
- return tgcore.SendMessage(chatID, "📡 暂无订阅源。", nil)
- }
-
- totalPages := int(math.Ceil(float64(len(feeds)) / float64(perPage)))
- if page > totalPages { page = totalPages }
- start := (page - 1) * perPage
- end := start + perPage
- if end > len(feeds) { end = len(feeds) }
-
- lines := []string{fmt.Sprintf("📡 订阅源 共%d个 · 第%d/%d页", len(feeds), page, totalPages)}
- for _, f := range feeds[start:end] {
- title := f.FeedTitle
- if title == "" { title = f.URL }
- if len([]rune(title)) > 50 { title = string([]rune(title)[:50]) }
- lines = append(lines, fmt.Sprintf("🗜 %s\n %s", title, f.URL))
- }
-
- kb := map[string]interface{}{}
- var nav []map[string]interface{}
- if page > 1 {
- nav = append(nav, map[string]interface{}{"text": "◀", "callback_data": fmt.Sprintf("feeds_%d", page-1)})
- }
- if page < totalPages {
- nav = append(nav, map[string]interface{}{"text": "▶", "callback_data": fmt.Sprintf("feeds_%d", page+1)})
- }
- if len(nav) > 0 {
- kb["inline_keyboard"] = []interface{}{nav}
- tgcore.TG("sendMessage", map[string]interface{}{
- "chat_id": chatID, "text": strings.Join(lines, "\n"),
- "parse_mode": "HTML", "reply_markup": kb, "disable_web_page_preview": true,
- })
- return nil
- }
- return tgcore.SendMessage(chatID, strings.Join(lines, "\n"), nil)
-}
-
-func (h *Handlers) FeedAdd(chatID int64, arg string) {
- if arg == "" { tgcore.SendMessage(chatID, "用法：/feed_add url", nil); return }
- parts := strings.SplitN(arg, " ", 2)
- url := parts[0]
- title := ""
- if len(parts) > 1 { title = parts[1] }
- if err := rssapi.AddFeed(url, title); err != nil {
- tgcore.SendMessage(chatID, "❌ "+err.Error(), nil)
- return
- }
- tgcore.SendMessage(chatID, "✅ 订阅源已添加："+url, nil)
-}
-
-func (h *Handlers) FeedDel(chatID int64, url string) {
- if url == "" { tgcore.SendMessage(chatID, "用法：/feed_del url", nil); return }
- if err := rssapi.DeleteFeed(url); err != nil {
- tgcore.SendMessage(chatID, "❌ "+err.Error(), nil)
- return
- }
- tgcore.SendMessage(chatID, "✅ 订阅源已删除："+url, nil)
-}
-
-// --- Stats ---
-
-func (h *Handlers) Stats(chatID int64) {
- postCount := posts.GetPostCount()
- linkCount := 0
- feedCount := 0
- if links, err := rssapi.GetLinks(true); err == nil { linkCount = len(links) }
- if feeds, err := rssapi.GetFeeds(); err == nil { feedCount = len(feeds) }
-
- tgcore.SendMessage(chatID, fmt.Sprintf("📊 网站数据\n\n📝 文章：%d 篇\n🔗 友链：%d 个\n📡 订阅源：%d 个\n\n🌐 usj.cc", postCount, linkCount, feedCount), nil)
-}
-
-
-// --- EnsureWriteReady ---
-
-func EnsureWriteReady(chatID int64, writePort int) bool {
- s := writeserver.GetWriteStatus()
- running, _ := s["running"].(bool)
- starting, _ := s["starting"].(bool)
-
- if running {
- writeserver.StartHugoIfNeeded()
- return true
- }
- if starting {
- tgcore.SendMessage(chatID, "⌛ Write 正在启动...", nil)
- if helpers.WaitForReady(writePort, 0) {
- writeserver.SetWriteReady(true)
- writeserver.StartHugoIfNeeded()
- return true
- }
- return false
- }
-
- result := writeserver.StartWriteServer()
- if started, ok := result["started"].(bool); !ok || !started {
- return false
- }
- tgcore.SendMessage(chatID, "⌛ 正在启动 Write...", nil)
- if helpers.WaitForReady(writePort, 0) {
- writeserver.SetWriteReady(true)
- writeserver.StartHugoIfNeeded()
- return true
- }
- return false
-}
-
-// --- Callback handlers for inline buttons ---
-
-func (h *Handlers) SessionCallback(chatID int64, action string) {
- switch action {
- case "categories":
- s := sessions.GetSession(chatID)
- tgcore.SendMessage(chatID, fmt.Sprintf("📂 当前分类：%s\n\n请发送新的分类（逗号分隔）：", strings.Join(s.Categories, "、")), nil)
- case "tags":
- s := sessions.GetSession(chatID)
- tgcore.SendMessage(chatID, fmt.Sprintf("🏷 当前标签：%s\n\n请发送新的标签（逗号分隔）：", strings.Join(s.Tags, "、")), nil)
- case "publish":
- h.Publish(chatID)
- case "draft":
- h.Draft(chatID)
- case "preview":
- h.Preview(chatID)
- case "cancel":
- h.Cancel(chatID)
- }
-}
-
-func (h *Handlers) MenuCallback(chatID int64, action string) {
- switch action {
- case "new":
- tgcore.SendMessage(chatID, "📝 请输入：/new 文章标题", nil)
- case "help":
- h.Help(chatID)
- case "stats":
- h.Stats(chatID)
- }
-}
diff --git a/bot-go/internal/writeserver/writeserver.go b/bot-go/internal/writeserver/writeserver.go
deleted file mode 100644
index 2fb8aa51..00000000
--- a/bot-go/internal/writeserver/writeserver.go
+++ /dev/null
@@ -1,156 +0,0 @@
-package writeserver
-
-import (
- "fmt"
- "net"
- "os/exec"
- "path/filepath"
- "sync"
- "time"
-)
-
-var (
- mu sync.Mutex
- writeProc *exec.Cmd
- writeReady bool
- hugoProc *exec.Cmd
- WritePort int
- WriteDir string
-)
-
-func Init(writePort int, writeDir string) {
- WritePort = writePort
- WriteDir = writeDir
-}
-
-func StartWriteServer() map[string]interface{} {
- mu.Lock()
- defer mu.Unlock()
-
- if writeProc != nil {
- if writeReady {
- return map[string]interface{}{"started": false, "reason": "already_running"}
- }
- return map[string]interface{}{"started": false, "reason": "starting"}
- }
-
- writeReady = false
- writeProc = exec.Command(filepath.Join(WriteDir, "writeserver.exe"))
- writeProc.Dir = WriteDir
-
- if err := writeProc.Start(); err != nil {
- writeProc = nil
- return map[string]interface{}{"started": false, "reason": err.Error()}
- }
-
- writeReady = true
-
- go func() {
- err := writeProc.Wait()
- mu.Lock()
- defer mu.Unlock()
- fmt.Printf("[write] exited: %v\n", err)
- writeProc = nil
- writeReady = false
- }()
-
- return map[string]interface{}{"started": true}
-}
-
-func StopWriteServer() bool {
- mu.Lock()
- defer mu.Unlock()
-
- if hugoProc != nil {
- killProcessTree(hugoProc)
- hugoProc = nil
- }
-
- if writeProc == nil {
- return false
- }
-
- killProcessTree(writeProc)
- writeProc = nil
- writeReady = false
- return true
-}
-
-func killProcessTree(cmd *exec.Cmd) {
- if cmd == nil || cmd.Process == nil {
- return
- }
- // On Windows, use taskkill /T to kill process tree
- pid := cmd.Process.Pid
- killCmd := exec.Command("taskkill", "/PID", fmt.Sprintf("%d", pid), "/T", "/F")
- killCmd.Run()
- cmd.Process.Kill()
-}
-
-func StartHugoIfNeeded() {
- mu.Lock()
- defer mu.Unlock()
-
- if hugoProc != nil {
- return
- }
-
- hugoDir := WriteDir + "/.."
- hugoProc = exec.Command("hugo", "server", "--bind", "0.0.0.0", "--port", "1313", "--disableFastRender")
- hugoProc.Dir = hugoDir
-
- if err := hugoProc.Start(); err != nil {
- fmt.Printf("[hugo] start error: %v\n", err)
- hugoProc = nil
- return
- }
-
- fmt.Println("[hugo] started on 0.0.0.0:1313")
-
- go func() {
- err := hugoProc.Wait()
- mu.Lock()
- defer mu.Unlock()
- fmt.Printf("[hugo] exited: %v\n", err)
- hugoProc = nil
- }()
-}
-
-func GetWriteStatus() map[string]interface{} {
- mu.Lock()
- running := writeProc != nil && writeReady
- starting := writeProc != nil && !writeReady
- mu.Unlock()
-
- // Also check via TCP if we are not tracking a process
- if !running && !starting {
- conn, err := net.DialTimeout("tcp", fmt.Sprintf("127.0.0.1:%d", WritePort), 2*time.Second)
- if err == nil {
- conn.Close()
- running = true
- }
- }
-
- return map[string]interface{}{
- "running": running,
- "starting": starting,
- }
-}
-
-func SetWriteReady(ready bool) {
- mu.Lock()
- defer mu.Unlock()
- writeReady = ready
-}
-
-func IsWriteReady() bool {
- mu.Lock()
- defer mu.Unlock()
- return writeReady
-}
-
-func IsWriteRunning() bool {
- mu.Lock()
- defer mu.Unlock()
- return writeProc != nil
-}
diff --git a/bot-go/start_bot.bat b/bot-go/start_bot.bat
deleted file mode 100644
index 20305000..00000000
--- a/bot-go/start_bot.bat
+++ /dev/null
@@ -1,5 +0,0 @@
-@echo off
-title WriteBot
-cd /d E:\GitHub\blog\bot-go
-echo [%date% %time%] WriteBot starting...
-writebot.exe
diff --git a/write/.recycle/meta/2026-06-01-深圳真的好热.json b/write/.recycle/meta/2026-06-01-深圳真的好热.json
new file mode 100644
index 00000000..07465d5e
--- /dev/null
+++ b/write/.recycle/meta/2026-06-01-深圳真的好热.json
@@ -0,0 +1,7 @@
+{
+ "slug": "2026-06-01-深圳真的好热",
+ "title": "深圳真的好热",
+ "deletedAt": "2026-06-01T16:21:45.062Z",
+ "originalPath": "E:\\GitHub\\blog\\content\\post\\2026\\2026-06-01-深圳真的好热",
+ "expiresAt": "2026-07-01T16:21:45.062Z"
+}
\ No newline at end of file
diff --git a/write/.recycle/meta/2026-06-01-深圳真的热.json b/write/.recycle/meta/2026-06-01-深圳真的热.json
new file mode 100644
index 00000000..49bd22d7
--- /dev/null
+++ b/write/.recycle/meta/2026-06-01-深圳真的热.json
@@ -0,0 +1,7 @@
+{
+ "slug": "2026-06-01-深圳真的热",
+ "title": "深圳真的热",
+ "deletedAt": "2026-06-01T14:59:57.582Z",
+ "originalPath": "E:\\GitHub\\blog\\content\\post\\2026\\2026-06-01-深圳真的热",
+ "expiresAt": "2026-07-01T14:59:57.582Z"
+}
\ No newline at end of file
diff --git a/write/.recycle/meta/202605311204.json b/write/.recycle/meta/202605311204.json
new file mode 100644
index 00000000..75f5d903
--- /dev/null
+++ b/write/.recycle/meta/202605311204.json
@@ -0,0 +1,7 @@
+{
+ "slug": "202605311204",
+ "title": "周末我把手机系统降级了一个大版本",
+ "deletedAt": "2026-06-01T15:06:56.071Z",
+ "originalPath": "E:\\GitHub\\blog\\content\\post\\2026\\2026-05-31-周末我把手机系统降级了一个大版本",
+ "expiresAt": "2026-07-01T15:06:56.071Z"
+}
\ No newline at end of file
diff --git a/write/.recycle/posts/2026-06-01-深圳真的好热/index.md b/write/.recycle/posts/2026-06-01-深圳真的好热/index.md
new file mode 100644
index 00000000..4b83c075
--- /dev/null
+++ b/write/.recycle/posts/2026-06-01-深圳真的好热/index.md
@@ -0,0 +1,24 @@
+---
+title: 深圳真的好热
+date: '2026-06-01T00:00:00.000Z'
+slug: 2026-06-01-深圳真的好热
+draft: false
+categories:
+ - 技术
+tags:
+ - 测试
+author: 小赵
+layout: post
+---
+你好
+
+
+
+
+
+今天的天气不错
+
+你觉得呢
+
+哈哈哈哈
+
diff --git a/write/.recycle/posts/2026-06-01-深圳真的热/1780325877248-AgACAgQA.jpg b/write/.recycle/posts/2026-06-01-深圳真的热/1780325877248-AgACAgQA.jpg
new file mode 100644
index 00000000..f58c5462
Binary files /dev/null and b/write/.recycle/posts/2026-06-01-深圳真的热/1780325877248-AgACAgQA.jpg differ
diff --git a/write/.recycle/posts/2026-06-01-深圳真的热/index.md b/write/.recycle/posts/2026-06-01-深圳真的热/index.md
new file mode 100644
index 00000000..9a8f4b37
--- /dev/null
+++ b/write/.recycle/posts/2026-06-01-深圳真的热/index.md
@@ -0,0 +1,20 @@
+---
+title: 深圳真的热
+date: '2026-06-01'
+slug: 2026-06-01-深圳真的热
+draft: false
+categories:
+ - 技术
+tags:
+ - 深圳
+author: 小赵
+layout: post
+---
+好热啊
+超级热
+
+
+
+哈哈哈
+此文章使用 telegram 撰写
+哈哈哈
diff --git a/write/.recycle/posts/202605311204/index.md b/write/.recycle/posts/202605311204/index.md
new file mode 100644
index 00000000..bf1956ba
--- /dev/null
+++ b/write/.recycle/posts/202605311204/index.md
@@ -0,0 +1,35 @@
+---
+title: 周末我把手机系统降级了一个大版本
+date: '2026-05-31T00:00:00.000Z'
+slug: '202605311204'
+draft: false
+categories:
+ - 生活
+tags:
+ - OPPO;ColorOS
+author: 小赵
+layout: post
+ai_comment: >-
+ 从技术角度看，ColorOS 16 的 AI
+ 功能堆砌是典型的版本迭代陷阱。厂商为追求差异化强行注入AI模块，却忽略了系统层级的功耗平衡优化。建议关闭非必要的AI服务，这就像给过度兴奋的CPU降频——有时候减法比加法更能体现工程智慧。续航劣化可能源于AI进程的常驻唤醒，等待后续热修复补丁或许是更理性的选择。
+---
+从 iPhone 16E 换到 OPPO Find X8s 之后，它就一直是主力机，没再变过。
+
+说实话，OPPO 这套系统我用着挺满意，功能到位，稳定性也没得挑。
+
+之所以彻底放弃 iPhone 当主力，理由其实很充分很现实：微信双开和通话录音。这两样，iPhone 都给不了，而我的工作又偏偏离不开。
+
+中间也动过双持的念头，两台手机分工协作，听起来挺美。但真用起来，麻烦比便利多。光是琢磨哪个 App 装在哪台手机上，就够头疼的。用了一阵子发现，我根本没有那份“区分使用”的需求，反而更想要一个干净利落的统一。
+
+手机到手时，预装的是 ColorOS 15。我就是被它的宣传语打动的——“流畅稳定，德芙一样丝滑”。用下来，确实名副其实，那种跟手和舒心，让我觉得自己选对了。
+
+所以 ColorOS 16 一推送，我毫不犹豫就更了。我的手机一直是默认自动更新，总相信新的一定更好。
+
+但很快我就发现，厂商的劲头，好像全往一个方向使了：AI。
+
+到处都是 AI。系统里那些曾经让我安心的“本分”感，开始变了味。
+
+带给我实际的体验就是，耗电和发热更厉害了，手机续航也来到了一天两充，看着手机里的电池健康，实际上还是百分之百
+
+
+
diff --git a/write/docs/bot_design/design.md b/write/docs/bot_design/design.md
new file mode 100644
index 00000000..d3983e89
--- /dev/null
+++ b/write/docs/bot_design/design.md
@@ -0,0 +1,914 @@
+# WriteBot 模块设计文档
+
+## 一、架构
+
+Bot 作为 Next.js 的 sidecar 模块运行，通过 `instrumentation.ts` 在服务端启动时自动拉起。
+
+```
+write/src/lib/bot/
+├── index.ts # 启动入口
+├── config.ts # Bot 专用配置
+├── tg.ts # Telegram API 封装
+├── sessions.ts # 写作会话状态管理
+├── handlers.ts # 全部命令处理器
+├── poll.ts # 长轮询循环（带指数退避）
+└── helpers.ts # 工具函数
+```
+
+Bot 不再通过 HTTP 调 write API，直接调用 `src/lib/posts.ts`、`src/lib/rssapi.ts` 等 lib 函数。
+
+---
+
+## 二、交互方式
+
+### 2.1 Telegram 原生组件使用规则
+
+| 组件 | 用途 | 使用场景 |
+|------|------|---------|
+| ReplyKeyboard（底部键盘） | 常驻操作按钮 | 所有文本回复都带，分主键盘和写作键盘两套 |
+| InlineKeyboard（消息内按钮） | 列表操作、确认、分页 | 文章列表编辑/删除、删除确认、分页导航、打开编辑器 |
+| ForceReply（强制回复） | 引导输入 | 新建标题、设置分类/标签、添加友链/订阅源 |
+| Web App | 内置浏览器打开编辑器 | /start 时提供 |
+
+**关键规则：ReplyKeyboard 和 InlineKeyboard 不能混在同一个 reply_markup 里。**
+
+### 2.2 ReplyKeyboard 布局
+
+主键盘（非写作状态）：
+```
+[/new 写文章] [/list 文章列表]
+[/links 友链] [/feeds 订阅]
+[/stats 数据] [/help 帮助]
+```
+
+写作键盘（写作会话中）：
+```
+[/preview 预览] [/publish 发布]
+[/draft 草稿] [/cancel 取消]
+[/title 标题] [/categories 分类]
+```
+
+---
+
+## 三、命令清单
+
+### 3.1 系统命令
+
+| 命令 | 参数 | 说明 |
+|------|------|------|
+| `/start` | 无 | 启动 Hugo，显示地址，发 Web App 编辑器按钮 |
+| `/stop` | 无 | 停止 Hugo |
+| `/status` | 无 | 显示 Hugo 运行状态和地址 |
+| `/ip` | 无 | 显示局域网 IP |
+| `/help` | 无 | 显示命令帮助（根据是否在写作中显示不同内容） |
+
+### 3.2 文章命令
+
+| 命令 | 参数 | 说明 |
+|------|------|------|
+| `/new` | 标题（可选） | 新建文章，见写作流程 |
+| `/edit` | slug | 编辑已有文章，见编辑流程 |
+| `/delete` | slug | 删除文章（二次确认），移入回收站 |
+| `/list` | 页码（可选） | 文章列表，纯文本 + 分页 |
+| `/view` | slug | 显示预览链接 |
+| `/preview` | 无 | 预览当前写作内容 |
+| `/publish` | 无 | 保存到本地（draft: false），不触发 git push |
+| `/draft` | 无 | 保存到本地（draft: true） |
+| `/deploy` | 无 | Git add → commit → pull --rebase → push |
+| `/sync` | 无 | Git pull --rebase，同步远程 |
+| `/undo` | 无 | 撤销最后一次追加的内容，自动预览 |
+| `/cancel` | 无 | 丢弃当前写作会话 |
+| `/title` | 新标题 | 修改文章标题（ForceReply 引导） |
+| `/categories` | 分类 | 设置分类（逗号分隔） |
+| `/tags` | 标签 | 设置标签（逗号分隔） |
+| `/author` | 作者名 | 修改作者 |
+
+### 3.3 友链命令
+
+| 命令 | 参数 | 说明 |
+|------|------|------|
+| `/links` | 页码（可选） | 友链列表，纯文本 + 分页 + 命令提示 |
+| `/link_add` | url 名称 | 添加友链（ForceReply 引导） |
+| `/link_del` | url | 删除友链 |
+| `/link_toggle` | url | 切换显示/隐藏 |
+
+### 3.4 订阅命令
+
+| 命令 | 参数 | 说明 |
+|------|------|------|
+| `/feeds` | 页码（可选） | 订阅源列表，纯文本 + 分页 + 命令提示 |
+| `/feed_add` | url | 添加订阅源（ForceReply 引导） |
+| `/feed_del` | url | 删除订阅源 |
+
+### 3.5 数据命令
+
+| 命令 | 参数 | 说明 |
+|------|------|------|
+| `/stats` | 无 | 显示文章数、友链数、订阅源数 |
+
+---
+
+## 四、核心流程
+
+### 4.1 新建文章 `/new`
+
+```
+用户: /new 标题
+ ↓ (如果没有标题，ForceReply 引导输入)
+Bot: 📝 开始写：《标题》
+ 📂 设置分类（可选）
+ [跳过] [设置分类] ← InlineKeyboard
+ ↓
+用户: 点 [跳过] → 直接进写作
+ 或: 点 [设置分类] → ForceReply 引导输入分类
+ → 然后同样问标签 [跳过] [设置标签]
+ ↓
+Bot: 切换写作键盘
+ "直接发消息写正文，完成后点「发布」"
+ ↓
+用户: 发消息 → 追加到 content
+用户: 发照片 → 下载到文章文件夹，追加 markdown 引用
+用户: /undo → 撤销最后一次追加，自动预览
+ ↓
+用户: /publish
+ ↓
+Bot: 保存到本地文件（draft: false）
+ "✅ 已保存，发 /deploy 推送到线上"
+ ↓
+用户: /deploy
+ ↓
+Bot: git add → commit → pull --rebase → push
+ "🚀 已发布并部署！"
+```
+
+Session 初始状态：
+```typescript
+{
+ title: "标题",
+ slug: "2026-06-01-标题",
+ content: "",
+ categories: [],
+ tags: [],
+ author: "小赵", // DEFAULT_AUTHOR 环境变量可覆盖
+ draft: true,
+ chunks: [], // 用于 /undo，记录每次追加的内容
+ mode: "write", // write | edit
+}
+```
+
+### 4.2 编辑文章 `/edit`（方案 B）
+
+```
+用户: /edit slug
+ ↓
+Bot: 加载文章，显示原文内容（分条，每条 ≤3800 字）
+ 清空 session.content（保留 title、slug、categories、tags、author）
+ 切换写作键盘
+ "原文已显示，现在重新写正文，写完点「发布」"
+ ↓
+用户: 发消息 → 追加到新 content（和 /new 一样）
+ ↓
+后续流程同新建
+```
+
+关键区别：`/new` 的 slug 是新生成的，`/edit` 保留原文章的 slug。保存时调用 `updatePost` 而不是 `createPost`。
+
+### 4.3 删除文章 `/delete`
+
+```
+用户: /delete slug
+ ↓
+Bot: "确认删除《标题》？"
+ [确认删除] [取消] ← InlineKeyboard
+ ↓
+用户: 点 [确认删除]
+ → moveToRecycle(slug, dirPath, title)
+ → "✂ 已移入回收站：《标题》\n30天内可恢复。"
+ ↓
+用户: 点 [取消]
+ → "已取消"
+```
+
+poll.ts callback 处理新增 `confirm_del` 前缀：
+```typescript
+const CALLBACK_PREFIXES = {
+ edit: "edit",
+ confirm_del: "delete", // 确认删除
+ cancel_del: "noop", // 取消删除
+ list: "list",
+ links: "links",
+ feeds: "feeds",
+ skip_cat: "skip_categories", // 跳过分类
+ skip_tag: "skip_tags", // 跳过标签
+};
+```
+
+### 4.4 文章列表 `/list`
+
+纯文本显示，无 InlineKeyboard 操作按钮：
+```
+📖 文章列表 共 46 篇 · 第 1/10 页
+
+我的第一篇文章
+ 2026-06-01-my-first-post
+另一篇文章 📝（草稿）
+ 2026-05-28-another-post
+
+◀ 上一页 下一页 ▶ ← InlineKeyboard（仅分页）
+```
+
+用户通过 slug 操作：`/edit slug`、`/delete slug`、`/view slug`。
+
+### 4.5 友链列表 `/links`
+
+纯文本 + 分页 + 命令提示：
+```
+🔗 友链 共 46 个 · 第 1/10 页
+
+🌐 强仔博客
+🌐 七栀
+🔒 若志随笔（已隐藏）
+
+操作命令：
+/link_add url 名称 — 添加
+/link_del url — 删除
+/link_toggle url — 显示/隐藏
+
+◀ 上一页 下一页 ▶
+```
+
+### 4.6 订阅列表 `/feeds`
+
+同友链，纯文本 + 分页 + 命令提示。
+
+---
+
+## 五、图片处理（Hugo Page Bundle）
+
+### 5.1 存储策略
+
+图片存到文章自己的文件夹里，符合 Hugo page bundle 规范：
+
+```
+content/post/2026/2026-06-01-文章标题/
+├── index.md
+├── photo1.jpg
+└── photo2.jpg
+```
+
+正文引用：``（相对路径）
+
+### 5.2 实现逻辑
+
+写作中收到照片时：
+1. 根据 session 的 slug 计算文章文件夹路径
+ - slug: `2026-06-01-文章标题`
+ - 文件夹: `content/post/2026/2026-06-01-文章标题/`
+2. 文件夹不存在则创建
+3. 下载图片到文件夹内
+4. content 追加 ``
+
+保存时（draft/publish）：
+1. index.md 写到同一个文件夹
+2. 图片已经在里面，无需移动
+
+取消时：
+1. 文件夹里只有图片没有 index.md
+2. Hugo 不会渲染，无害
+
+---
+
+## 六、撤销 `/undo`
+
+### 6.1 实现机制
+
+Session 新增 `chunks: string[]` 字段：
+
+```typescript
+interface Session {
+ // ... 其他字段
+ chunks: string[]; // 每次追加的内容记录
+}
+```
+
+每次用户发消息追加到 content 时，同时 push 到 chunks：
+```typescript
+s.chunks.push(fullText + "\n");
+s.content += fullText + "\n";
+```
+
+### 6.2 `/undo` 流程
+
+```
+用户: /undo
+ ↓
+如果 chunks 为空: "没有可撤销的内容"
+ ↓
+否则:
+ lastChunk = chunks.pop()
+ content = content 去掉 lastChunk
+ → 自动调用 preview 逻辑，显示当前文章内容
+ → "↩ 已撤销最后一段（上方为当前内容）"
+```
+
+---
+
+## 七、发布与部署（分离设计）
+
+### 7.1 与网页端保持一致
+
+| 操作 | 命令 | 效果 |
+|------|------|------|
+| 保存草稿 | `/draft` | 保存到本地，draft: true |
+| 发布 | `/publish` | 保存到本地，draft: false，不触发 git |
+| 部署 | `/deploy` | git add → commit → pull --rebase → push |
+| 同步 | `/sync` | git pull --rebase，拉取远程最新 |
+
+### 7.2 Git 冲突处理
+
+`/deploy` 执行流程：
+1. `git add content/post static`
+2. `git diff --cached --quiet` → 有变更则 `git commit`
+3. `git pull --rebase --autostash origin main`
+ - 成功 → 继续
+ - 冲突 → `git rebase --abort` → 回复"远程有冲突，已自动放弃合并。请先 /sync 同步，手动解决后再 deploy"
+4. `git push`
+
+---
+
+## 八、配置
+
+### 8.1 环境变量（write/.env）
+
+```env
+# Bot 配置
+TG_BOT_TOKEN=xxx
+TG_ALLOWED_CHAT_IDS=xxx # 留空允许所有人
+PREFER_IFACE=WLAN
+DEFAULT_AUTHOR=小赵 # 新增：默认作者名
+```
+
+### 8.2 config.ts 新增
+
+```typescript
+export const DEFAULT_AUTHOR = process.env.DEFAULT_AUTHOR || "小赵";
+```
+
+---
+
+## 九、命令解析
+
+### 9.1 ReplyKeyboard 按钮文字处理
+
+按钮发出的文字如 `/new 写文章`，解析规则：
+1. `split("@")[0]` 去掉 bot mention
+2. `split(/\s+/)` 拆词
+3. 第一个词去掉 `/` 前缀作为命令名
+4. 其余词作为参数
+
+`/new 写文章` → 命令 `new`，参数 `写文章`
+但 `new` 命令的参数是标题，所以实际行为：`/new 写文章` 会创建一篇标题为"写文章"的文章。
+
+需要特殊处理：如果参数和命令的中文描述匹配（如 `new` 的参数是 `写文章`），则忽略该参数。
+或者更简单的方案：ReplyKeyboard 按钮只发命令，不带中文。
+
+**最终方案：ReplyKeyboard 按钮文字改为纯命令：**
+```
+[/new] [/list]
+[/links] [/feeds]
+[/stats] [/help]
+```
+
+### 9.2 ForceReply 回复识别
+
+poll.ts 通过 `reply_to_message.text` 匹配关键词来识别 ForceReply 回复：
+
+| 关键词 | 路由到 |
+|--------|--------|
+| "请输入文章标题" | `handleCommand(chatId, "new", text)` |
+| "请输入新标题" | `handleCommand(chatId, "title", text)` |
+| "请输入友链信息" | `handleCommand(chatId, "link_add", text)` |
+| "请输入订阅源 URL" | `handleCommand(chatId, "feed_add", text)` |
+| "请输入分类" | `handleCommand(chatId, "categories", text)` |
+| "请输入标签" | `handleCommand(chatId, "tags", text)` |
+
+---
+
+## 十、会话状态机
+
+Session 有一个 `state` 字段，控制消息处理行为：
+
+```
+idle → 非写作状态，普通命令处理
+writing_title → 等待 ForceReply 标题输入
+writing_cat → 等待 ForceReply 分类输入（或 InlineKeyboard 跳过）
+writing_tag → 等待 ForceReply 标签输入（或 InlineKeyboard 跳过）
+writing → 写作中，消息追加到 content
+confirm_del → 等待删除确认（InlineKeyboard）
+```
+
+状态转换：
+```
+idle → ( /new ) → writing_title → ( 输入标题 ) → writing_cat
+ → ( 跳过/输入 ) → writing_tag → ( 跳过/输入 ) → writing → idle
+
+idle → ( /edit slug ) → 显示原文 → 清空 content → writing → idle
+
+idle → ( /delete slug ) → confirm_del → ( 确认 ) → idle
+ → ( 取消 ) → idle
+```
+
+
+
+---
+
+## 十一、友链模块
+
+### 11.1 命令清单
+
+| 命令 | 参数 | 说明 |
+|------|------|------|
+| `/links` | 页码（可选） | 友链列表，纯文本 + 分页 |
+| `/link_add` | url 名称 | ForceReply 引导输入，添加友链 |
+| `/link_edit` | url | ForceReply 引导输入新名称，通过 oldUrl 编辑 |
+| `/link_del` | url | 删除友链 |
+| `/link_toggle` | url | 切换显示/隐藏 |
+
+### 11.2 列表显示格式
+
+```
+🔗 友链 共 46 个 · 第 1/10 页
+
+🌐 吾柯 https://blog.keepke.com
+🌐 强仔博客 https://loseu.cc
+🔒 七栀 https://blog.qydzz.cn
+
+操作：/link_add /link_edit /link_del /link_toggle
+
+◀ 上一页 下一页 ▶
+```
+
+每条显示：图标（🌐 正常 / 🔒 隐藏）+ 名称 + URL。
+每页 10 条。底部 InlineKeyboard 仅分页按钮。
+底部文字提示可用操作命令。
+
+### 11.3 `/link_edit` 流程
+
+```
+用户: /link_edit url
+ ↓
+Bot: 查找该友链，显示当前信息
+ "请输入新名称（留空保持不变）：" ← ForceReply
+ ↓
+用户: 输入新名称（或发"跳过"）
+ ↓
+Bot: 调用 POST /api/links { oldUrl, name: newName }
+ "✅ 已更新：新名称"
+```
+
+### 11.4 API 调用
+
+- 列表：`GET /api/links?all=1`
+- 添加：`POST /api/links` body: `{ name, url }`
+- 编辑：`POST /api/links` body: `{ oldUrl, name, ... }`
+- 删除：`DELETE /api/links?url=xxx`
+- 切换：先 GET 获取 hidden 状态，再 POST `{ url, hidden: !current }`
+
+---
+
+## 十二、订阅模块
+
+### 12.1 命令清单
+
+| 命令 | 参数 | 说明 |
+|------|------|------|
+| `/feeds` | 页码（可选） | 订阅源列表，纯文本 + 分页 |
+| `/feed_add` | url 名称 | ForceReply 引导输入 URL 和名称 |
+| `/feed_edit` | url | ForceReply 引导编辑，通过 oldUrl |
+| `/feed_del` | url | 删除订阅源 |
+| `/feed_health` | 无 | 检测全部订阅源健康状态 |
+
+### 12.2 列表显示格式
+
+```
+📡 订阅源 共 52 个 · 第 1/10 页
+
+📰 吾柯 https://blog.keepke.com
+📰 强仔博客 https://loseu.cc
+
+操作：/feed_add /feed_edit /feed_del /feed_health
+
+◀ 上一页 下一页 ▶
+```
+
+每页 10 条。
+
+### 12.3 `/feed_health` 流程
+
+调用 `GET /api/health`（不传 url 参数，检测全部订阅源）。
+
+```
+用户: /feed_health
+ ↓
+Bot: "⏳ 正在检测 52 个订阅源..."
+ ↓
+Bot:
+ 📊 订阅源健康报告
+ ✅ 存活：49 ❌ 异常：3
+
+ ❌ 异常站点：
+ 🔴 dead-blog.com — timeout
+ 🔴 another.com — 500
+ 🔴 third.com — 连接失败
+```
+
+只列出异常站点，正常的不逐一显示。
+
+### 12.4 `/feed_edit` 流程
+
+同友链编辑，通过 oldUrl 参数调用 POST /api/feeds。
+
+### 12.5 API 调用
+
+- 列表：`GET /api/feeds`
+- 添加：`POST /api/feeds` body: `{ url, feedTitle }`
+- 编辑：`POST /api/feeds` body: `{ oldUrl, url, feedTitle }`
+- 删除：`DELETE /api/feeds?url=xxx`
+- 健康：`GET /api/health`
+
+---
+
+## 十三、新增 `/read` 命令
+
+利用 API 的 `GET /api/articles` 接口，获取友链博客的最新文章。
+
+### 13.1 命令
+
+| 命令 | 参数 | 说明 |
+|------|------|------|
+| `/read` | 数量（可选，默认 10） | 友链最新文章 |
+
+### 13.2 显示格式
+
+```
+📰 友链最新文章（10 篇）
+
+吾柯 — 如何在 Hugo 中实现友链
+ https://blog.keepke.com/xxx
+
+强仔博客 — 2026 年度总结
+ https://loseu.cc/xxx
+
+七栀 — 我的第一次旅行
+ https://blog.qydzz.cn/xxx
+```
+
+每条显示：博客名 — 文章标题 + 链接。
+Telegram 自动将 URL 转为可点击链接。
+
+### 13.3 API 调用
+
+`GET /api/articles?limit=10`
+
+响应结构：
+```json
+{
+ "total": 380,
+ "articles": [
+ {
+ "title": "...",
+ "link": "...",
+ "pubDate": "...",
+ "feedName": "吾柯",
+ "siteUrl": "...",
+ "favicon": "...",
+ "author": "..."
+ }
+ ]
+}
+```
+
+---
+
+## 十四、完整命令注册列表
+
+更新 `setMyCommands` 注册的命令：
+
+```typescript
+commands: [
+ { command: "new", description: "写一篇文章" },
+ { command: "edit", description: "编辑文章" },
+ { command: "delete", description: "删除文章" },
+ { command: "list", description: "文章列表" },
+ { command: "publish", description: "保存发布" },
+ { command: "draft", description: "保存草稿" },
+ { command: "deploy", description: "推送到线上" },
+ { command: "sync", description: "同步远程" },
+ { command: "undo", description: "撤销最后一段" },
+ { command: "preview", description: "预览" },
+ { command: "links", description: "友链管理" },
+ { command: "link_add", description: "添加友链" },
+ { command: "link_edit", description: "编辑友链" },
+ { command: "link_del", description: "删除友链" },
+ { command: "link_toggle", description: "显示/隐藏友链" },
+ { command: "feeds", description: "订阅管理" },
+ { command: "feed_add", description: "添加订阅源" },
+ { command: "feed_edit", description: "编辑订阅源" },
+ { command: "feed_del", description: "删除订阅源" },
+ { command: "feed_health", description: "订阅源健康检查" },
+ { command: "read", description: "友链最新文章" },
+ { command: "stats", description: "网站数据" },
+ { command: "help", description: "帮助" },
+]
+```
+
+---
+
+## 十五、其他可考虑的功能
+
+### 15.1 `/random` — 随机图片
+
+利用 API 的 `GET /api/random-image` 接口，可以做一个随机壁纸/图片功能。
+适合在聊天中发一张随机图片，增加趣味性。优先级低。
+
+### 15.2 `/greeting` — 问候语
+
+利用 API 的 `GET /api/ai/greeting` 接口，获取 AI 生成的问候语。
+适合每天早上发一条问候。可以和定时任务结合。优先级低。
+
+### 15.3 公众号同步 `/wechat`
+
+利用 API 的 `POST /api/wechat-material` 接口，在 bot 中直接把文章同步到微信公众号草稿箱。
+当前 write 已有公众号页面，bot 可以加一个 `/wechat slug` 命令。
+优先级中——如果经常在手机上写文章，同步到公众号是个高频操作。
+
+### 15.4 定时任务
+
+利用 Cowork 的 scheduled-tasks 功能，可以设置：
+- 每天早上 9 点发一条问候语 + 友链最新文章摘要
+- 每周检测一次订阅源健康状态
+- 每天自动部署未发布的草稿（可选）
+
+这些功能当前不急，后续按需添加。
+
+
+---
+
+## 十六、确认的补充项
+
+### 16.1 写作键盘更新
+
+加入 `/undo` 和 `/deploy`：
+
+```
+[/preview] [/undo]
+[/publish] [/deploy]
+[/draft] [/cancel]
+[/title] [/categories]
+```
+
+### 16.2 主键盘更新
+
+按钮文字改为纯命令：
+
+```
+[/new] [/list]
+[/links] [/feeds]
+[/stats] [/help]
+```
+
+### 16.3 /stats 增强
+
+显示本地数据 + API 数据：
+
+```
+📊 网站数据
+
+📝 本地文章：128 篇
+🔗 友链：46 个
+📡 订阅源：52 个
+
+📰 友链文章：380 篇（来自 52 个博客）
+🌐 usj.cc
+```
+
+### 16.4 API 不可用降级
+
+所有调用 `api.usj.cc` 的操作统一处理：
+- 超时：10 秒
+- 失败回复："⚠️ API 暂时不可用，请稍后再试"
+- 涉及命令：/links、/link_add、/link_edit、/link_del、/link_toggle、/feeds、/feed_add、/feed_edit、/feed_del、/feed_health、/read、/stats（API 部分）
+
+---
+
+## 十七、完整的 poll.ts 命令解析更新
+
+### 17.1 ARG_COMMANDS 更新
+
+```typescript
+const ARG_COMMANDS = new Set([
+ "new", "title", "categories", "tags", "author",
+ "edit", "view", "delete",
+ "link_add", "link_edit", "link_del", "link_toggle",
+ "feed_add", "feed_edit", "feed_del",
+ "list", "links", "feeds", "read",
+]);
+```
+
+### 17.2 CALLBACK_PREFIXES 更新
+
+```typescript
+const CALLBACK_PREFIXES: Record" + p.slug + "");
+ }
+ const navRow: { text: string; callback_data: string }[] = [];
+ if (page > 1) navRow.push({ text: "◀ 上一页", callback_data: "list_" + (page - 1) });
+ if (page < totalPages) navRow.push({ text: "下一页 ▶", callback_data: "list_" + (page + 1) });
+ await tg("sendMessage", {
+ chat_id: chatId, text: lines.join("\n"), parse_mode: "HTML", disable_web_page_preview: true,
+ reply_markup: navRow.length ? { inline_keyboard: [navRow] } : undefined,
+ });
+ } catch (e: unknown) { await sendMain(chatId, "❌ " + (e instanceof Error ? e.message : String(e))); }
+};
+
+// ---- Articles: View / Title / Author / Preview ----
+
+handlers.view = async (chatId, slug) => {
+ if (!slug) { await sendMain(chatId, "格式：/view slug"); return; }
+ const ip = getLanIP();
+ await tg("sendMessage", {
+ chat_id: chatId,
+ text: "🔖 " + slug + "\n\n📱 http://" + ip + ":1313/" + slug + ".html\n💻 http://localhost:1313/" + slug + ".html",
+ parse_mode: "HTML", disable_web_page_preview: true,
+ reply_markup: { inline_keyboard: [[{ text: "🌐 浏览器打开", url: "http://localhost:1313/" + slug + ".html" }]] },
+ });
+};
+
+handlers.title = async (chatId, newTitle) => {
+ if (!newTitle) { await tg("sendMessage", { chat_id: chatId, text: "请输入新标题：", reply_markup: { force_reply: true, input_field_placeholder: "新标题..." } }); return; }
+ const s = getSession(chatId);
+ s.title = newTitle;
+ await sendWrite(chatId, "✏ 标题已更新：" + newTitle + "");
+};
+
+handlers.author = async (chatId, author) => {
+ getSession(chatId).author = author || DEFAULT_AUTHOR;
+ await sendWrite(chatId, "✍ 作者：" + getSession(chatId).author);
+};
+
+handlers.preview = async (chatId) => {
+ const s = getSession(chatId);
+ if (!s || !s.title) { await sendMain(chatId, "还没开始写。发 /new 开始。"); return; }
+ if (!s.content) { await sendWrite(chatId, "正文为空。"); return; }
+ await sendWrite(chatId, "📝 " + s.title + "\n\n" + truncateText(s.content, 3800));
+};
+
+// ---- Writing: Publish / Draft / Deploy / Sync / Undo / Cancel ----
+
+handlers.publish = async (chatId) => {
+ const s = getSession(chatId);
+ if (!s || !s.title) { await sendMain(chatId, "还没开始写。发 /new 开始。"); return; }
+ if (!s.content) { await sendWrite(chatId, "正文为空，先写点内容再发布。"); return; }
+ try {
+ const title = s.title;
+ await saveSession(s, false);
+ clearSession(chatId);
+ await sendMain(chatId, "✅ 已保存：" + title + "\n\n发 /deploy 推送到线上");
+ } catch (e: unknown) { await sendWrite(chatId, "❌ 保存失败：" + (e instanceof Error ? e.message : String(e))); }
+};
+
+handlers.draft = async (chatId) => {
+ const s = getSession(chatId);
+ if (!s || !s.title) { await sendMain(chatId, "还没开始写。发 /new 开始。"); return; }
+ if (!s.content) { await sendWrite(chatId, "正文为空，先写点内容再保存。"); return; }
+ try {
+ const title = s.title;
+ await saveSession(s, true);
+ clearSession(chatId);
+ await sendMain(chatId, "📄 草稿已保存：" + title + "");
+ } catch (e: unknown) { await sendWrite(chatId, "❌ 保存失败：" + (e instanceof Error ? e.message : String(e))); }
+};
+
+handlers.deploy = async (chatId) => {
+ await sendMessage(chatId, "⏳ 正在部署...", { reply_markup: { remove_keyboard: true } });
+ const result = await deployQueue.enqueue("发布文章");
+ if (result.success) await sendMain(chatId, "🚀 已部署！\n\n🌐 https://usj.cc");
+ else if (result.conflict) await sendMain(chatId, "⚠️ " + (result.error || "远程冲突"));
+ else await sendMain(chatId, "❌ 部署失败：" + (result.error || "未知错误"));
+};
+
+handlers.sync = async (chatId) => {
+ await sendMessage(chatId, "⏳ 正在同步远程...");
+ const result = await deployQueue.sync();
+ if (result.success) await sendMain(chatId, "✅ 同步完成\n\n" + (result.output || "").slice(0, 500));
+ else await sendMain(chatId, "❌ " + (result.error || "同步失败"));
+};
+
+handlers.undo = async (chatId) => {
+ if (!hasSession(chatId)) { await sendMain(chatId, "没有活动的草稿。"); return; }
+ const ok = undoLastChunk(chatId);
+ if (!ok) { await sendWrite(chatId, "没有可撤销的内容。"); return; }
+ const s = getSession(chatId);
+ await sendWrite(chatId, "↩ 已撤销\n\n📝 " + s.title + "\n\n" + (s.content ? truncateText(s.content, 3800) : "（正文为空）"));
+};
+
+handlers.cancel = async (chatId) => {
+ if (!hasSession(chatId)) { await sendMain(chatId, "没有活动的草稿。"); return; }
+ clearSession(chatId);
+ await sendMain(chatId, "✂ 草稿已丢弃。");
+};
+
+// ---- Links ----
+
+handlers.links = async (chatId, pageStr) => {
+ const page = parseInt(pageStr || "1") || 1;
+ const perPage = 10;
+ try {
+ const allLinks = await cachedLinks(true);
+ if (allLinks.length === 0) { await sendMain(chatId, "还没有友链。\n\n添加：/link_add url 名称"); return; }
+ const totalPages = Math.ceil(allLinks.length / perPage);
+ const p = Math.min(page, totalPages);
+ const start = (p - 1) * perPage;
+ const pageLinks = allLinks.slice(start, start + perPage);
+ const lines = ["🔗 友链 共 " + allLinks.length + " 个 · 第 " + p + "/" + totalPages + " 页\n"];
+ for (const l of pageLinks) {
+ const icon = l.hidden ? "🔒" : "🌐";
+ lines.push(icon + " " + (l.name || l.url) + "\n " + l.url);
+ }
+ lines.push("\n/link_add /link_edit /link_del /link_toggle");
+ const navRow: { text: string; callback_data: string }[] = [];
+ if (p > 1) navRow.push({ text: "◀ 上一页", callback_data: "links_" + (p - 1) });
+ if (p < totalPages) navRow.push({ text: "下一页 ▶", callback_data: "links_" + (p + 1) });
+ await tg("sendMessage", {
+ chat_id: chatId, text: lines.join("\n"), parse_mode: "HTML", disable_web_page_preview: true,
+ reply_markup: navRow.length ? { inline_keyboard: [navRow] } : undefined,
+ });
+ } catch (e) { await sendMain(chatId, "⚠️ API 暂时不可用，请稍后再试"); }
+};
+
+handlers.link_add = async (chatId, arg) => {
+ if (!arg) { await tg("sendMessage", { chat_id: chatId, text: "请输入友链信息：\n格式：url 名称", reply_markup: { force_reply: true, input_field_placeholder: "url 名称" } }); return; }
+ const parts = arg.split(/\s+/);
+ let url = parts[0];
+ const name = parts.slice(1).join(" ") || url;
+ if (!url.startsWith("http")) url = "https://" + url;
+ try { await addLink({ name, url }); invalidateByPrefix("links"); await sendMain(chatId, "✅ 友链已添加：" + name); }
+ catch (e) { await sendMain(chatId, "⚠️ API 暂时不可用，请稍后再试"); }
+};
+
+handlers.link_edit = async (chatId, arg) => {
+ if (!arg) { await sendMain(chatId, "格式：/link_edit url\n用 /links 查看友链。"); return; }
+ const s = getSession(chatId);
+ s.originalSlug = arg;
+ await tg("sendMessage", {
+ chat_id: chatId,
+ text: "当前 URL：" + arg + "\n请输入新名称（空则保持不变）：",
+ reply_markup: { force_reply: true, input_field_placeholder: "新名称" },
+ });
+};
+
+handlers.link_del = async (chatId, url) => {
+ if (!url) { await sendMain(chatId, "格式：/link_del url"); return; }
+ try { await deleteLink(url); invalidateByPrefix("links"); await sendMain(chatId, "✅ 已删除：" + url); }
+ catch (e) { await sendMain(chatId, "⚠️ API 暂时不可用，请稍后再试"); }
+};
+
+handlers.link_toggle = async (chatId, url) => {
+ if (!url) { await sendMain(chatId, "格式：/link_toggle url"); return; }
+ try {
+ const allLinks = await cachedLinks(true);
+ const link = allLinks.find((l) => l.url === url);
+ if (!link) { await sendMain(chatId, "❌ 未找到：" + url); return; }
+ await updateLink(url, { hidden: !link.hidden });
+ invalidateByPrefix("links");
+ await sendMain(chatId, (!link.hidden ? "🔒 已隐藏" : "🌐 已显示") + "：" + (link.name || url));
+ } catch (e) { await sendMain(chatId, "⚠️ API 暂时不可用，请稍后再试"); }
+};
+
+// ---- Feeds ----
+
+handlers.feeds = async (chatId, pageStr) => {
+ const page = parseInt(pageStr || "1") || 1;
+ const perPage = 10;
+ try {
+ const allFeeds = await cachedFeeds();
+ if (allFeeds.length === 0) { await sendMain(chatId, "还没有订阅源。\n\n添加：/feed_add url"); return; }
+ const totalPages = Math.ceil(allFeeds.length / perPage);
+ const p = Math.min(page, totalPages);
+ const start = (p - 1) * perPage;
+ const pageFeeds = allFeeds.slice(start, start + perPage);
+ const lines = ["📡 订阅源 共 " + allFeeds.length + " 个 · 第 " + p + "/" + totalPages + " 页\n"];
+ for (const f of pageFeeds) {
+ lines.push("📰 " + (f.feedTitle || f.url) + "\n " + f.url);
+ }
+ lines.push("\n/feed_add /feed_edit /feed_del /feed_health");
+ const navRow: { text: string; callback_data: string }[] = [];
+ if (p > 1) navRow.push({ text: "◀ 上一页", callback_data: "feeds_" + (p - 1) });
+ if (p < totalPages) navRow.push({ text: "下一页 ▶", callback_data: "feeds_" + (p + 1) });
+ await tg("sendMessage", {
+ chat_id: chatId, text: lines.join("\n"), parse_mode: "HTML", disable_web_page_preview: true,
+ reply_markup: navRow.length ? { inline_keyboard: [navRow] } : undefined,
+ });
+ } catch (e) { await sendMain(chatId, "⚠️ API 暂时不可用，请稍后再试"); }
+};
+
+handlers.feed_add = async (chatId, arg) => {
+ if (!arg) { await tg("sendMessage", { chat_id: chatId, text: "请输入订阅源 URL：", reply_markup: { force_reply: true, input_field_placeholder: "https://example.com/rss.xml" } }); return; }
+ const parts = arg.split(/\s+/);
+ const url = parts[0];
+ const feedTitle = parts.slice(1).join(" ") || "";
+ try { await addFeed(url, feedTitle); invalidateByPrefix("feeds"); await sendMain(chatId, "✅ 订阅源已添加：" + url); }
+ catch (e) { await sendMain(chatId, "⚠️ API 暂时不可用，请稍后再试"); }
+};
+
+handlers.feed_edit = async (chatId, arg) => {
+ if (!arg) { await sendMain(chatId, "格式：/feed_edit url\n用 /feeds 查看。"); return; }
+ const s = getSession(chatId);
+ s.originalSlug = arg;
+ await tg("sendMessage", {
+ chat_id: chatId,
+ text: "当前 URL：" + arg + "\n请输入新的订阅信息：\n格式：新URL 新名称",
+ reply_markup: { force_reply: true, input_field_placeholder: "新URL 新名称" },
+ });
+};
+
+handlers.feed_del = async (chatId, url) => {
+ if (!url) { await sendMain(chatId, "格式：/feed_del url"); return; }
+ try { await deleteFeed(url); invalidateByPrefix("feeds"); await sendMain(chatId, "✅ 已删除：" + url); }
+ catch (e) { await sendMain(chatId, "⚠️ API 暂时不可用，请稍后再试"); }
+};
+
+handlers.feed_health = async (chatId) => {
+ try {
+ await sendMessage(chatId, "⏳ 正在检测订阅源...");
+ const result = await cachedHealth();
+ const lines = ["📊 订阅源健康报告\n", "✅ 存活：" + result.alive + " ❌ 异常：" + result.dead];
+ const dead = (result.results || []).filter((r) => !r.ok);
+ if (dead.length > 0) {
+ lines.push("\n❌ 异常站点：");
+ for (const d of dead.slice(0, 10)) {
+ lines.push("🔴 " + d.url + " — " + (d.error || String(d.status)));
+ }
+ }
+ await sendMain(chatId, lines.join("\n"));
+ } catch (e) { await sendMain(chatId, "⚠️ API 暂时不可用，请稍后再试"); }
+};
+
+// ---- Data ----
+
+handlers.stats = async (chatId) => {
+ try {
+ const { total } = listPosts({ perPage: 1 });
+ const allLinks = await cachedLinks(true);
+ const allFeeds = await cachedFeeds();
+ const visibleLinks = allLinks.filter((l) => !l.hidden).length;
+
+ let extra = "";
+ try {
+ const healthRes = await cachedHealth();
+ extra = "\n\n📰 友链博客：" + healthRes.total + " 个";
+ } catch (e) { /* ignore */ }
+
+ await sendMain(chatId,
+ "📊 网站数据\n\n" +
+ "📝 本地文章：" + total + " 篇\n" +
+ "🔗 友链：" + visibleLinks + " 个\n" +
+ "📡 订阅源：" + allFeeds.length + " 个" +
+ extra + "\n\n🌐 usj.cc"
+ );
+ } catch (e) { await sendMain(chatId, "⚠️ API 暂时不可用，请稍后再试"); }
+};
+
+handlers.read = async (chatId, limitStr) => {
+ const limit = parseInt(limitStr || "10") || 10;
+ try {
+ const articles = await cachedArticles(Math.min(limit, 20));
+ if (articles.length === 0) { await sendMain(chatId, "暂无最新文章。"); return; }
+ const lines = ["📰 友链最新文章（" + articles.length + " 篇）\n"];
+ for (const a of articles) {
+ lines.push((a.feedName || "未知") + " — " + a.title + "\n " + a.link);
+ }
+ await tg("sendMessage", {
+ chat_id: chatId, text: lines.join("\n"), parse_mode: "HTML", disable_web_page_preview: true,
+ });
+ } catch (e) { await sendMain(chatId, "⚠️ API 暂时不可用，请稍后再试"); }
+};
+
+export default handlers;
diff --git a/write/src/lib/bot/helpers.ts b/write/src/lib/bot/helpers.ts
new file mode 100644
index 00000000..81f36cad
--- /dev/null
+++ b/write/src/lib/bot/helpers.ts
@@ -0,0 +1,37 @@
+import path from "path";
+import { CONTENT_DIR } from "@/lib/config";
+
+export function makeSlug(title: string): string {
+ const dateStr = new Date().toISOString().slice(0, 10);
+ const slugPart = (title || "untitled")
+ .replace(/[^\w一-鿿㐀-䶿]+/g, "-")
+ .replace(/^-+|-+$/g, "")
+ .toLowerCase() || "post";
+ return dateStr + "-" + slugPart;
+}
+
+export function sessionSummary(s: {
+ title: string;
+ categories: string[];
+ tags: string[];
+ content: string;
+}): string {
+ const lines = s.content ? s.content.split("\n").filter(Boolean).length : 0;
+ const chars = s.content.length;
+ const parts: string[] = [];
+ parts.push(`\u{1f4dd} ${s.title || "未命名"}`);
+ if (s.categories.length) parts.push(`\u{1f4c2} ${s.categories.join("、")}`);
+ if (s.tags.length) parts.push(`\u{1f3f7} ${s.tags.join("、")}`);
+ if (chars) parts.push(`✍ ${lines} 行 ${chars} 字`);
+ return parts.filter(Boolean).join(" · ");
+}
+
+export function getArticleDirPath(slug: string): string {
+ const year = slug.slice(0, 4);
+ return path.join(CONTENT_DIR, year, slug);
+}
+
+export function truncateText(text: string, maxLen: number): string {
+ if (text.length <= maxLen) return text;
+ return text.slice(0, maxLen) + "\n\n... 前 " + maxLen + " 字";
+}
diff --git a/write/src/lib/bot/index.ts b/write/src/lib/bot/index.ts
new file mode 100644
index 00000000..6c6ecbe7
--- /dev/null
+++ b/write/src/lib/bot/index.ts
@@ -0,0 +1,21 @@
+import { startPolling } from "./poll";
+import { TG_TOKEN } from "./config";
+
+const g = globalThis as Record