Route project devices through history

2026-07-24 10:57:50 +02:00
parent ac16cca77a
commit e930cb75b8
13 changed files with 323 additions and 119 deletions
@@ -1,15 +1,26 @@
+import { randomUUID } from "node:crypto";
 import type { Request, Response } from "express";
 import { GlobalDeviceRepository } from "../../db/repositories/global-device.repository.js";
 import { ProjectDeviceRepository } from "../../db/repositories/project-device.repository.js";
-import { projectDeviceSyncService } from "../composition/project-device-sync-service.js";
+import { createProjectDeviceUpdateProjectCommand } from "../../domain/models/project-device-project-command.model.js";
 import {
-  createProjectDeviceSchema,
+  createProjectDeviceDeleteProjectCommand,
+  createProjectDeviceInsertProjectCommand,
+  type ProjectDeviceSnapshot,
+} from "../../domain/models/project-device-structure-project-command.model.js";
+import { projectDeviceSyncService } from "../composition/project-device-sync-service.js";
+import { projectCommandService } from "../composition/project-command-stores.js";
+import {
+  createProjectDeviceCommandSchema,
  disconnectProjectDeviceRowsSchema,
+  projectDeviceStructureCommandSchema,
  reconnectProjectDeviceRowsSchema,
  restoreProjectDeviceRowsSchema,
  synchronizeProjectDeviceRowsSchema,
-  updateProjectDeviceSchema,
+  updateProjectDeviceCommandSchema,
 } from "../../shared/validation/project-device.schemas.js";
+import type { CreateProjectDeviceInput } from "../../shared/validation/project-device.schemas.js";
+import { respondWithProjectCommandError } from "./project-command.controller.js";

 const globalDeviceRepository = new GlobalDeviceRepository();
 const projectDeviceRepository = new ProjectDeviceRepository();
