Add distribution power summaries

src/domain/models/distribution-board-project-command.model.ts

@@ -6,11 +6,13 @@ import type { SerializedProjectCommand } from "./project-command.model.js";
 
 export const distributionBoardUpdateCommandType =
   "distribution-board.update" as const;
-export const distributionBoardUpdateCommandSchemaVersion = 1 as const;
+export const legacyDistributionBoardUpdateCommandSchemaVersion = 1 as const;
+export const distributionBoardUpdateCommandSchemaVersion = 2 as const;
 
 export interface DistributionBoardUpdateValues {
   floorId: string | null;
   supplyType: DistributionBoardSupplyType | null;
+  simultaneityFactor: number;
 }
 
 export type DistributionBoardUpdateField =
@@ -31,17 +33,27 @@ export interface DistributionBoardUpdateCommandPayload {
   changes: DistributionBoardUpdateFieldChange[];
 }
 
-export interface DistributionBoardUpdateProjectCommand
+interface CurrentDistributionBoardUpdateProjectCommand
   extends SerializedProjectCommand<DistributionBoardUpdateCommandPayload> {
   schemaVersion: typeof distributionBoardUpdateCommandSchemaVersion;
   type: typeof distributionBoardUpdateCommandType;
 }
 
+interface LegacyDistributionBoardUpdateProjectCommand
+  extends SerializedProjectCommand<DistributionBoardUpdateCommandPayload> {
+  schemaVersion: typeof legacyDistributionBoardUpdateCommandSchemaVersion;
+  type: typeof distributionBoardUpdateCommandType;
+}
+
+export type DistributionBoardUpdateProjectCommand =
+  | CurrentDistributionBoardUpdateProjectCommand
+  | LegacyDistributionBoardUpdateProjectCommand;
+
 export function createDistributionBoardUpdateProjectCommand(
   distributionBoardId: string,
   patch: DistributionBoardUpdatePatch
-): DistributionBoardUpdateProjectCommand {
-  const command: DistributionBoardUpdateProjectCommand = {
+): CurrentDistributionBoardUpdateProjectCommand {
+  const command: CurrentDistributionBoardUpdateProjectCommand = {
     schemaVersion: distributionBoardUpdateCommandSchemaVersion,
     type: distributionBoardUpdateCommandType,
     payload: {
@@ -60,7 +72,9 @@ export function assertDistributionBoardUpdateProjectCommand(
   command: SerializedProjectCommand<unknown>
 ): asserts command is DistributionBoardUpdateProjectCommand {
   if (
-    command.schemaVersion !== distributionBoardUpdateCommandSchemaVersion ||
+    (command.schemaVersion !==
+      legacyDistributionBoardUpdateCommandSchemaVersion &&
+      command.schemaVersion !== distributionBoardUpdateCommandSchemaVersion) ||
     command.type !== distributionBoardUpdateCommandType ||
     !isPlainObject(command.payload)
   ) {
@@ -81,7 +95,11 @@ export function assertDistributionBoardUpdateProjectCommand(
   for (const change of changes) {
     if (
       !isPlainObject(change) ||
-      (change.field !== "floorId" && change.field !== "supplyType") ||
+      (change.field !== "floorId" &&
+        change.field !== "supplyType" &&
+        (command.schemaVersion ===
+          legacyDistributionBoardUpdateCommandSchemaVersion ||
+          change.field !== "simultaneityFactor")) ||
       seen.has(change.field)
     ) {
       throw new Error(
@@ -95,13 +113,24 @@ export function assertDistributionBoardUpdateProjectCommand(
       ) {
         throw new Error("floorId must be a non-empty string or null.");
       }
+    } else if (change.field === "supplyType") {
+      if (
+        change.value !== null &&
+        !distributionBoardSupplyTypes.includes(
+          change.value as DistributionBoardSupplyType
+        )
+      ) {
+        throw new Error("supplyType is invalid.");
+      }
     } else if (
-      change.value !== null &&
-      !distributionBoardSupplyTypes.includes(
-        change.value as DistributionBoardSupplyType
-      )
+      typeof change.value !== "number" ||
+      !Number.isFinite(change.value) ||
+      change.value < 0 ||
+      change.value > 1
     ) {
-      throw new Error("supplyType is invalid.");
+      throw new Error(
+        "simultaneityFactor must be between zero and one."
+      );
     }
     seen.add(change.field);
   }