feat(i18n): Enhance internationalization support and error handling messages

- Added i18n keys for various error and info messages related to task management, user handling, and storage operations.
- Updated error messages in the watch and task handling commands to use i18n for better localization.
- Refactored error handling in the database initialization and user synchronization processes to provide clearer messages.
- Improved logging messages for better clarity and consistency across the application.
- Added comprehensive documentation for AI collaboration and project structure in the repository.

client/bot/handlers/add_task.go

@@ -12,6 +12,8 @@ import (
 	"github.com/gotd/td/tg"
 	"github.com/krau/SaveAny-Bot/client/bot/handlers/utils/msgelem"
 	"github.com/krau/SaveAny-Bot/client/bot/handlers/utils/shortcut"
+	"github.com/krau/SaveAny-Bot/common/i18n"
+	"github.com/krau/SaveAny-Bot/common/i18n/i18nk"
 	"github.com/krau/SaveAny-Bot/common/utils/fsutil"
 	"github.com/krau/SaveAny-Bot/database"
 	"github.com/krau/SaveAny-Bot/pkg/enums/tasktype"
@@ -33,12 +35,14 @@ func handleAddCallback(ctx *ext.Context, update *ext.Update) error {
 	selectedStorage, err := storage.GetStorageByUserIDAndName(ctx, userID, data.SelectedStorName)
 	if err != nil {
 		log.FromContext(ctx).Errorf("Failed to get storage: %s", err)
-		ctx.AnswerCallback(msgelem.AlertCallbackAnswer(queryID, "存储获取失败: "+err.Error()))
+		ctx.AnswerCallback(msgelem.AlertCallbackAnswer(queryID, i18n.T(i18nk.BotMsgCommonErrorGetStorageFailed, map[string]any{
+			"Error": err.Error(),
+		})))
 		return dispatcher.EndGroups
 	}
 	dirs, err := database.GetDirsByUserChatIDAndStorageName(ctx, userID, data.SelectedStorName)
 	if err != nil && !errors.Is(err, gorm.ErrRecordNotFound) {
-		return fmt.Errorf("获取用户目录失败: %w", err)
+		return fmt.Errorf("failed to get user directories: %w", err)
 	}
 
 	if !data.SettedDir && len(dirs) != 0 {
@@ -46,12 +50,14 @@ func handleAddCallback(ctx *ext.Context, update *ext.Update) error {
 		markup, err := msgelem.BuildSetDirMarkupForAdd(dirs, dataid)
 		if err != nil {
 			log.FromContext(ctx).Errorf("Failed to build directory keyboard: %s", err)
-			ctx.AnswerCallback(msgelem.AlertCallbackAnswer(queryID, "目录键盘构建失败: "+err.Error()))
+			ctx.AnswerCallback(msgelem.AlertCallbackAnswer(queryID, i18n.T(i18nk.BotMsgCommonErrorBuildStorageSelectKeyboardFailed, map[string]any{
+				"Error": err.Error(),
+			})))
 			return dispatcher.EndGroups
 		}
 		ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 			ID:          update.CallbackQuery.GetMsgID(),
-			Message:     "请选择要存储到的目录",
+			Message:     i18n.T(i18nk.BotMsgCommonPromptSelectDir, nil),
 			ReplyMarkup: markup,
 		})
 		return dispatcher.EndGroups
@@ -61,7 +67,9 @@ func handleAddCallback(ctx *ext.Context, update *ext.Update) error {
 	if data.DirID != 0 {
 		dir, err := database.GetDirByID(ctx, data.DirID)
 		if err != nil {
-			ctx.AnswerCallback(msgelem.AlertCallbackAnswer(queryID, "获取目录失败: "+err.Error()))
+			ctx.AnswerCallback(msgelem.AlertCallbackAnswer(queryID, i18n.T(i18nk.BotMsgCommonErrorGetDirFailed, map[string]any{
+				"Error": err.Error(),
+			})))
 			return dispatcher.EndGroups
 		}
 		dirPath = dir.Path

client/bot/handlers/cancel_task.go

@@ -8,20 +8,24 @@ import (
 	"github.com/charmbracelet/log"
 	"github.com/gotd/td/tg"
 	"github.com/krau/SaveAny-Bot/client/bot/handlers/utils/msgelem"
+	"github.com/krau/SaveAny-Bot/common/i18n"
+	"github.com/krau/SaveAny-Bot/common/i18n/i18nk"
 	"github.com/krau/SaveAny-Bot/core"
 )
 
 func handleCancelCallback(ctx *ext.Context, update *ext.Update) error {
 	taskid := strings.Split(string(update.CallbackQuery.Data), " ")[1]
 	if err := core.CancelTask(ctx, taskid); err != nil {
-		log.FromContext(ctx).Errorf("error cancelling task %s: %v", taskid, err)
-		ctx.AnswerCallback(msgelem.AlertCallbackAnswer(update.CallbackQuery.GetQueryID(), "取消任务失败: "+err.Error()))
+		log.FromContext(ctx).Errorf("Failed to cancel task %s: %v", taskid, err)
+		ctx.AnswerCallback(msgelem.AlertCallbackAnswer(update.CallbackQuery.GetQueryID(), i18n.T(i18nk.BotMsgCancelErrorCancelFailed, map[string]any{
+			"Error": err.Error(),
+		})))
 		return dispatcher.EndGroups
 	}
 
 	ctx.EditMessage(update.CallbackQuery.GetUserID(), &tg.MessagesEditMessageRequest{
 		ID:      update.CallbackQuery.GetMsgID(),
-		Message: "正在取消任务...",
+		Message: i18n.T(i18nk.BotMsgCancelInfoCancellingTask, nil),
 	})
 
 	return dispatcher.EndGroups
@@ -31,15 +35,19 @@ func handleCancelCmd(ctx *ext.Context, update *ext.Update) error {
 	logger := log.FromContext(ctx)
 	args := strings.Fields(update.EffectiveMessage.Text)
 	if len(args) < 2 {
-		ctx.Reply(update, ext.ReplyTextString("用法: /cancel <task_id>"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCancelUsage, nil)), nil)
 		return dispatcher.EndGroups
 	}
 	taskID := args[1]
 	if err := core.CancelTask(ctx, taskID); err != nil {
 		logger.Errorf("failed to cancel task %s: %v", taskID, err)
-		ctx.Reply(update, ext.ReplyTextString("取消任务失败: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCancelErrorCancelFailed, map[string]any{
+			"Error": err.Error(),
+		})), nil)
 		return dispatcher.EndGroups
 	}
-	ctx.Reply(update, ext.ReplyTextString("已请求取消任务: "+taskID), nil)
+	ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCancelInfoCancelRequested, map[string]any{
+		"TaskID": taskID,
+	})), nil)
 	return dispatcher.EndGroups
 }

client/bot/handlers/dir.go

@@ -18,7 +18,7 @@ func handleDirCmd(ctx *ext.Context, update *ext.Update) error {
 	userChatID := update.GetUserChat().GetID()
 	dirs, err := database.GetUserDirsByChatID(ctx, userChatID)
 	if err != nil {
-		logger.Errorf("获取用户文件夹失败: %s", err)
+		logger.Errorf("Failed to get user directories: %s", err)
 		ctx.Reply(update, ext.ReplyTextString("获取用户文件夹失败"), nil)
 		return dispatcher.EndGroups
 	}
@@ -28,7 +28,7 @@ func handleDirCmd(ctx *ext.Context, update *ext.Update) error {
 	}
 	user, err := database.GetUserByChatID(ctx, update.GetUserChat().GetID())
 	if err != nil {
-		logger.Errorf("获取用户失败: %s", err)
+		logger.Errorf("Failed to get user: %s", err)
 		ctx.Reply(update, ext.ReplyTextString("获取用户失败"), nil)
 		return dispatcher.EndGroups
 	}
@@ -45,7 +45,7 @@ func handleDirCmd(ctx *ext.Context, update *ext.Update) error {
 		}
 
 		if err := database.CreateDirForUser(ctx, user.ID, args[2], args[3]); err != nil {
-			logger.Errorf("创建文件夹失败: %s", err)
+			logger.Errorf("Failed to create directory: %s", err)
 			ctx.Reply(update, ext.ReplyTextString("创建文件夹失败"), nil)
 			return dispatcher.EndGroups
 		}
@@ -62,7 +62,7 @@ func handleDirCmd(ctx *ext.Context, update *ext.Update) error {
 			return dispatcher.EndGroups
 		}
 		if err := database.DeleteDirByID(ctx, uint(dirID)); err != nil {
-			logger.Errorf("删除文件夹失败: %s", err)
+			logger.Errorf("Failed to delete directory: %s", err)
 			ctx.Reply(update, ext.ReplyTextString("删除文件夹失败"), nil)
 			return dispatcher.EndGroups
 		}

client/bot/handlers/link.go

@@ -24,7 +24,7 @@ func handleMessageLink(ctx *ext.Context, update *ext.Update) error {
 	if len(files) == 1 {
 		req, err := msgelem.BuildAddOneSelectStorageMessage(ctx, stors, files[0], replied.ID)
 		if err != nil {
-			logger.Errorf("构建存储选择消息失败: %s", err)
+			logger.Errorf("Failed to build storage selection message: %s", err)
 			editReplied("构建存储选择消息失败: "+err.Error(), nil)
 			return dispatcher.EndGroups
 		}
@@ -35,7 +35,7 @@ func handleMessageLink(ctx *ext.Context, update *ext.Update) error {
 		Files: files,
 	})
 	if err != nil {
-		logger.Errorf("构建存储选择键盘失败: %s", err)
+		logger.Errorf("Failed to build storage selection keyboard: %s", err)
 		editReplied("构建存储选择键盘失败: "+err.Error(), nil)
 		return dispatcher.EndGroups
 	}

client/bot/handlers/media.go

@@ -34,7 +34,7 @@ func handleMediaMessage(ctx *ext.Context, update *ext.Update) error {
 	stors := storage.GetUserStorages(ctx, userId)
 	req, err := msgelem.BuildAddOneSelectStorageMessage(ctx, stors, file, msg.ID)
 	if err != nil {
-		logger.Errorf("构建存储选择消息失败: %s", err)
+		logger.Errorf("Failed to build storage selection message: %s", err)
 		ctx.Reply(update, ext.ReplyTextString("构建存储选择消息失败: "+err.Error()), nil)
 		return dispatcher.EndGroups
 	}

client/bot/handlers/media_group.go

@@ -111,7 +111,7 @@ func processMediaGroup(ctx *ext.Context, update *ext.Update, groupID int64) {
 		AsBatch: len(items) > 1,
 	})
 	if err != nil {
-		logger.Errorf("构建存储选择键盘失败: %s", err)
+		logger.Errorf("Failed to build storage selection keyboard: %s", err)
 		ctx.EditMessage(userId, &tg.MessagesEditMessageRequest{
 			ID:      msg.ID,
 			Message: "构建存储选择键盘失败: " + err.Error(),

client/bot/handlers/rule.go

@@ -21,7 +21,7 @@ func handleRuleCmd(ctx *ext.Context, update *ext.Update) error {
 	userChatID := update.GetUserChat().GetID()
 	user, err := database.GetUserByChatID(ctx, userChatID)
 	if err != nil {
-		logger.Errorf("获取用户规则失败: %s", err)
+		logger.Errorf("Failed to get user rules: %s", err)
 		ctx.Reply(update, ext.ReplyTextString("获取用户规则失败"), nil)
 		return dispatcher.EndGroups
 	}

client/bot/handlers/save.go

@@ -1,7 +1,6 @@
 package handlers
 
 import (
-	"fmt"
 	"regexp"
 	"strings"
 
@@ -52,8 +51,8 @@ func handleSaveCmd(ctx *ext.Context, update *ext.Update) error {
 	stors := storage.GetUserStorages(ctx, userId)
 	req, err := msgelem.BuildAddOneSelectStorageMessage(ctx, stors, file, msg.ID)
 	if err != nil {
-		logger.Errorf("构建存储选择消息失败: %s", err)
-		ctx.Reply(update, ext.ReplyTextString("构建存储选择消息失败: "+err.Error()), nil)
+		logger.Errorf("Failed to build storage selection message: %s", err)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorBuildStorageSelectMessageFailed, map[string]any{"Error": err.Error()})), nil)
 		return dispatcher.EndGroups
 	}
 	ctx.EditMessage(update.EffectiveChat().GetID(), req)
@@ -97,35 +96,35 @@ func handleBatchSave(ctx *ext.Context, update *ext.Update, args []string) error
 		var err error
 		filter, err = regexp.Compile(filterStr)
 		if err != nil {
-			ctx.Reply(update, ext.ReplyTextString("无效的正则表达式: "+err.Error()), nil)
+			ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorInvalidRegex, map[string]any{"Error": err.Error()})), nil)
 			return dispatcher.EndGroups
 		}
 	}
 	startID, endID, err := strutil.ParseIntStrRange(msgIdRangeArg, "-")
 	if err != nil {
-		ctx.Reply(update, ext.ReplyTextString("无效的消息ID范围: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorInvalidMsgIdRange, map[string]any{"Error": err.Error()})), nil)
 		return dispatcher.EndGroups
 	}
 	chatID, err := tgutil.ParseChatID(ctx, chatArg)
 	if err != nil {
-		ctx.Reply(update, ext.ReplyTextString("无效的ID或用户名: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorInvalidIdOrUsername, map[string]any{"Error": err.Error()})), nil)
 		return dispatcher.EndGroups
 	}
 
-	replied, err := ctx.Reply(update, ext.ReplyTextString("正在获取消息..."), nil)
+	replied, err := ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonInfoFetchingMessages)), nil)
 	if err != nil {
-		log.FromContext(ctx).Errorf("回复失败: %s", err)
+		log.FromContext(ctx).Errorf("Failed to reply: %s", err)
 		return dispatcher.EndGroups
 	}
 
 	// [TODO]: generator istead of get all messages
 	msgs, err := tgutil.GetMessagesRange(ctx, chatID, int(startID), int(endID))
 	if err != nil {
-		ctx.Reply(update, ext.ReplyTextString("获取消息失败: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorGetMessagesFailed, map[string]any{"Error": err.Error()})), nil)
 		return dispatcher.EndGroups
 	}
 	if len(msgs) == 0 {
-		ctx.Reply(update, ext.ReplyTextString("没有找到指定范围内的消息"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorNoMessagesInRange)), nil)
 		return dispatcher.EndGroups
 	}
 	files := make([]tfile.TGFileMessage, 0, len(msgs))
@@ -144,7 +143,7 @@ func handleBatchSave(ctx *ext.Context, update *ext.Update, args []string) error
 		}
 		file, err := tfile.FromMediaMessage(media, ctx.Raw, msg, tfile.WithNameIfEmpty(tgutil.GenFileNameFromMessage(*msg)))
 		if err != nil {
-			log.FromContext(ctx).Errorf("获取文件失败: %s", err)
+			log.FromContext(ctx).Errorf("Failed to get file from message: %s", err)
 			continue
 		}
 		if filter != nil {
@@ -160,7 +159,7 @@ func handleBatchSave(ctx *ext.Context, update *ext.Update, args []string) error
 		files = append(files, file)
 	}
 	if len(files) == 0 {
-		ctx.Reply(update, ext.ReplyTextString("没有找到指定范围内的可保存消息"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorNoSavableMessagesInRange)), nil)
 		return dispatcher.EndGroups
 	}
 	stor := storage.FromContext(ctx)
@@ -171,16 +170,16 @@ func handleBatchSave(ctx *ext.Context, update *ext.Update, args []string) error
 			Files: files,
 		})
 		if err != nil {
-			log.FromContext(ctx).Errorf("构建存储选择键盘失败: %s", err)
+			log.FromContext(ctx).Errorf("Failed to build storage selection keyboard: %s", err)
 			ctx.EditMessage(update.EffectiveChat().GetID(), &tg.MessagesEditMessageRequest{
-				ID:      replied.ID,
-				Message: "构建存储选择键盘失败: " + err.Error(),
+					ID: replied.ID,
+					Message: i18n.T(i18nk.BotMsgCommonErrorBuildStorageSelectKeyboardFailed, map[string]any{"Error": err.Error()}),
 			})
 			return dispatcher.EndGroups
 		}
 		ctx.EditMessage(update.EffectiveChat().GetID(), &tg.MessagesEditMessageRequest{
-			ID:          replied.ID,
-			Message:     fmt.Sprintf("找到 %d 个文件, 请选择存储位置", len(files)),
+				ID: replied.ID,
+				Message: i18n.T(i18nk.BotMsgCommonInfoFoundFilesSelectStorage, map[string]any{"Count": len(files)}),
 			ReplyMarkup: markup,
 		})
 		return dispatcher.EndGroups

