Method restoreJobs

tmp_admin/tmp_admin.ts:805–843

()

  }

  private async restoreJobs(): Promise<void> {
    const runtime = tryGetCurrentRuntime();
    if (!runtime) return;

    const db = await this.getDb();
    await db.read();
    if (!db.data) db.data = { jobs: {} };
    if (!db.data.jobs) db.data.jobs = {};

    const removedKeys: string[] = [];
    for (const [key, stored] of Object.entries(db.data.jobs)) {
      try {
        const channel = deserializeChannel(stored.channel);
        const userEntity = deserializeUser(stored.user);
        this.scheduleExpiry(key, {
          client: runtime.client,
          channel,
          chatKey: stored.chatKey,
          peerId: toSendPeer(channel),
          userEntity,
          userId: stored.userId,
          userDisplay: stored.userDisplay,
          originalRank: stored.originalRank || "",
          replyToMsgId: stored.replyToMsgId,
          expiresAt: stored.expiresAt,
          retryCount: stored.retryCount || 0,
        });
      } catch (error) {
        console.error(`[tmp_admin] 跳过无法恢复的任务 ${key}:`, error);
        removedKeys.push(key);
      }
    }

    if (removedKeys.length > 0) {
      await this.mutateDb((data) => {
        for (const key of removedKeys) delete data.jobs[key];
      });
    }
  }

  private async demoteAdmin(client: any, channel: any, userEntity: any, originalRank?: string): Promise<void> {
    await client.invoke(