homeio

1import { type NextRequest, NextResponse } from "next/server";
2import { requireApiSession } from "@/lib/server/modules/auth/api";
3import {
4  createRequestId,
5  withServerTiming,
6} from "@/lib/server/logging/logger";
7import {
8  getHomeioLogs,
9  getSystemLogs,
10  getDockerLogs,
11  type LogSource,
12} from "@/lib/server/modules/logs/service";
13
14export const runtime = "nodejs";
15
16/**
17 * GET /api/v1/logs?source=homeio|system|docker
18 *
19 * Returns recent log entries for the requested source.
20 * - homeio: structured JSON entries from LOG_FILE_PATH
21 * - system: journalctl (last 500 lines)
22 * - docker: journalctl -u docker (last 500 lines)
23 */
24export async function GET(request: NextRequest) {
25  const apiSession = await requireApiSession(request);
26  if (apiSession.response) return apiSession.response;
27  const requestId = createRequestId();
28
29  return withServerTiming(
30    { layer: "api", action: "logs.get", requestId },
31    async () => {
32      const source = (request.nextUrl.searchParams.get("source") ??
33        "homeio") as LogSource;
34
35      if (!["homeio", "system", "docker"].includes(source)) {
36        return NextResponse.json(
37          { error: "Invalid source. Use homeio, system, or docker." },
38          { status: 400 },
39        );
40      }
41
42      const result =
43        source === "homeio"
44          ? await getHomeioLogs()
45          : source === "system"
46            ? await getSystemLogs()
47            : await getDockerLogs();
48
49      return NextResponse.json({ data: result });
50    },
51  );
52}
53