client/bot/handlers/tasks.go

@@ -1,7 +1,6 @@
 package handlers
 
 import (
-	"fmt"
 	"strings"
 	"time"
 
@@ -9,6 +8,8 @@ import (
 	"github.com/celestix/gotgproto/ext"
 	"github.com/charmbracelet/log"
 	"github.com/gotd/td/telegram/message/styling"
+	"github.com/krau/SaveAny-Bot/common/i18n"
+	"github.com/krau/SaveAny-Bot/common/i18n/i18nk"
 	"github.com/krau/SaveAny-Bot/core"
 )
 
@@ -27,21 +28,21 @@ func handleTaskCmd(ctx *ext.Context, update *ext.Update) error {
 		showQueuedTasks(ctx, update)
 	case "cancel", "c":
 		if len(args) < 3 {
-			ctx.Reply(update, ext.ReplyTextString("用法: /tasks cancel <task_id>"), nil)
+			ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgTasksUsageCancel)), nil)
 			return dispatcher.EndGroups
 		}
 		taskID := args[2]
 		if err := core.CancelTask(ctx, taskID); err != nil {
-			logger.Errorf("取消任务 %s 失败: %v", taskID, err)
-			ctx.Reply(update, ext.ReplyTextString("取消任务失败: "+err.Error()), nil)
+			logger.Errorf("Failed to cancel task %s: %v", taskID, err)
+			ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgTasksCancelFailed, map[string]any{"Error": err.Error()})), nil)
 			return dispatcher.EndGroups
 		}
 		ctx.Reply(update, ext.ReplyTextStyledTextArray([]styling.StyledTextOption{
-			styling.Plain("已请求取消任务: "),
+				styling.Plain(i18n.T(i18nk.BotMsgTasksCancelRequestedPrefix)),
 			styling.Code(taskID),
 		}), nil)
 	default:
