src/charging-station/MessageChannelUtils.ts

   1 import type { ChargingStation } from './ChargingStation';
   2 import {
   3   type ChargingStationData,
   4   type ChargingStationWorkerMessage,
   5   ChargingStationWorkerMessageEvents,
   6   type Statistics,
   7 } from '../types';
   8
   9 export class MessageChannelUtils {
  10   private constructor() {
  11     // This is intentional
  12   }
  13
  14   public static buildStartedMessage(
  15     chargingStation: ChargingStation
  16   ): ChargingStationWorkerMessage<ChargingStationData> {
  17     return {
  18       id: ChargingStationWorkerMessageEvents.started,
  19       data: MessageChannelUtils.buildChargingStationDataPayload(chargingStation),
  20     };
  21   }
  22
  23   public static buildStoppedMessage(
  24     chargingStation: ChargingStation
  25   ): ChargingStationWorkerMessage<ChargingStationData> {
  26     return {
  27       id: ChargingStationWorkerMessageEvents.stopped,
  28       data: MessageChannelUtils.buildChargingStationDataPayload(chargingStation),
  29     };
  30   }
  31
  32   public static buildUpdatedMessage(
  33     chargingStation: ChargingStation
  34   ): ChargingStationWorkerMessage<ChargingStationData> {
  35     return {
  36       id: ChargingStationWorkerMessageEvents.updated,
  37       data: MessageChannelUtils.buildChargingStationDataPayload(chargingStation),
  38     };
  39   }
  40
  41   public static buildPerformanceStatisticsMessage(
  42     statistics: Statistics
  43   ): ChargingStationWorkerMessage<Statistics> {
  44     return {
  45       id: ChargingStationWorkerMessageEvents.performanceStatistics,
  46       data: statistics,
  47     };
  48   }
  49
  50   private static buildChargingStationDataPayload(
  51     chargingStation: ChargingStation
  52   ): ChargingStationData {
  53     return {
  54       started: chargingStation.started,
  55       stationInfo: chargingStation.stationInfo,
  56       connectors: [...chargingStation.connectors.values()].map(
  57         // eslint-disable-next-line @typescript-eslint/no-unused-vars
  58         ({ transactionSetInterval, ...connectorStatusRest }) => connectorStatusRest
  59       ),
  60       evses: [...chargingStation.evses.values()].map((evseStatus) => {
  61         return {
  62           ...evseStatus,
  63           connectors: [...evseStatus.connectors.values()].map(
  64             // eslint-disable-next-line @typescript-eslint/no-unused-vars
  65             ({ transactionSetInterval, ...connectorStatusRest }) => connectorStatusRest
  66           ),
  67         };
  68       }),
  69       ocppConfiguration: chargingStation.ocppConfiguration,
  70       wsState: chargingStation?.wsConnection?.readyState,
  71       bootNotificationResponse: chargingStation.bootNotificationResponse,
  72       ...(chargingStation.automaticTransactionGenerator && {
  73         automaticTransactionGenerator: {
  74           automaticTransactionGenerator:
  75             chargingStation.getAutomaticTransactionGeneratorConfiguration(),
  76           automaticTransactionGeneratorStatuses: [
  77             ...chargingStation.automaticTransactionGenerator.connectorsStatus.values(),
  78           ],
  79         },
  80       }),
  81     };
  82   }
  83 }