Disconnected due to limit

Author: patuwwy

packages/host/src/lib/cpm-connector.ts

@@ -271,7 +271,7 @@ export class CPMConnector extends TypedEmitter<Events> {
                     this.logger.updateBaseLog({ id: this.info.id });
                 }
 
-                if (message[0] === CPMMessageCode.KEY_REVOKED) {
+                if (message[0] === CPMMessageCode.KEY_REVOKED || message[0] === CPMMessageCode.LIMIT_EXCEEDED) {
                     this.logger.trace("Received pre drop message");
                     this.isAbandoned = true;
                 }

packages/model/src/stream-handler.ts

@@ -55,6 +55,7 @@ type ControlMessageHandlerList = {
     [RunnerMessageCode.EVENT]: ConfiguredMessageHandler<RunnerMessageCode.EVENT>[];
     [CPMMessageCode.STH_ID]: ConfiguredMessageHandler<CPMMessageCode.STH_ID>[];
     [CPMMessageCode.KEY_REVOKED]: ConfiguredMessageHandler<CPMMessageCode.KEY_REVOKED>[];
+    [CPMMessageCode.LIMIT_EXCEEDED]: ConfiguredMessageHandler<CPMMessageCode.LIMIT_EXCEEDED>[];
 };
 
 export class CommunicationHandler implements ICommunicationHandler {
@@ -90,6 +91,7 @@ export class CommunicationHandler implements ICommunicationHandler {
             [RunnerMessageCode.INPUT_CONTENT_TYPE]: [],
             [CPMMessageCode.STH_ID]: [],
             [CPMMessageCode.KEY_REVOKED]: [],
+            [CPMMessageCode.LIMIT_EXCEEDED]: [],
         };
         this.monitoringHandlerHash = {
             [RunnerMessageCode.ACKNOWLEDGE]: [],

packages/symbols/src/cpm-message-code.ts

@@ -13,5 +13,6 @@ export enum CPMMessageCode {
 
     CONFIRM_MSG = 8000,
 
-    KEY_REVOKED = 9001
+    KEY_REVOKED = 9001,
+    LIMIT_EXCEEDED = 9002
 }

packages/types/src/message-streams.ts

@@ -95,7 +95,7 @@ export type EncodedMessage<
 export type ControlMessageCode =
     RunnerMessageCode.KILL | RunnerMessageCode.MONITORING_RATE | RunnerMessageCode.STOP | RunnerMessageCode.EVENT |
     RunnerMessageCode.PONG |
-    CPMMessageCode.STH_ID | CPMMessageCode.KEY_REVOKED |
+    CPMMessageCode.STH_ID | CPMMessageCode.KEY_REVOKED | CPMMessageCode.LIMIT_EXCEEDED |
     RunnerMessageCode.INPUT_CONTENT_TYPE;
 
 export type EncodedControlMessage = EncodedMessage<ControlMessageCode>;