-		ctx.Reply(update, ext.ReplyTextString("用法: /tasks [running|queued|cancel <task_id>]"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgTasksUsage)), nil)
 	}
 	return dispatcher.EndGroups
 }
@@ -49,28 +50,28 @@ func handleTaskCmd(ctx *ext.Context, update *ext.Update) error {
 func showRunningTasks(ctx *ext.Context, update *ext.Update) {
 	tasks := core.GetRunningTasks(ctx)
 	if len(tasks) == 0 {
-		ctx.Reply(update, ext.ReplyTextString("当前没有正在运行的任务"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgTasksRunningEmpty)), nil)
 		return
 	}
 	opts := make([]styling.StyledTextOption, 0, 2+len(tasks)*4)
 	opts = append(opts,
-		styling.Bold("当前正在运行的任务:"),
-		styling.Plain(fmt.Sprintf("\n总数: %d\n", len(tasks))),
+		styling.Bold(i18n.T(i18nk.BotMsgTasksRunningTitle)),
+		styling.Plain(i18n.T(i18nk.BotMsgTasksTotalPrefix, map[string]any{"Count": len(tasks)})),
 	)
 	for _, t := range tasks {
 		created := t.Created.In(time.Local).Format("2006-01-02 15:04:05")
-		status := "运行中"
+		status := i18n.T(i18nk.BotMsgTasksStatusRunning)
 		if t.Cancelled {
-			status = "已请求取消"
+			status = i18n.T(i18nk.BotMsgTasksStatusCancelRequested)
 		}
 		opts = append(opts,
-			styling.Plain("\nID: "),
+			styling.Plain("\n"+i18n.T(i18nk.BotMsgTasksFieldId)),
 			styling.Code(t.ID),
-			styling.Plain("\n名称: "),
+			styling.Plain("\n"+i18n.T(i18nk.BotMsgTasksFieldTitle)),
 			styling.Code(t.Title),
-			styling.Plain("\n创建时间: "),
+			styling.Plain("\n"+i18n.T(i18nk.BotMsgTasksFieldCreated)),
 			styling.Code(created),
-			styling.Plain("\n状态: "),
+			styling.Plain("\n"+i18n.T(i18nk.BotMsgTasksFieldStatus)),
 			styling.Code(status),
 		)
 	}
@@ -80,32 +81,32 @@ func showRunningTasks(ctx *ext.Context, update *ext.Update) {
 func showQueuedTasks(ctx *ext.Context, update *ext.Update) {
 	tasks := core.GetQueuedTasks(ctx)
 	if len(tasks) == 0 {
-		ctx.Reply(update, ext.ReplyTextString("当前没有排队中的任务"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgTasksQueuedEmpty)), nil)
 		return
 	}
 	opts := make([]styling.StyledTextOption, 0, 2+len(tasks)*3)
 	opts = append(opts,
-		styling.Bold("当前排队中的任务:"),
-		styling.Plain(fmt.Sprintf("\n总数: %d\n", len(tasks))),
+		styling.Bold(i18n.T(i18nk.BotMsgTasksQueuedTitle)),
+		styling.Plain(i18n.T(i18nk.BotMsgTasksTotalPrefix, map[string]any{"Count": len(tasks)})),
 	)
 	for _, t := range tasks {
 		created := t.Created.In(time.Local).Format("2006-01-02 15:04:05")
-		status := "排队中"
+		status := i18n.T(i18nk.BotMsgTasksStatusQueued)
 		if t.Cancelled {
-			status = "已请求取消"
+			status = i18n.T(i18nk.BotMsgTasksStatusCancelRequested)
 		}
 		opts = append(opts,
-			styling.Plain("\nID: "),
+			styling.Plain("\n"+i18n.T(i18nk.BotMsgTasksFieldId)),
 			styling.Code(t.ID),
-			styling.Plain("\n名称: "),
+			styling.Plain("\n"+i18n.T(i18nk.BotMsgTasksFieldTitle)),
 			styling.Code(t.Title),
-			styling.Plain("\n创建时间: "),
+			styling.Plain("\n"+i18n.T(i18nk.BotMsgTasksFieldCreated)),
 			styling.Code(created),
-			styling.Plain("\n状态: "),
+			styling.Plain("\n"+i18n.T(i18nk.BotMsgTasksFieldStatus)),
 			styling.Code(status),
 		)
 		if len(tasks) > 10 {
-			opts = append(opts, styling.Plain("\n...\n只显示前 10 个任务, 共 "+fmt.Sprintf("%d", len(tasks))+" 个任务"))
+			opts = append(opts, styling.Plain("\n"+i18n.T(i18nk.BotMsgTasksTruncatedNote, map[string]any{"Count": len(tasks)})))
 			break
 		}
 	}

client/bot/handlers/telegraph.go

@@ -34,7 +34,7 @@ func handleTelegraphUrlMessage(ctx *ext.Context, update *ext.Update) error {
 		TphPics:     result.Pics,
 	})
 	if err != nil {
-		logger.Errorf("构建存储选择键盘失败: %s", err)
+		logger.Errorf("Failed to build storage selection keyboard: %s", err)
 		ctx.Reply(update, ext.ReplyTextString("构建存储选择键盘失败: "+err.Error()), nil)
 		return dispatcher.EndGroups
 	}

client/bot/handlers/utils/shortcut/message.go

@@ -17,6 +17,8 @@ import (
 	"github.com/krau/SaveAny-Bot/client/bot/handlers/utils/re"
 	uc "github.com/krau/SaveAny-Bot/client/user"
 	"github.com/krau/SaveAny-Bot/common/cache"
+	"github.com/krau/SaveAny-Bot/common/i18n"
+	"github.com/krau/SaveAny-Bot/common/i18n/i18nk"
 	"github.com/krau/SaveAny-Bot/common/utils/tgutil"
 	"github.com/krau/SaveAny-Bot/common/utils/tphutil"
 	"github.com/krau/SaveAny-Bot/config"
@@ -36,7 +38,7 @@ func GetFileFromMessageWithReply(ctx *ext.Context, update *ext.Update, message *
 		return nil, nil, dispatcher.ContinueGroups
 	}
 
-	replied, err = ctx.Reply(update, ext.ReplyTextString("正在获取文件信息..."), nil)
+	replied, err = ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonInfoFetchingFileInfo, nil)), nil)
 	if err != nil {
 		logger.Errorf("Failed to reply: %s", err)
 		return nil, nil, dispatcher.EndGroups
@@ -52,7 +54,9 @@ func GetFileFromMessageWithReply(ctx *ext.Context, update *ext.Update, message *
 	file, err = tfile.FromMediaMessage(media, ctx.Raw, message, tfileopts...)
 	if err != nil {
 		logger.Errorf("Failed to get file from media: %s", err)
-		ctx.Reply(update, ext.ReplyTextString("获取文件失败: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorGetFileFailed, map[string]any{
+			"Error": err.Error(),
+		})), nil)
 		return nil, nil, dispatcher.EndGroups
 	}
 	return replied, file, nil
@@ -68,7 +72,7 @@ func GetFilesFromUpdateLinkMessageWithReplyEdit(ctx *ext.Context, update *ext.Up
 		logger.Warn("no matched message links but called handleMessageLink")
 		return nil, nil, nil, dispatcher.EndGroups
 	}
-	replied, err = ctx.Reply(update, ext.ReplyTextString("正在获取消息..."), nil)
+	replied, err = ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonInfoFetchingMessages, nil)), nil)
 	if err != nil {
 		logger.Errorf("failed to reply: %s", err)
 		return nil, nil, nil, dispatcher.EndGroups
@@ -85,7 +89,9 @@ func GetFilesFromUpdateLinkMessageWithReplyEdit(ctx *ext.Context, update *ext.Up
 	user, err := database.GetUserByChatID(ctx, update.GetUserChat().GetID())
 	if err != nil {
 		logger.Errorf("failed to get user from db: %s", err)
-		editReplied("获取用户信息失败: "+err.Error(), nil)
+		editReplied(i18n.T(i18nk.BotMsgCommonErrorGetUserInfoFailed, map[string]any{
+			"Error": err.Error(),
+		}), nil)
 		return nil, nil, nil, dispatcher.EndGroups
 	}
 	files = make([]tfile.TGFileMessage, 0, len(msgLinks))
@@ -146,7 +152,7 @@ func GetFilesFromUpdateLinkMessageWithReplyEdit(ctx *ext.Context, update *ext.Up
 		}
 	}
 	if len(files) == 0 {
-		editReplied("没有找到可保存的文件", nil)
+		editReplied(i18n.T(i18nk.BotMsgCommonErrorNoSavableFilesFound, nil), nil)
 		return nil, nil, nil, dispatcher.EndGroups
 	}
 	return replied, files, editReplied, nil
@@ -157,7 +163,7 @@ func GetCallbackDataWithAnswer[DataType any](ctx *ext.Context, update *ext.Updat
 	if !ok {
 		log.FromContext(ctx).Warnf("Invalid data ID: %s", dataid)
 		queryID := update.CallbackQuery.GetQueryID()
-		ctx.AnswerCallback(msgelem.AlertCallbackAnswer(queryID, "数据已过期或无效"))
+		ctx.AnswerCallback(msgelem.AlertCallbackAnswer(queryID, i18n.T(i18nk.BotMsgCommonErrorDataExpired, nil)))
 		var zero DataType
 		return zero, dispatcher.EndGroups
 	}
@@ -182,11 +188,13 @@ func GetTphPicsFromMessageWithReply(ctx *ext.Context, update *ext.Update) (*type
 	tphdir, err := url.PathUnescape(pagepath)
 	if err != nil {
 		logger.Errorf("Failed to unescape telegraph path: %s", err)
-		ctx.Reply(update, ext.ReplyTextString("解析 telegraph 路径失败: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorParseTelegraphPathFailed, map[string]any{
+			"Error": err.Error(),
+		})), nil)
 		return nil, nil, dispatcher.EndGroups
 	}
 	tphdir = strings.TrimSpace(tphdir)
-	msg, err := ctx.Reply(update, ext.ReplyTextString("正在获取 telegraph 页面..."), nil)
+	msg, err := ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonInfoFetchingTelegraphPage, nil)), nil)
 	if err != nil {
 		logger.Errorf("Failed to reply to update: %s", err)
 		return nil, nil, dispatcher.EndGroups
@@ -195,7 +203,9 @@ func GetTphPicsFromMessageWithReply(ctx *ext.Context, update *ext.Update) (*type
 	page, err := tphutil.DefaultClient().GetPage(ctx, pagepath)
 	if err != nil {
 		logger.Errorf("Failed to get telegraph page: %s", err)
-		ctx.Reply(update, ext.ReplyTextString("获取 telegraph 页面失败: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorGetTelegraphPageFailed, map[string]any{
+			"Error": err.Error(),
+		})), nil)
 		return nil, nil, dispatcher.EndGroups
 	}
 	imgs := make([]string, 0)