@@ -27,12 +38,28 @@ export async function createProjectDevice(req: Request, res: Response) {
  if (typeof projectId !== "string") {
    return res.status(400).json({ error: "Invalid projectId" });
  }
-  const parsed = createProjectDeviceSchema.safeParse(req.body);
+  const parsed = createProjectDeviceCommandSchema.safeParse(req.body);
  if (!parsed.success) {
    return res.status(400).json({ error: parsed.error.flatten() });
  }
-  const created = await projectDeviceRepository.create(projectId, parsed.data);
-  return res.status(201).json(created);
+  const { expectedRevision, ...input } = parsed.data;
+  const projectDevice = toProjectDeviceSnapshot(projectId, randomUUID(), input);
+
+  try {
+    const result = projectCommandService.executeUser({
+      projectId,
+      expectedRevision,
+      description: "Projektgerät anlegen",
+      command: createProjectDeviceInsertProjectCommand(projectDevice),
+    });
+    const created = await projectDeviceRepository.findById(projectId, projectDevice.id);
+    if (!created) {
+      throw new Error("Created project device could not be loaded.");
+    }
+    return res.status(201).json({ ...result, projectDevice: created });
+  } catch (error) {
+    return respondWithProjectCommandError(error, res);
+  }
 }

 export async function updateProjectDevice(req: Request, res: Response) {
@@ -41,19 +68,32 @@ export async function updateProjectDevice(req: Request, res: Response) {
    return res.status(400).json({ error: "Invalid parameters" });
  }

-  const parsed = updateProjectDeviceSchema.safeParse(req.body);
+  const parsed = updateProjectDeviceCommandSchema.safeParse(req.body);
  if (!parsed.success) {
    return res.status(400).json({ error: parsed.error.flatten() });
  }
+  const { expectedRevision, ...input } = parsed.data;

-  await projectDeviceRepository.update(projectId, projectDeviceId, parsed.data);
-  // Linked rows are synchronized only through the explicit review flow.
-  // Updating a project device must never silently overwrite local circuit-list values.
-  const row = await projectDeviceRepository.findById(projectId, projectDeviceId);
-  if (!row) {
-    return res.status(404).json({ error: "Project device not found" });
+  try {
+    const result = projectCommandService.executeUser({
+      projectId,
+      expectedRevision,
+      description: "Projektgerät bearbeiten",
+      command: createProjectDeviceUpdateProjectCommand(
+        projectDeviceId,
+        toProjectDeviceValues(input)
+      ),
+    });
+    // Linked rows are synchronized only through the explicit review flow.
+    // Updating a project device must never silently overwrite local circuit-list values.
+    const projectDevice = await projectDeviceRepository.findById(projectId, projectDeviceId);
+    if (!projectDevice) {
+      throw new Error("Updated project device could not be loaded.");
+    }
+    return res.json({ ...result, projectDevice });
+  } catch (error) {
+    return respondWithProjectCommandError(error, res);
  }
-  return res.json(row);
 }

 export async function deleteProjectDevice(req: Request, res: Response) {
@@ -62,8 +102,23 @@ export async function deleteProjectDevice(req: Request, res: Response) {
    return res.status(400).json({ error: "Invalid parameters" });
  }

-  await projectDeviceRepository.delete(projectId, projectDeviceId);
-  return res.status(204).send();
+  const parsed = projectDeviceStructureCommandSchema.safeParse(req.body);
+  if (!parsed.success) {
+    return res.status(400).json({ error: parsed.error.flatten() });
+  }
+
+  try {
+    return res.json(
+      projectCommandService.executeUser({
+        projectId,
+        expectedRevision: parsed.data.expectedRevision,
+        description: "Projektgerät löschen",
+        command: createProjectDeviceDeleteProjectCommand(projectDeviceId, projectId),
+      })
+    );
+  } catch (error) {
+    return respondWithProjectCommandError(error, res);
+  }
 }

 export async function copyGlobalDeviceToProject(req: Request, res: Response) {
@@ -71,13 +126,17 @@ export async function copyGlobalDeviceToProject(req: Request, res: Response) {
  if (typeof projectId !== "string" || typeof globalDeviceId !== "string") {
    return res.status(400).json({ error: "Invalid parameters" });
  }
+  const parsed = projectDeviceStructureCommandSchema.safeParse(req.body);
+  if (!parsed.success) {
+    return res.status(400).json({ error: parsed.error.flatten() });
+  }

  const source = await globalDeviceRepository.findById(globalDeviceId);
  if (!source) {
    return res.status(404).json({ error: "Global device not found" });
  }

-  const created = await projectDeviceRepository.create(projectId, {
+  const projectDevice = toProjectDeviceSnapshot(projectId, randomUUID(), {
    name: source.name,
    displayName: source.displayName,
    phaseType: source.phaseCount === 3 ? "three_phase" : "single_phase",
@@ -90,7 +149,50 @@ export async function copyGlobalDeviceToProject(req: Request, res: Response) {
    voltageV: source.voltageV ?? undefined,
  });

-  return res.status(201).json(created);
+  try {
+    const result = projectCommandService.executeUser({
+      projectId,
+      expectedRevision: parsed.data.expectedRevision,
+      description: "Globales Gerät ins Projekt übernehmen",
+      command: createProjectDeviceInsertProjectCommand(projectDevice),
+    });
+    const created = await projectDeviceRepository.findById(projectId, projectDevice.id);
+    if (!created) {
+      throw new Error("Imported project device could not be loaded.");
+    }
+    return res.status(201).json({ ...result, projectDevice: created });
+  } catch (error) {
+    return respondWithProjectCommandError(error, res);
+  }
+}
+
+function toProjectDeviceSnapshot(
+  projectId: string,
+  id: string,
+  input: CreateProjectDeviceInput
+): ProjectDeviceSnapshot {
+  return {
+    id,
+    projectId,
+    ...toProjectDeviceValues(input),
+  };
+}
+
+function toProjectDeviceValues(input: CreateProjectDeviceInput) {
+  return {
+    name: input.name,
+    displayName: input.displayName,
+    phaseType: input.phaseType,
+    connectionKind: input.connectionKind ?? null,
+    costGroup: input.costGroup ?? null,
+    category: input.category ?? null,
+    quantity: input.quantity,
+    powerPerUnit: input.powerPerUnit,
+    simultaneityFactor: input.simultaneityFactor,
+    cosPhi: input.cosPhi ?? null,
+    remark: input.remark ?? null,
+    voltageV: input.voltageV ?? null,
+  };
 }

 export async function getProjectDeviceSyncPreview(req: Request, res: Response) {