Add close connection to a charge point method (#53)

voltbras · Jun 10, 2024 · f3cf185 · f3cf185
1 parent 5a99cb0
commit f3cf185
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 0 deletions.
diff --git a/docs/modules/cs/index.ts.md b/docs/modules/cs/index.ts.md
@@ -17,6 +17,7 @@ Sets up a central system, that can communicate with charge points
     - [getConnectedChargePoints (method)](#getconnectedchargepoints-method)
     - [addConnectionListener (method)](#addconnectionlistener-method)
     - [close (method)](#close-method)
+    - [closeConnection (method)](#closeconnection-method)
     - [sendRequest (method)](#sendrequest-method)
 - [utils](#utils)
   - [CSSendRequestArgs (type alias)](#cssendrequestargs-type-alias)
@@ -89,6 +90,14 @@ public addConnectionListener(listener: ConnectionListener)
 public async close(): Promise<void>
 ```
 
+### closeConnection (method)
+
+**Signature**
+
+```ts
+public async closeConnection(chargePointId: string): Promise<void>
+```
+
 ### sendRequest (method)
 
 **Signature**

diff --git a/src/cs/index.ts b/src/cs/index.ts
@@ -163,6 +163,11 @@ export default class CentralSystem {
     return Promise.all([httpClosing, wsClosing]).then(() => { });
   }
 
+  public async closeConnection(chargePointId: string): Promise<void> {
+    const connections = this.connections[chargePointId];
+    await Promise.all(connections.map((connection) => connection.close()));
+  }
+
   sendRequest<V extends OCPPVersion, T extends CentralSystemAction>(args: CSSendRequestArgs<T, V>): EitherAsync<OCPPRequestError, Response<T, V>> {
     return EitherAsync.fromPromise(async () => {
       const { chargePointId, payload, action } = args;