@@ -229,7 +239,7 @@ func GetTphPicsFromMessageWithReply(ctx *ext.Context, update *ext.Update) (*type
 	}
 	if len(imgs) == 0 {
 		logger.Warn("No images found in telegraph page")
-		ctx.Reply(update, ext.ReplyTextString("在 telegraph 页面中未找到图片"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorNoImagesInTelegraphPage, nil)), nil)
 		return nil, nil, dispatcher.EndGroups
 	}
 	return msg, &TelegraphResult{

client/bot/handlers/utils/shortcut/parsed.go

@@ -6,9 +6,11 @@ import (
 	"github.com/charmbracelet/log"
 	"github.com/gotd/td/tg"
 	"github.com/krau/SaveAny-Bot/client/bot/handlers/utils/msgelem"
+	"github.com/krau/SaveAny-Bot/common/i18n"
+	"github.com/krau/SaveAny-Bot/common/i18n/i18nk"
 	"github.com/krau/SaveAny-Bot/common/utils/tgutil"
 	"github.com/krau/SaveAny-Bot/core"
-	"github.com/krau/SaveAny-Bot/core/tasks/parsed"
+	parsed "github.com/krau/SaveAny-Bot/core/tasks/parsed"
 	"github.com/krau/SaveAny-Bot/pkg/parser"
 	"github.com/krau/SaveAny-Bot/storage"
 	"github.com/rs/xid"
@@ -21,7 +23,9 @@ func CreateAndAddParsedTaskWithEdit(ctx *ext.Context, stor storage.Storage, dirP
 		log.FromContext(ctx).Errorf("Failed to add task: %s", err)
 		ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 			ID:      msgID,
-			Message: "任务添加失败: " + err.Error(),
+			Message: i18n.T(i18nk.BotMsgCommonErrorTaskAddFailed, map[string]any{
+				"Error": err.Error(),
+			}),
 		})
 		return dispatcher.EndGroups
 	}

client/bot/handlers/utils/shortcut/tftask.go

@@ -1,7 +1,6 @@
 package shortcut
 
 import (
-	"fmt"
 	"path"
 	"strings"
 
@@ -11,6 +10,8 @@ import (
 	"github.com/gotd/td/tg"
 	"github.com/krau/SaveAny-Bot/client/bot/handlers/utils/msgelem"
 	"github.com/krau/SaveAny-Bot/client/bot/handlers/utils/ruleutil"
+	"github.com/krau/SaveAny-Bot/common/i18n"
+	"github.com/krau/SaveAny-Bot/common/i18n/i18nk"
 	"github.com/krau/SaveAny-Bot/common/utils/tgutil"
 	"github.com/krau/SaveAny-Bot/core"
 	"github.com/krau/SaveAny-Bot/core/tasks/batchtfile"
@@ -29,7 +30,9 @@ func CreateAndAddTGFileTaskWithEdit(ctx *ext.Context, userID int64, stor storage
 		logger.Errorf("Failed to get user by chat ID: %s", err)
 		ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 			ID:      trackMsgID,
-			Message: "获取用户失败: " + err.Error(),
+			Message: i18n.T(i18nk.BotMsgCommonErrorGetUserWithErrFailed, map[string]any{
+				"Error": err.Error(),
+			}),
 		})
 		return dispatcher.EndGroups
 	}
@@ -47,7 +50,9 @@ func CreateAndAddTGFileTaskWithEdit(ctx *ext.Context, userID int64, stor storage
 				logger.Errorf("Failed to get storage by user ID and name: %s", err)
 				ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 					ID:      trackMsgID,
-					Message: "获取存储失败: " + err.Error(),
+					Message: i18n.T(i18nk.BotMsgCommonErrorGetStorageFailed, map[string]any{
+						"Error": err.Error(),
+					}),
 				})
 				return dispatcher.EndGroups
 			}
@@ -65,7 +70,9 @@ startCreateTask:
 		logger.Errorf("create task failed: %s", err)
 		ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 			ID:      trackMsgID,
-			Message: "创建任务失败: " + err.Error(),
+			Message: i18n.T(i18nk.BotMsgCommonErrorTaskCreateFailed, map[string]any{
+				"Error": err.Error(),
+			}),
 		})
 		return dispatcher.EndGroups
 	}
@@ -73,7 +80,9 @@ startCreateTask:
 		logger.Errorf("add task failed: %s", err)
 		ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 			ID:      trackMsgID,
-			Message: "添加任务失败: " + err.Error(),
+			Message: i18n.T(i18nk.BotMsgCommonErrorTaskAddFailed, map[string]any{
+				"Error": err.Error(),
+			}),
 		})
 		return dispatcher.EndGroups
 	}
@@ -95,7 +104,9 @@ func CreateAndAddBatchTGFileTaskWithEdit(ctx *ext.Context, userID int64, stor st
 		logger.Errorf("Failed to get user by chat ID: %s", err)
 		ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 			ID:      trackMsgID,
-			Message: "获取用户失败: " + err.Error(),
+			Message: i18n.T(i18nk.BotMsgCommonErrorGetUserWithErrFailed, map[string]any{
+				"Error": err.Error(),
+			}),
 		})
 		return dispatcher.EndGroups
 	}
@@ -132,7 +143,9 @@ func CreateAndAddBatchTGFileTaskWithEdit(ctx *ext.Context, userID int64, stor st
 				logger.Errorf("Failed to get storage by user ID and name: %s", err)
 				ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 					ID:      trackMsgID,
-					Message: "获取存储失败: " + err.Error(),
+					Message: i18n.T(i18nk.BotMsgCommonErrorGetStorageFailed, map[string]any{
+						"Error": err.Error(),
+					}),
 				})
 				return dispatcher.EndGroups
 			}
@@ -144,7 +157,9 @@ func CreateAndAddBatchTGFileTaskWithEdit(ctx *ext.Context, userID int64, stor st
 				logger.Errorf("Failed to create task element: %s", err)
 				ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 					ID:      trackMsgID,
-					Message: "任务创建失败: " + err.Error(),
+						Message: i18n.T(i18nk.BotMsgCommonErrorTaskCreateFailed, map[string]any{
+							"Error": err.Error(),
+						}),
 				})
 				return dispatcher.EndGroups
 			}
@@ -179,7 +194,9 @@ func CreateAndAddBatchTGFileTaskWithEdit(ctx *ext.Context, userID int64, stor st
 				logger.Errorf("Failed to create task element for album file: %s", err)
 				ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 					ID:      trackMsgID,
-					Message: "任务创建失败: " + err.Error(),
+					Message: i18n.T(i18nk.BotMsgCommonErrorTaskCreateFailed, map[string]any{
+						"Error": err.Error(),
+					}),
 				})
 				return dispatcher.EndGroups
 			}
@@ -194,13 +211,17 @@ func CreateAndAddBatchTGFileTaskWithEdit(ctx *ext.Context, userID int64, stor st
 		logger.Errorf("Failed to add batch task: %s", err)
 		ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 			ID:      trackMsgID,
-			Message: "批量任务添加失败: " + err.Error(),
+			Message: i18n.T(i18nk.BotMsgCommonErrorTaskAddFailed, map[string]any{
+				"Error": err.Error(),
+			}),
 		})
 		return dispatcher.EndGroups
 	}
 	ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 		ID:          trackMsgID,
-		Message:     fmt.Sprintf("已添加批量任务, 共 %d 个文件", len(files)),
+		Message:     i18n.T(i18nk.BotMsgCommonInfoBatchTasksAdded, map[string]any{
+			"Count": len(files),
+		}),
 		ReplyMarkup: nil,
 	})
 	return dispatcher.EndGroups

client/bot/handlers/utils/shortcut/tphtask.go

@@ -6,6 +6,8 @@ import (
 	"github.com/charmbracelet/log"
 	"github.com/gotd/td/tg"
 	"github.com/krau/SaveAny-Bot/client/bot/handlers/utils/msgelem"
+	"github.com/krau/SaveAny-Bot/common/i18n"
+	"github.com/krau/SaveAny-Bot/common/i18n/i18nk"
 	"github.com/krau/SaveAny-Bot/common/utils/tgutil"
 	"github.com/krau/SaveAny-Bot/common/utils/tphutil"
 	"github.com/krau/SaveAny-Bot/core"
@@ -38,7 +40,9 @@ func CreateAndAddtelegraphWithEdit(
 		log.FromContext(ctx).Errorf("Failed to add task: %s", err)
 		ctx.EditMessage(userID, &tg.MessagesEditMessageRequest{
 			ID:      trackMsgID,
-			Message: "任务添加失败: " + err.Error(),
+			Message: i18n.T(i18nk.BotMsgCommonErrorTaskAddFailed, map[string]any{
+				"Error": err.Error(),
+			}),
 		})
 		return dispatcher.EndGroups
 	}

client/bot/handlers/watch.go

@@ -34,18 +34,18 @@ func handleWatchCmd(ctx *ext.Context, update *ext.Update) error {
 	userChatID := update.GetUserChat().GetID()
 	user, err := database.GetUserByChatID(ctx, userChatID)
 	if err != nil {
-		logger.Errorf("获取用户失败: %s", err)
-		ctx.Reply(update, ext.ReplyTextString("获取用户失败"), nil)
+		logger.Errorf("Failed to get user: %s", err)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorGetUserFailed)), nil)
 		return dispatcher.EndGroups
 	}
 	if user.DefaultStorage == "" {
-		ctx.Reply(update, ext.ReplyTextString("请先设置默认存储, 使用 /storage 命令"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorDefaultStorageNotSet)), nil)
 		return dispatcher.EndGroups
 	}
 	chatArg := args[1]
 	chatID, err := tgutil.ParseChatID(ctx, chatArg)
 	if err != nil {
-		ctx.Reply(update, ext.ReplyTextString("无效的ID或用户名: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorInvalidIdOrUsername, map[string]any{"Error": err.Error()})), nil)
 		return dispatcher.EndGroups
 	}
 	watching, err := user.WatchingChat(ctx, chatID)
@@ -54,7 +54,7 @@ func handleWatchCmd(ctx *ext.Context, update *ext.Update) error {
 		return dispatcher.EndGroups
 	}
 	if watching {
-		ctx.Reply(update, ext.ReplyTextString("已经在监听此聊天"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgWatchInfoAlreadyWatchingChat)), nil)
 		return dispatcher.EndGroups
 	}
 	filter := ""
@@ -63,19 +63,19 @@ func handleWatchCmd(ctx *ext.Context, update *ext.Update) error {
 		filterType := strings.Split(filterArg, ":")[0]
 		filterData := strings.Split(filterArg, ":")[1]
 		if filterType == "" || filterData == "" {
-			ctx.Reply(update, ext.ReplyTextString("过滤器格式错误, 请使用 <过滤器类型>:<表达式>"), nil)
+			ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgWatchErrorFilterFormatInvalid)), nil)
 			return dispatcher.EndGroups
 		}
 		switch filterType {
 		case "msgre":
 			_, err := regexp.Compile(filterData)
 			if err != nil {
-				ctx.Reply(update, ext.ReplyTextString("正则表达式格式错误: "+err.Error()), nil)
+				ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorInvalidRegex, map[string]any{"Error": err.Error()})), nil)
 				return dispatcher.EndGroups
 			}
 			filter = filterType + ":" + filterData
 		default:
