src/server/mentions.ts

Functions

Imports

It imports src/adapter.ts, src/contract.ts, src/server/http.ts. Imported by src/server.ts.

Source

1// The mentions routes (v0.5.0), mounted only when the site's adapter has mentions.
2
3import type { MentionsAdapter } from "../adapter.js";
4import {
5  MentionDecideInput,
6  MentionDeleteQuery,
7  MentionDeleteResult,
8  MentionId,
9  MentionList,
10  MentionListQuery,
11  MentionSweepInput,
12  MentionSweepResult,
13  MentionWriteResult,
14} from "../contract.js";
15import { ID, checked, fail, json, pathParam, readBody, readQuery, type Route } from "./http.js";
16
17export function mentionsRoutes(mentions: MentionsAdapter): Route[] {
18  const mentionId = (m: RegExpMatchArray) => pathParam(m[1], MentionId, "mention id");
19
20  return [
21    {
22      method: "GET",
23      pattern: /^\/mentions$/,
24      run: async (_m, url) => json(200, checked(MentionList, await mentions.list(readQuery(url, MentionListQuery)), "mentions list")),
25    },
26    {
27      method: "POST",
28      pattern: /^\/mentions\/sweep$/,
29      run: async (_m, _u, request) => {
30        const input = await readBody(request, MentionSweepInput);
31        const removed = await mentions.sweep(input);
32        return json(200, checked(MentionSweepResult, { changeId: input.changeId, removed }, "mentions sweep"));
33      },
34    },
35    {
36      method: "POST",
37      pattern: new RegExp(`^/mentions/${ID}/decide$`),
38      run: async (m, _u, request) => {
39        const id = mentionId(m);
40        const input = await readBody(request, MentionDecideInput);
41        const { decision, ...rest } = input;
42        let result;
43        if (decision === "reset") {
44          if (!mentions.reset) return fail("not-implemented", "This site does not take a mention decision back.");
45          result = await mentions.reset(id, rest);
46        } else {
47          result = await mentions.decide(id, { ...rest, decision });
48        }
49        return json(200, checked(MentionWriteResult, { id, ...result, changeId: input.changeId }, "mention decision"));
50      },
51    },
52    {
53      method: "DELETE",
54      pattern: new RegExp(`^/mentions/${ID}$`),
55      run: async (m, url) => {
56        const id = mentionId(m);
57        const query = readQuery(url, MentionDeleteQuery);
58        const result = await mentions.delete(id, query);
59        return json(200, checked(MentionDeleteResult, { id, deleted: true, changeId: query.changeId, purged: result.purged }, "mention delete"));
60      },
61    },
62  ];
63}