add status notification

app/components/evse.tsx

@@ -8,7 +8,11 @@ import { ChargingSocket, IChargingSocket } from '../service/ocpp/connector';
 import { HandleOcpp } from '../service/ocpp/ocpp.handler';
 import { SendBootNotification } from '../service/ocpp/command/boot-notification/bootnotification';
 import StatusNotificationUI from './status.notification';
-import { StatusNotification } from '../service/ocpp/status.notificiation';
+import {
+  ChargePointErrorCodes,
+  StatusNotification,
+} from '../service/ocpp/command/status-notification/status.notificiation';
+import { SendStatusNotification } from '../service/ocpp/command/status-notification/statusnotification';
 
 const defaultValue = 'ws://localhost:8080/ocpp/JwNpTpPxPm/CHR202305102';
 
@@ -32,13 +36,21 @@ export default function Evse() {
 
   const onMessage = (ev: MessageEvent) => {
     if (writer == null) return;
-    console.log(socket);
-
     HandleOcpp(writer.current[0], ev.data, changeState);
   };
 
-  const changeState = (state: StatusNotification) => {
+  const changeState = (
+    state: StatusNotification,
+    error?: ChargePointErrorCodes
+  ) => {
     setSocket({ ...socket, State: state });
+    if (writer.current[0] == null) return;
+    SendStatusNotification(
+      writer.current[0],
+      0,
+      error ?? ChargePointErrorCodes.NoError,
+      state
+    );
   };
 
   return (

app/components/select.tsx

@@ -1,4 +1,4 @@
-import { useState } from 'react';
+import { useEffect, useState } from 'react';
 
 type ReturnValue = string | number;
 
@@ -34,7 +34,7 @@ export default function Select({
   defaultItem,
   onChange,
 }: Select): React.JSX.Element {
-  const [selected, setSelected] = useState(defaultItem);
+  const [selected, setSelected] = useState<Item>();
   const [drop, setDrop] = useState(false);
   const show = drop ? '' : 'hidden';
 
@@ -48,6 +48,10 @@ export default function Select({
     setDrop((v) => !v);
   };
 
+  useEffect(() => {
+    setSelected(defaultItem);
+  }, [defaultItem]);
+
   return (
     <div>
       <div className='relative mt-2'>

app/components/status.notification.tsx

@@ -1,5 +1,5 @@
 import React from 'react';
-import { StatusNotification } from '../service/ocpp/status.notificiation';
+import { StatusNotification } from '../service/ocpp/command/status-notification/status.notificiation';
 import { ChangeState } from '../service/ocpp/ocpp.handler';
 import Select, { Item, ReturnValue } from './select';
 
@@ -15,18 +15,17 @@ export default function StatusNotificationUI({
   const items: Array<Item> = Object.values(StatusNotification).map((v) => {
     return { name: v, value: v };
   });
+  const defaultState = { name: state, value: state };
 
   const onChange = (value: ReturnValue) =>
     changeState(value as StatusNotification);
 
+  console.log(state);
+
   return (
     <div>
       state: {state}
-      <Select
-        items={items}
-        onChange={onChange}
-        defaultItem={{ name: state, value: state }}
-      />
+      <Select items={items} onChange={onChange} defaultItem={defaultState} />
     </div>
   );
 }

app/service/ocpp/command/boot-notification/bootnotification.ts

@@ -1,15 +1,15 @@
 import { DEFAULT_TIMER, IWriter } from '../../../websocket/websocket.model';
 import { Action, CreateRequestFrame, GetRequestFrame } from '../../ocpp.action';
 import { IResponse } from '../../ocpp.frame';
-import { NewTransaction } from '../../transaction/transaction.handler';
+import { CreateTransaction } from '../../transaction/transaction.handler';
 import {
   BootNotificationRes,
   IBootNotification,
   Status,
 } from './bootnotification.model';
 import { CreateError, ErrorCode } from '../../ocpp.error';
 import Validate from '@/app/helper/validation.helper';
-import { StatusNotification } from '../../status.notificiation';
+import { StatusNotification } from '../status-notification/status.notificiation';
 import { ChangeState } from '../../ocpp.handler';
 
 const defaultValue: IBootNotification = {
@@ -42,7 +42,7 @@ function SendBootNotification(w: IWriter): void {
     clearTimeout(id);
     if (success) return;
     const frame = CreateRequestFrame(Action.BOOT_NOTIFICATION, defaultValue);
-    NewTransaction(GetRequestFrame(frame), BootNotification);
+    CreateTransaction(GetRequestFrame(frame), BootNotification);
     w.Write(frame);
   } catch (error) {
     retry(w);

app/service/ocpp/command/status-notification/status.notificiation.ts

@@ -0,0 +1,39 @@
+enum StatusNotification {
+  AVAILABLE = 'Available',
+  PREPARING = 'Preparing',
+  CHARGING = 'Charging',
+  SUSPENDED_EVSE = 'SuspendedEVSE',
+  SUSPENDED_EV = 'SuspendedEV',
+  FINISHING = 'Finishing',
+  RESERVED = 'Reserved',
+  UNAVAILABLE = 'Unavailable',
+  FAULTED = 'Faulted',
+}
+
+enum ChargePointErrorCodes {
+  ConnectorLockFailure = 'NoError',
+  EVCommunicationError = 'EVCommunicationError',
+  GroundFailure = 'GroundFailure',
+  HighTemperature = 'HighTemperature',
+  InternalError = 'InternalError',
+  LocalListConflict = 'LocalListConflict',
+  NoError = 'NoError',
+  OtherError = 'OtherError',
+  OverCurrentFailure = 'OverCurrentFailure',
+  OverVoltage = 'OverVoltage',
+  PowerMeterFailure = 'PowerMeterFailure',
+  PowerSwitchFailure = 'PowerSwitchFailure',
+  ReaderFailure = 'ReaderFailure',
+  ResetFailure = 'ResetFailure',
+  UnderVoltage = 'UnderVoltage',
+  WeakSignal = 'WeakSignal',
+}
+
+interface IStatusNotification {
+  connectorId: number;
+  status: StatusNotification;
+  errorCode: ChargePointErrorCodes;
+}
+
+export type { IStatusNotification };
+export { ChargePointErrorCodes, StatusNotification };

app/service/ocpp/command/status-notification/statusnotification.ts

@@ -0,0 +1,30 @@
+import { IWriter } from '../../../websocket/websocket.model';
+import { Action, CreateRequestFrame, GetRequestFrame } from '../../ocpp.action';
+import { CreateTransaction } from '../../transaction/transaction.handler';
+import {
+  ChargePointErrorCodes,
+  IStatusNotification,
+  StatusNotification,
+} from './status.notificiation';
+
+function SendStatusNotification(
+  w: IWriter,
+  connectorId: number,
+  errorCode: ChargePointErrorCodes,
+  status: StatusNotification
+): void {
+  const req: IStatusNotification = {
+    connectorId,
+    errorCode,
+    status,
+  };
+  const frame = CreateRequestFrame(Action.STATUS_NOTIFICATION, req);
+  w.Write(frame);
+  CreateTransaction(GetRequestFrame(frame), StatusNotificationRes);
+}
+
+function StatusNotificationRes(): void {
+  console.log('status notification res received');
+}
+
+export { SendStatusNotification };

app/service/ocpp/connector.ts

@@ -1,4 +1,4 @@
-import { StatusNotification } from './status.notificiation';
+import { StatusNotification } from './command/status-notification/status.notificiation';
 
 interface IChargingSocket {
   State: StatusNotification;

app/service/ocpp/ocpp.handler.ts

@@ -8,11 +8,17 @@ import {
   IRequest,
   IResponse,
 } from './ocpp.frame';
-import { StatusNotification } from './status.notificiation';
+import {
+  ChargePointErrorCodes,
+  StatusNotification,
+} from './command/status-notification/status.notificiation';
 import { FindTransaction } from './transaction/transaction.handler';
 
 type OCPPData = IRequest | IResponse | IErrorFrame;
-type ChangeState = (state: StatusNotification) => void;
+type ChangeState = (
+  state: StatusNotification,
+  error?: ChargePointErrorCodes
+) => void;
 
 function getCallType(frame: BaseTuple): CallType {
   return frame[0];

app/service/ocpp/transaction/transaction.handler.ts

@@ -3,7 +3,7 @@ import { ActionResponse, ITransaction, Transaction } from './transaction.model';
 
 const List: Array<ITransaction> = [];
 
-function NewTransaction(frame: IRequest, handler: ActionResponse): void {
+function CreateTransaction(frame: IRequest, handler: ActionResponse): void {
   List.push(new Transaction(frame, handler));
 }
 
@@ -17,4 +17,4 @@ function GetTransactions(): Array<ITransaction> {
   return List;
 }
 
-export { GetTransactions, NewTransaction, FindTransaction };
+export { GetTransactions, CreateTransaction, FindTransaction };