Method processMessage

save/save.ts:805–893

(
    sourceMsg: Api.Message, 
    targetPeer: any, 
    replyMsg: Api.Message,
    sourceChatId: string,
    sourceMessageId: number,
    progress: string = ""
  )

            return {
              success: true,
              forwardedMsg: forwardedMessage,
              source: { chatId: sourceChatId, messageId: sourceMessageId }
            };
          } else {
            await this.safeEditMessage(replyMsg, `${progress}❌ 消息无内容可转发`, true);
            return { success: false };
          }
        }
        
        tempFileInfo = await this.downloadMedia(sourceMsg, 0, replyMsg);
        if (!tempFileInfo) {
          await this.safeEditMessage(replyMsg, `${progress}❌ 下载媒体失败`, true);
          return { success: false };
        }
        
        // 发送媒体消息，获取发送的消息
        forwardedMessage = await this.sendSingleMedia(client, targetPeer, tempFileInfo, replyMsg);
        await this.safeEditMessage(replyMsg, `${progress}✅ 内容已重新上传发送`, true);
        
        // 如果开启了来源显示，发送来源消息
        return {
          success: true,
          forwardedMsg: forwardedMessage,
          source: { chatId: sourceChatId, messageId: sourceMessageId }
        };
      }
    } catch (error: unknown) {
      logger.error(`处理消息失败:`, error);
      await this.safeEditMessage(replyMsg, `${progress}❌ 处理失败: ${htmlEscape(getErrorMessage(error) || "未知错误")}`, true);
      return { success: false };
    } finally {
      if (tempFileInfo?.path) {
        await this.cleanupTempFile(tempFileInfo.path);
      }
    }
  }

  private async processMessageToLocal(
    sourceMsg: MessageContext,
    replyMsg: MessageContext,
    sourceChatId: string,
    sourceMessageId: number,
    progress: string = "",
    options?: { groupDirName?: string; quietSuccess?: boolean }
  ): Promise<ProcessMessageResult> {
    try {
      if (!sourceMsg.media) {
        await this.safeEditMessage(replyMsg, `${progress}⏭️ 消息不包含媒体文件，已跳过`, true);
        return { success: false, skipped: true };
      }

      await this.safeEditMessage(replyMsg, `${progress}💾 正在保存媒体到本地...`, true);
      const savedFile = await this.saveMediaToLocal(sourceMsg, sourceChatId, sourceMessageId, replyMsg, 0, options);

      if (!savedFile) {
        await this.safeEditMessage(replyMsg, `${progress}❌ 保存到本地失败`, true);
        return { success: false };
      }