From b76c1d5cccbc17497b249b428074a47b587723a8 Mon Sep 17 00:00:00 2001
From: krau <71133316+krau@users.noreply.github.com>
Date: Sun, 19 Jan 2025 14:35:08 +0800
Subject: [PATCH] feat: enhance task processing messages with download status
and error details
---
core/core.go | 11 ++++++-----
1 file changed, 6 insertions(+), 5 deletions(-)
diff --git a/core/core.go b/core/core.go
index e51f0b7..112f4b9 100644
--- a/core/core.go
+++ b/core/core.go
@@ -24,7 +24,7 @@ func processPendingTask(task *types.Task) error {
logger.L.Debugf("Start processing task: %s", task.String())
os.MkdirAll(config.Cfg.Temp.BasePath, os.ModePerm)
task.Ctx.(*ext.Context).EditMessage(task.ChatID, &tg.MessagesEditMessageRequest{
- Message: "正在下载文件...",
+ Message: "正在下载: " + task.String(),
ID: task.ReplyMessageID,
})
@@ -49,7 +49,7 @@ func processPendingTask(task *types.Task) error {
return
}
- text := fmt.Sprintf("正在下载文件\n[%s] %.2f%%", func() string {
+ text := fmt.Sprintf("正在下载: %s\n[%s] %.2f%%", task.String(), func() string {
bar := ""
for i := 0; i < barTotalCount; i++ {
if int(progress)/barSize > i {
@@ -96,8 +96,9 @@ func processPendingTask(task *types.Task) error {
task.StoragePath = task.File.FileName
}
+ logger.L.Infof("Downloaded file: %s", dest.Name())
task.Ctx.(*ext.Context).EditMessage(task.ChatID, &tg.MessagesEditMessageRequest{
- Message: "下载完成, 正在转存文件...",
+ Message: fmt.Sprintf("下载完成: %s\n正在转存文件...", task.FileName()),
ID: task.ReplyMessageID,
})
if config.Cfg.Retry <= 0 {
@@ -144,13 +145,13 @@ func worker(queue *queue.TaskQueue, semaphore chan struct{}) {
case types.Succeeded:
logger.L.Infof("Task succeeded: %s", task.String())
task.Ctx.(*ext.Context).EditMessage(task.ChatID, &tg.MessagesEditMessageRequest{
- Message: "文件保存成功",
+ Message: "保存成功\n" + task.FileName(),
ID: task.ReplyMessageID,
})
case types.Failed:
logger.L.Errorf("Task failed: %s", task.String())
task.Ctx.(*ext.Context).EditMessage(task.ChatID, &tg.MessagesEditMessageRequest{
- Message: "文件保存失败",
+ Message: "文件保存失败\n" + task.Error.Error(),
ID: task.ReplyMessageID,
})
case types.Canceled: