app/lib/webmention/queue.ts

Functions

Imports

It imports no other module of this repo. Imported by app/routes/webmention.ts, workers/app.ts, workers/webmention-verify.ts.

Source

1/**
2 * The one message the webmention route sends and the queue consumer reads. The queue name is here so
3 * `queue()` routes a batch by it; the binding and its consumer settings are in wrangler.jsonc.
4 */
5
6export const WEBMENTION_VERIFY_QUEUE = "dustinedwards-webmention-verify";
7
8export type WebmentionVerifyMessage = { id: number; source: string; target: string };
9
10/** Null for anything else: a message is acked and dropped rather than retried on a shape it will never change. */
11export function readVerifyMessage(body: unknown): WebmentionVerifyMessage | null {
12  if (typeof body !== "object" || body === null) return null;
13  const { id, source, target } = body as Record<string, unknown>;
14  if (typeof id !== "number" || !Number.isInteger(id)) return null;
15  if (typeof source !== "string" || source.length === 0) return null;
16  if (typeof target !== "string" || target.length === 0) return null;
17  return { id, source, target };
18}