app/routes/media.bulk.ts

Functions

Imports

It imports app/lib/context.ts, app/lib/media.server.ts, app/lib/projects.server.ts, app/lib/sites.server.ts. No module of this repo imports it.

Source

1// The media library's bulk endpoint: one action on several files, answered as JSON with an outcome for
2// every file. Roles are checked in media.server.ts before the site is asked anything (delete is the
3// Owner's; trash, restore and tags are an Editor's). The site answers file by file, so a stale file or
4// one a post uses is refused alone. POST only.
5//
6// Form fields: `op` (trash, restore, delete, add-tags, remove-tags), `item` once per file as the file's
7// id, a tab, and the version the person saw (empty for delete), and `tags` for the tag ops.
8
9import { getEnv, getViewer } from "~/lib/context";
10import { bulkMedia, parseMediaTags, type BulkOp } from "~/lib/media.server";
11import { requireSiteProject } from "~/lib/projects.server";
12import { SiteNotConnected } from "~/lib/sites.server";
13import { SiteApiError } from "@dustinedwards/site-api/client";
14
15import type { Route } from "./+types/media.bulk";
16
17const OPS: readonly BulkOp[] = ["trash", "restore", "delete", "add-tags", "remove-tags"];
18
19export async function action({ params, request, context }: Route.ActionArgs) {
20  if (request.method !== "POST") return Response.json({ error: "Method not allowed." }, { status: 405 });
21  const env = getEnv(context);
22  const viewer = getViewer(context);
23  const project = await requireSiteProject(env.DB, viewer, params.project, "read");
24  const form = await request.formData();
25  const op = OPS.find((o) => o === form.get("op"));
26  if (!op) return Response.json({ error: "That is not a bulk action." }, { status: 400 });
27  const items = form.getAll("item").map((raw) => {
28    const [id = "", version = ""] = String(raw).split("\t");
29    return { id, version: version || null };
30  });
31  let tags: string[] = [];
32  if (op === "add-tags" || op === "remove-tags") {
33    const parsed = parseMediaTags(String(form.get("tags") ?? ""));
34    if (!parsed.ok) return Response.json({ error: parsed.message }, { status: 400 });
35    tags = parsed.tags;
36  }
37  try {
38    return Response.json({ results: await bulkMedia(env, project, { viewer }, op, items, tags) });
39  } catch (thrown) {
40    if (thrown instanceof Response) {
41      if (thrown.status === 403) return Response.json({ error: op === "delete" ? "Deleting files is the Owner's step." : "You may not change files here." }, { status: 403 });
42      return Response.json({ error: (await thrown.text()) || "The request was not accepted." }, { status: thrown.status });
43    }
44    if (thrown instanceof SiteNotConnected) return Response.json({ error: `This site is not connected yet: ${thrown.detail}` }, { status: 502 });
45    if (thrown instanceof SiteApiError) {
46      return Response.json({ error: thrown.body ? `The site refused: ${thrown.body.message}` : `The site answered ${thrown.status}.` }, { status: 502 });
47    }
48    throw thrown;
49  }
50}