Full project added

app/api/ingest/event/route.ts

@@ -0,0 +1,77 @@
+import { NextResponse } from "next/server";
+import { prisma } from "@/lib/prisma";
+
+export async function POST(req: Request) {
+  const apiKey = req.headers.get("x-api-key");
+  if (!apiKey) return NextResponse.json({ ok: false, error: "Missing api key" }, { status: 401 });
+
+  const body = await req.json().catch(() => null);
+  if (!body?.machineId || !body?.event) {
+    return NextResponse.json({ ok: false, error: "Invalid payload" }, { status: 400 });
+  }
+
+  const machine = await prisma.machine.findFirst({
+    where: { id: String(body.machineId), apiKey },
+    select: { id: true, orgId: true },
+  });
+  if (!machine) return NextResponse.json({ ok: false, error: "Unauthorized" }, { status: 401 });
+
+  
+
+  // Convert ms epoch -> Date if provided
+
+  
+  
+const e = body.event;
+
+const ts =
+  typeof e?.data?.timestamp === "number"
+    ? new Date(e.data.timestamp)
+    : undefined;
+
+// normalize inputs from event
+const sev = String(e.severity ?? "").toLowerCase();
+const typ = String(e.eventType ?? e.anomaly_type ?? "").toLowerCase();
+const title = String(e.title ?? "").trim();
+
+const ALLOWED_TYPES = new Set([
+  "slow-cycle",
+  "anomaly-detected",
+  "performance-degradation",
+  "scrap-spike",
+  "down",
+  "microstop",
+]);
+
+const ALLOWED_SEVERITIES = new Set(["warning", "critical"]);
+
+// Drop generic/noise
+if (!ALLOWED_SEVERITIES.has(sev) || !ALLOWED_TYPES.has(typ)) {
+  return NextResponse.json({ ok: true, skipped: true }, { status: 200 });
+}
+
+if (!title) return NextResponse.json({ ok: true, skipped: true }, { status: 200 });
+
+
+
+  const row = await prisma.machineEvent.create({
+    data: {
+      orgId: machine.orgId,
+      machineId: machine.id,
+      ts: ts ?? undefined,
+
+      topic: e.topic ? String(e.topic) : "event",
+      eventType: e.anomaly_type ? String(e.anomaly_type) : "unknown",
+      severity: e.severity ? String(e.severity) : "info",
+      requiresAck: !!e.requires_ack,
+      title: e.title ? String(e.title) : "Event",
+      description: e.description ? String(e.description) : null,
+
+      data: e.data ?? e, // store full blob
+
+      workOrderId: e?.data?.work_order_id ? String(e.data.work_order_id) : null,
+    },
+  });
+
+  return NextResponse.json({ ok: true, id: row.id, ts: row.ts });
+}

app/api/ingest/heartbeat/route.ts

@@ -0,0 +1,32 @@
+import { NextResponse } from "next/server";
+import { prisma } from "@/lib/prisma";
+
+export async function POST(req: Request) {
+  const apiKey = req.headers.get("x-api-key");
+  if (!apiKey) return NextResponse.json({ ok: false, error: "Missing api key" }, { status: 401 });
+
+  const body = await req.json().catch(() => null);
+  if (!body?.machineId || !body?.status) {
+    return NextResponse.json({ ok: false, error: "Invalid payload" }, { status: 400 });
+  }
+
+  const machine = await prisma.machine.findFirst({
+    where: { id: String(body.machineId), apiKey },
+    select: { id: true, orgId: true },
+  });
+
+  if (!machine) return NextResponse.json({ ok: false, error: "Unauthorized" }, { status: 401 });
+
+  const hb = await prisma.machineHeartbeat.create({
+    data: {
+      orgId: machine.orgId,
+      machineId: machine.id,
+      status: String(body.status),
+      message: body.message ? String(body.message) : null,
+      ip: body.ip ? String(body.ip) : null,
+      fwVersion: body.fwVersion ? String(body.fwVersion) : null,
+    },
+  });
+
+  return NextResponse.json({ ok: true, id: hb.id, ts: hb.ts });
+}

app/api/ingest/kpi/route.ts

@@ -0,0 +1,50 @@
+import { NextResponse } from "next/server";
+import { prisma } from "@/lib/prisma";
+
+export async function POST(req: Request) {
+  const apiKey = req.headers.get("x-api-key");
+  if (!apiKey) return NextResponse.json({ ok: false, error: "Missing api key" }, { status: 401 });
+
+  const body = await req.json().catch(() => null);
+  if (!body?.machineId || !body?.kpis) {
+    return NextResponse.json({ ok: false, error: "Invalid payload" }, { status: 400 });
+  }
+
+  const machine = await prisma.machine.findFirst({
+    where: { id: String(body.machineId), apiKey },
+    select: { id: true, orgId: true },
+  });
+  if (!machine) return NextResponse.json({ ok: false, error: "Unauthorized" }, { status: 401 });
+
+  const wo = body.activeWorkOrder ?? {};
+  const k = body.kpis ?? {};
+
+  const row = await prisma.machineKpiSnapshot.create({
+    data: {
+      orgId: machine.orgId,
+      machineId: machine.id,
+
+      workOrderId: wo.id ? String(wo.id) : null,
+      sku: wo.sku ? String(wo.sku) : null,
+
+      target: typeof wo.target === "number" ? wo.target : null,
+      good: typeof wo.good === "number" ? wo.good : null,
+      scrap: typeof wo.scrap === "number" ? wo.scrap : null,
+
+      cycleCount: typeof body.cycle_count === "number" ? body.cycle_count : null,
+      goodParts: typeof body.good_parts === "number" ? body.good_parts : null,
+
+      cycleTime: typeof body.cycleTime === "number" ? body.cycleTime : null,
+
+      availability: typeof k.availability === "number" ? k.availability : null,
+      performance: typeof k.performance === "number" ? k.performance : null,
+      quality: typeof k.quality === "number" ? k.quality : null,
+      oee: typeof k.oee === "number" ? k.oee : null,
+
+      trackingEnabled: typeof body.trackingEnabled === "boolean" ? body.trackingEnabled : null,
+      productionStarted: typeof body.productionStarted === "boolean" ? body.productionStarted : null,
+    },
+  });
+
+  return NextResponse.json({ ok: true, id: row.id, ts: row.ts });
+}