Method scheduleWithDelay

tmp_admin/tmp_admin.ts:663–705

(delay: number)

    if (existing?.timer) clearTimeout(existing.timer);

    const scheduleWithDelay = (delay: number) => {
      job.timer = setTimeout(async () => {
        if (Date.now() < job.expiresAt) {
          scheduleNext();
          return;
        }

        let participant: any;
        try {
          participant = await this.getCurrentParticipantOrThrow(
            job.channel,
            job.userEntity
          );
        } catch (e) {
          scheduleRetry(e);
          return;
        }

        if (!isTemporaryAdminParticipant(participant)) {
          this.jobs.delete(key);
          await this.deleteStoredJobQuiet(key);
          await this.sendReplyQuiet(
            job,
            `临时管理员已到期, 但 ${job.userDisplay} 已不再是插件设置的临时管理状态, 未自动解除。`
          );
          return;
        }

        try {
          await this.demoteAdmin(job.client, job.channel, job.userEntity, job.originalRank);
        } catch (e) {
          scheduleRetry(e);
          return;
        }

        this.jobs.delete(key);
        await this.deleteStoredJobQuiet(key);
        await this.sendReplyQuiet(
          job,
          `临时管理员已到期并自动解除: ${job.userDisplay}`
        );
      }, Math.min(Math.max(0, delay), maxTimerDelayMs));
    };

    const scheduleRetry = (error: any) => {
      if (job.retryCount >= maxExpiryRetries) {