Fix dropping STH by id

scramjetorg · Mar 29, 2023 · e72220b · e72220b
1 parent e8c1725
commit e72220b
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 8 deletions.
diff --git a/packages/cli/src/lib/commands/space.ts b/packages/cli/src/lib/commands/space.ts
@@ -86,16 +86,16 @@ export const space: CommandDefinition = (program) => {
         .argument("<space_name>", "The name of the Space")
         .option("--id <id>", "Hub Id")
         .option("--all", "Disconnects all self-hosted Hubs connected to Space", false)
-        .action(async (spaceName: string, id: string, all: string) => {
+        .action(async (spaceName: string, options: { id: string, all: boolean }) => {
             const mwClient = getMiddlewareClient();
             const managerClient = mwClient.getManagerClient(spaceName);
             let opts = { } as PostDisconnectPayload;
 
-            if (typeof id === "string") {
-                opts = { id };
+            if (typeof options.id === "string") {
+                opts = { id: options.id };
             }
 
-            if (all) {
+            if (options.all) {
                 opts = { limit: 0 };
             }
 

diff --git a/packages/host/src/lib/cpm-connector.ts b/packages/host/src/lib/cpm-connector.ts
@@ -295,9 +295,6 @@ export class CPMConnector extends TypedEmitter<Events> {
             [CPMMessageCode.NETWORK_INFO, await this.getNetworkInfo()]
         );
 
-
-
-
         this.emit("connect");
 
         return new Promise((resolve, reject) => {
@@ -344,7 +341,8 @@ export class CPMConnector extends TypedEmitter<Events> {
 
             connection.socket
                 .once("close", async () => {
-                    this.logger.warn("CLOSE STATUS", connection.res.statusCode)
+                    this.logger.warn("CLOSE STATUS", connection.res.statusCode);
+
                     await this.handleConnectionClose(connection.res.statusCode || -1);
                 });
         } catch (error: any) {