homeio

1import { createScheduledTask, listScheduledTasks } from "@/lib/server/modules/scheduled-tasks/service";
2import { NextResponse } from "next/server";
3import type { NextRequest } from "next/server";
4import { createRequestId, logServerAction } from "@/lib/server/logging/logger";
5import { z } from "zod";
6import { CRON_EXPRESSION_REGEX, createScheduledTaskSchema } from "@/lib/shared/contracts/scheduled-tasks";
7import { requireApiSession } from "@/lib/server/modules/auth/api";
8
9export const runtime = "nodejs";
10
11export async function GET(request: NextRequest) {
12  const apiSession = await requireApiSession(request);
13  if (apiSession.response) return apiSession.response;
14  const requestId = createRequestId();
15
16  try {
17    const tasks = await listScheduledTasks();
18    return NextResponse.json({ tasks });
19  } catch (error) {
20    logServerAction({
21      level: "error",
22      layer: "api",
23      action: "scheduled-tasks.get.response",
24      status: "error",
25      requestId,
26      message: "Failed to fetch scheduled tasks",
27      error,
28    });
29    return NextResponse.json({ error: "Failed to fetch scheduled tasks" }, { status: 500 });
30  }
31}
32
33export async function POST(request: NextRequest) {
34  const apiSession = await requireApiSession(request);
35  if (apiSession.response) return apiSession.response;
36  const requestId = createRequestId();
37  const session = apiSession.session;
38
39  let body: unknown;
40  try {
41    body = await request.json();
42  } catch {
43    return NextResponse.json({ error: "Invalid JSON" }, { status: 400 });
44  }
45
46  const parsed = createScheduledTaskSchema.safeParse(body);
47  if (!parsed.success) {
48    return NextResponse.json({ error: "Invalid request", details: parsed.error.flatten() }, { status: 400 });
49  }
50
51  try {
52    const task = await createScheduledTask(parsed.data);
53    logServerAction({
54      layer: "api",
55      action: "scheduled-tasks.post.created",
56      status: "success",
57      requestId,
58      message: "Created scheduled task",
59      meta: { userId: session.userId, username: session.username, taskId: task.id, label: task.label },
60    });
61    return NextResponse.json({ task }, { status: 201 });
62  } catch (error) {
63    logServerAction({
64      level: "error",
65      layer: "api",
66      action: "scheduled-tasks.post.response",
67      status: "error",
68      requestId,
69      message: "Failed to create scheduled task",
70      error,
71    });
72    return NextResponse.json({ error: "Failed to create scheduled task" }, { status: 500 });
73  }
74}
75