Function tryGetCanvas

pmcaptcha/pmcaptcha.ts:510–555

()

async function runFailActions(client: TelegramClient, userId: number) {
  await archiveChat(client, userId);
  await muteChat(client, userId);

  for (const a of cfg.failActions()) {
    if (a === FailAction.BLOCK)  await blockUser(client, userId);
    if (a === FailAction.DELETE) {
      try {
        const peer = await resolveInputPeer(client, userId);
        await client.invoke(new Api.messages.DeleteHistory({ peer, revoke: true, maxId: 0 }));
        log(LogLevel.INFO, `Deleted history (revoke both sides) ${userId}`);
      } catch (e) { log(LogLevel.ERROR, `delete failed ${userId}`, e); }
    }
    if (a === FailAction.REPORT)  await reportSpam(client, userId);
    if (a === FailAction.MUTE)    await muteChat(client, userId);
    if (a === FailAction.ARCHIVE) await archiveChat(client, userId);
  }
}

async function runPassActions(client: TelegramClient, userId: number) {
  for (const a of cfg.passActions()) {
    if (a === PassAction.UNMUTE)    await unmuteChat(client, userId);
    if (a === PassAction.UNARCHIVE) await unarchiveChat(client, userId);
    if (a === PassAction.WL)        wl.add(userId);
  }
}

// ─── 图片验证码生成 ───────────────────────────────────────────────────────────

let _canvas: any = null;
let _canvasInstalling = false;

async function tryGetCanvas(): Promise<any> {
  if (_canvas !== null) return _canvas;

  try {
    _canvas = await import("canvas");
    log(LogLevel.INFO, "canvas module loaded");
    return _canvas;
  } catch {}

  if (_canvasInstalling) {
    const deadline = Date.now() + 60_000;
    while (_canvasInstalling && Date.now() < deadline) {
      if (!(await generationDelay(500))) return false;
    }
    return _canvas ?? false;
  }

  _canvasInstalling = true;