feat: upload/recipe/job API routes + Klarbild visual identity

- api: /uploads (multipart, HEIC, 25MB guard, S3), /recipes (GET/POST), /jobs (create+snapshot+enqueue, list), /jobs/:id (status+items), /jobs/:id/:action (pause/resume/cancel/retry-failed), /items/:id/retry - design: adopt Till mockup identity — Space Grotesk + Space Mono (self-hosted, no google/US), blue accent, paper/card, registration-mark motif; OKLCH tokens - verified: astro build passes
2026-07-23 11:47:27 +00:00
parent 577b13f680
commit c12d55368c
10 changed files with 285 additions and 46 deletions
@@ -0,0 +1,41 @@
+import type { APIRoute } from 'astro';
+import { one, query } from '../../../../lib/db';
+import { enqueue } from '../../../../lib/queue';
+
+export const prerender = false;
+const json = (b: unknown, s = 200) =>
+  new Response(JSON.stringify(b), { status: s, headers: { 'Content-Type': 'application/json' } });
+
+export const POST: APIRoute = async ({ params, locals }) => {
+  if (!locals.user) return new Response('Unauthorized', { status: 401 });
+  const id = params.id!;
+  const job = await one<{ id: string }>('SELECT id FROM jobs WHERE id=$1', [id]);
+  if (!job) return json({ error: 'Nicht gefunden.' }, 404);
+
+  switch (params.action) {
+    case 'pause':
+      await query(`UPDATE jobs SET status='paused' WHERE id=$1`, [id]);
+      break;
+    case 'resume': {
+      await query(`UPDATE jobs SET status='queued' WHERE id=$1`, [id]);
+      const items = await query<{ id: string }>(
+        `SELECT id FROM items WHERE job_id=$1 AND status IN ('queued','running')`, [id]);
+      for (const it of items) await enqueue({ itemId: it.id, jobId: id });
+      break;
+    }
+    case 'cancel':
+      await query(`UPDATE jobs SET status='cancelled', finished_at=now() WHERE id=$1`, [id]);
+      await query(`UPDATE items SET status='skipped' WHERE job_id=$1 AND status IN ('queued','running')`, [id]);
+      break;
+    case 'retry-failed': {
+      const items = await query<{ id: string }>(
+        `UPDATE items SET status='queued', error_message=NULL WHERE job_id=$1 AND status='failed' RETURNING id`, [id]);
+      await query(`UPDATE jobs SET status='queued', failed_count=0 WHERE id=$1`, [id]);
+      for (const it of items) await enqueue({ itemId: it.id, jobId: id });
+      break;
+    }
+    default:
+      return json({ error: 'Unbekannte Aktion.' }, 400);
+  }
+  return json({ ok: true });
+};