Function scheduleTask

acron/acron.ts:278–451

(task: AcronTask)

}

async function scheduleTask(task: AcronTask) {
  const key = makeCronKey(task.id);
  if (task.disabled) return;
  if (cronManager.has(key)) return;

  cronManager.set(key, task.cron, async () => {
    const db = await getDB();
    const idx = db.data.tasks.findIndex((t) => t.id === task.id);
    const now = Date.now();
    try {
      const client = await getGlobalClient();
      // NOTE: https://docs.telethon.dev/en/stable/concepts/entities.html
      await client.getDialogs();
      const chatIdNum = toInt((task as any).chatId);
      const entityLike = (chatIdNum as any) ?? task.chat;

      if (task.type === "send") {
        const t = task as SendTask;
        const entities = reviveEntities(t.entities);
        const replyTo = t.replyTo ? toInt(t.replyTo) : undefined;
        await client.sendMessage(entityLike, {
          message: t.message,
          formattingEntities: entities,
          ...(replyTo ? { replyTo } : {}),
        });
        if (idx >= 0) {
          db.data.tasks[idx].lastRunAt = String(now);
          db.data.tasks[idx].lastResult = `已发送 1 条消息`;
          db.data.tasks[idx].lastError = undefined;
          await db.write();
        }
      } else if (task.type === "cmd") {
        const t = task as CmdTask;
        const cmd = await getCommandFromMessage(t.message);
        const replyTo = t.replyTo ? toInt(t.replyTo) : undefined;
        const sudoMsg = await client.sendMessage(entityLike, {
          message: t.message,
          ...(replyTo ? { replyTo } : {}),
        });
        if (cmd && sudoMsg)
          await dealCommandPluginWithMessage({ cmd, msg: sudoMsg as any });
        if (idx >= 0) {
          db.data.tasks[idx].lastRunAt = String(now);
          db.data.tasks[idx].lastResult = `已执行命令`;
          db.data.tasks[idx].lastError = undefined;
          await db.write();
        }
      } else if (task.type === "copy") {
        const t = task as CopyTask;
        const fromChatIdNum = toInt(t.fromChatId);
        const fromMsgIdNum = toInt(t.fromMsgId);
        try {
          // 获取源消息（尽量使用完整实体以避免 hash 失效）
          const fromEntityLike = (fromChatIdNum as any) ?? t.fromChatId;
          const messages = await safeGetMessages(client, fromEntityLike as any, {
            ids: fromMsgIdNum,
          });
          const realtimeMsg = messages?.[0] as any;