workers/webmention-verify.ts

Functions

Imports

It imports app/db/index.ts, app/lib/error-message.mjs, app/lib/webmention/queue.ts, app/lib/webmention/verify.server.ts. Imported by workers/app.ts.

Source

1import { webmentionToVerify } from "~/db";
2import { readVerifyMessage } from "~/lib/webmention/queue";
3import { errorMessage } from "~/lib/error-message.mjs";
4
5/**
6 * The webmention queue consumer. Queues delivers at least once, so each message re-reads its row and
7 * fetches nothing unless the row is still `unverified`: a redelivery after the verdict is a no-op.
8 * `verifyWebmention` never throws and records a verdict for every source failure, so a row still
9 * `unverified` afterwards means the verdict write failed, and only that is retried.
10 */
11export async function handleWebmentionVerify(batch: MessageBatch<unknown>, env: Env) {
12  for (const message of batch.messages) {
13    const mention = readVerifyMessage(message.body);
14    if (!mention) {
15      console.error(JSON.stringify({ alert: "webmention-message-unreadable", body: message.body }));
16      message.ack();
17      continue;
18    }
19
20    try {
21      const row = await webmentionToVerify(env, mention.id);
22      // Gone (rejected and swept), already decided, or reset under another source: nothing to do.
23      if (row?.status !== "unverified" || row.sourceUrl !== mention.source) {
24        message.ack();
25        continue;
26      }
27
28      // Imported here, not at the top: linkedom has no place in the chunk every cold isolate evaluates.
29      const { verifyWebmention } = await import("~/lib/webmention/verify.server");
30      await verifyWebmention(env, mention.id, mention.source, mention.target);
31
32      const after = await webmentionToVerify(env, mention.id);
33      if (after?.status === "unverified") message.retry();
34      else message.ack();
35    } catch (error) {
36      // D1 or the chunk failed: retried, then the dead-letter queue, and the row stays `unverified`.
37      console.error(
38        JSON.stringify({ alert: "webmention-verify-failed", id: mention.id, detail: errorMessage(error) }),
39      );
40      message.retry();
41    }
42  }
43}