-			ctx.Reply(update, ext.ReplyTextString("不支持的过滤器类型, 请参阅文档"), nil)
+			ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgWatchErrorFilterTypeUnsupported)), nil)
 			return dispatcher.EndGroups
 		}
 	}
@@ -85,10 +85,10 @@ func handleWatchCmd(ctx *ext.Context, update *ext.Update) error {
 		Filter: filter,
 	}); err != nil {
 		logger.Errorf("Failed to watch chat %d: %s", chatID, err)
-		ctx.Reply(update, ext.ReplyTextString("监听聊天失败: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgWatchErrorWatchChatFailed, map[string]any{"Error": err.Error()})), nil)
 		return dispatcher.EndGroups
 	}
-	ctx.Reply(update, ext.ReplyTextString("已开始监听聊天: "+chatArg), nil)
+	ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgWatchInfoWatchChatStarted, map[string]any{"Chat": chatArg})), nil)
 	return dispatcher.EndGroups
 }
 
@@ -97,22 +97,22 @@ func handleLswatchCmd(ctx *ext.Context, update *ext.Update) error {
 	userChatID := update.GetUserChat().GetID()
 	user, err := database.GetUserByChatID(ctx, userChatID)
 	if err != nil {
-		logger.Errorf("获取用户失败: %s", err)
-		ctx.Reply(update, ext.ReplyTextString("获取用户失败"), nil)
+		logger.Errorf("Failed to get user: %s", err)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorGetUserFailed)), nil)
 		return dispatcher.EndGroups
 	}
 	chats := user.WatchChats
 	if len(chats) == 0 {
-		ctx.Reply(update, ext.ReplyTextString("当前没有监听任何聊天"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgWatchInfoWatchListEmpty)), nil)
 		return dispatcher.EndGroups
 	}
 	var sb strings.Builder
-	sb.WriteString("当前监听的聊天:\n")
+	sb.WriteString(i18n.T(i18nk.BotMsgWatchInfoWatchListHeader))
 	for _, chat := range chats {
 		sb.WriteString("- ")
 		sb.WriteString(fmt.Sprintf("%d", chat.ChatID))
 		if chat.Filter != "" {
-			sb.WriteString(" (过滤器: ")
+			sb.WriteString(i18n.T(i18nk.BotMsgWatchInfoWatchListFilterPrefix))
 			sb.WriteString(chat.Filter)
 			sb.WriteString(")")
 		}
@@ -126,28 +126,28 @@ func handleUnwatchCmd(ctx *ext.Context, update *ext.Update) error {
 	logger := log.FromContext(ctx)
 	args := strings.Split(update.EffectiveMessage.Text, " ")
 	if len(args) < 2 {
-		ctx.Reply(update, ext.ReplyTextString("请提供要取消监听的聊天ID或用户名"), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgWatchErrorUnwatchNoChatProvided)), nil)
 		return dispatcher.EndGroups
 	}
 	userChatID := update.GetUserChat().GetID()
 	user, err := database.GetUserByChatID(ctx, userChatID)
 	if err != nil {
-		logger.Errorf("获取用户失败: %s", err)
-		ctx.Reply(update, ext.ReplyTextString("获取用户失败"), nil)
+		logger.Errorf("Failed to get user: %s", err)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorGetUserFailed)), nil)
 		return dispatcher.EndGroups
 	}
 	chatArg := args[1]
 	chatID, err := tgutil.ParseChatID(ctx, chatArg)
 	if err != nil {
-		ctx.Reply(update, ext.ReplyTextString("无效的ID或用户名: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgCommonErrorInvalidIdOrUsername, map[string]any{"Error": err.Error()})), nil)
 		return dispatcher.EndGroups
 	}
 	if err := user.UnwatchChat(ctx, chatID); err != nil {
 		logger.Errorf("Failed to unwatch chat %d: %s", chatID, err)
-		ctx.Reply(update, ext.ReplyTextString("取消监听聊天失败: "+err.Error()), nil)
+		ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgWatchErrorUnwatchChatFailed, map[string]any{"Error": err.Error()})), nil)
 		return dispatcher.EndGroups
 	}
-	ctx.Reply(update, ext.ReplyTextString("已取消监听聊天: "+chatArg), nil)
+	ctx.Reply(update, ext.ReplyTextString(i18n.T(i18nk.BotMsgWatchInfoWatchChatStopped, map[string]any{"Chat": chatArg})), nil)
 	return dispatcher.EndGroups
 }