From 96985e6353de572c42fcb5eff6eee7c3f35ca24f Mon Sep 17 00:00:00 2001 From: patuwwy Date: Mon, 25 Sep 2023 12:02:53 +0000 Subject: [PATCH] Reconnect. logs. [wip] --- packages/host/src/lib/csi-controller.ts | 5 ++++- packages/runner/src/runner.ts | 10 +++++----- 2 files changed, 9 insertions(+), 6 deletions(-) diff --git a/packages/host/src/lib/csi-controller.ts b/packages/host/src/lib/csi-controller.ts index fcc4360af..f635c5920 100644 --- a/packages/host/src/lib/csi-controller.ts +++ b/packages/host/src/lib/csi-controller.ts @@ -186,7 +186,10 @@ export class CSIController extends TypedEmitter { this.logger = new ObjLogger(this, { id: this.id }); - this.logger.debug("Constructor executed"); + this.logger.debug("Constructor executed", arguments); + + // eslint-disable-next-line no-console + console.log("Constructor executed", arguments); this.status = InstanceStatus.INITIALIZING; diff --git a/packages/runner/src/runner.ts b/packages/runner/src/runner.ts index a9e13adc2..a9785958b 100644 --- a/packages/runner/src/runner.ts +++ b/packages/runner/src/runner.ts @@ -328,7 +328,9 @@ export class Runner implements IComponent { .finally(() => process.exit()); } - async premain() { + async premain(): Promise<{ appConfig: AppConfig, args: any}> { + this.logger.debug("premain"); + try { await this.hostClient.init(this.instanceId); } catch (e) { @@ -336,9 +338,7 @@ export class Runner implements IComponent { await defer(2000); - this.premain().catch((err: any) => { - this.logger.error("Premain error", err); - }); + return await this.premain(); } this.redirectOutputs(); @@ -358,7 +358,7 @@ export class Runner implements IComponent { const { appConfig, args } = await this.waitForHandshakeResponse(); - this.logger.debug("Handshake received"); + this.logger.debug("Handshake received", appConfig, args); return { appConfig, args }; }