Merge pull request #5 from shiv3/fix/concurrent-connect

Fix to connect concurrency

Author: shiv3

src/components/TopPage.tsx

@@ -62,9 +62,10 @@ interface transactionInfo {
 const ExperimentalView: React.FC<ExperimentalProps> = ({cps, tagIDs}) => {
   const handleAllConnect = () => {
     console.log("Connecting all charge points");
-    cps.forEach((cp) => {
-      cp.connect();
-    });
+    const chunk = 100;
+    cps.flatMap((_, i, a) => i % chunk ? [] : [a.slice(i, i + chunk)]).forEach((cps) => {
+      Promise.all(cps.map((cp) => cp.connect()))
+    })
   }
 
   const handleAllDisconnect = () => {

src/cp/ChargePoint.ts

@@ -1,9 +1,9 @@
-import { Connector } from "./Connector";
-import { OCPPWebSocket } from "./OCPPWebSocket";
-import { OCPPMessageHandler } from "./OCPPMessageHandler";
-import { Logger } from "./Logger";
-import { OCPPStatus, OCPPAvailability } from "./OcppTypes";
-import { Transaction } from "./Transaction.ts";
+import {Connector} from "./Connector";
+import {OCPPWebSocket} from "./OCPPWebSocket";
+import {OCPPMessageHandler} from "./OCPPMessageHandler";
+import {Logger} from "./Logger";
+import {OCPPStatus, OCPPAvailability} from "./OcppTypes";
+import {Transaction} from "./Transaction.ts";
 import * as ocpp from "./OcppTypes.ts";
 
 export class ChargePoint {
@@ -15,7 +15,8 @@ export class ChargePoint {
 
   public _status: OCPPStatus = OCPPStatus.Unavailable;
   private _error: string = "";
-  public _errorCallback: (error: string) => void = () => {};
+  public _errorCallback: (error: string) => void = () => {
+  };
 
   private _heartbeat: number | null = null;
   private _statusChangeCallback: