diff --git a/packages/apps-engine/src/server/runtime/deno/AppsEngineDenoRuntime.ts b/packages/apps-engine/src/server/runtime/deno/AppsEngineDenoRuntime.ts index 3a8db5ddd414..277ca15373c0 100644 --- a/packages/apps-engine/src/server/runtime/deno/AppsEngineDenoRuntime.ts +++ b/packages/apps-engine/src/server/runtime/deno/AppsEngineDenoRuntime.ts @@ -5,10 +5,6 @@ import { type Readable, EventEmitter } from 'stream'; import debugFactory from 'debug'; import * as jsonrpc from 'jsonrpc-lite'; -import { LivenessManager } from './LivenessManager'; -import { ProcessMessenger } from './ProcessMessenger'; -import { bundleLegacyApp } from './bundler'; -import { newDecoder } from './codec'; import { AppStatus, AppStatusUtils } from '../../../definition/AppStatus'; import type { AppMethod } from '../../../definition/metadata'; import type { AppManager } from '../../AppManager'; @@ -17,6 +13,10 @@ import type { IParseAppPackageResult } from '../../compiler'; import { AppConsole, type ILoggerStorageEntry } from '../../logging'; import type { AppAccessorManager, AppApiManager } from '../../managers'; import type { AppLogStorage, IAppStorageItem } from '../../storage'; +import { LivenessManager } from './LivenessManager'; +import { ProcessMessenger } from './ProcessMessenger'; +import { bundleLegacyApp } from './bundler'; +import { newDecoder } from './codec'; const baseDebug = debugFactory('appsEngine:runtime:deno'); @@ -112,7 +112,11 @@ export class DenoRuntimeSubprocessController extends EventEmitter { private readonly livenessManager: LivenessManager; // We need to keep the appSource around in case the Deno process needs to be restarted - constructor(manager: AppManager, private readonly appPackage: IParseAppPackageResult, private readonly storageItem: IAppStorageItem) { + constructor( + manager: AppManager, + private readonly appPackage: IParseAppPackageResult, + private readonly storageItem: IAppStorageItem, + ) { super(); this.debug = baseDebug.extend(appPackage.info.id); diff --git a/packages/apps-engine/src/server/runtime/deno/LivenessManager.ts b/packages/apps-engine/src/server/runtime/deno/LivenessManager.ts index 5b9a7d3b6b96..61d208786f9d 100644 --- a/packages/apps-engine/src/server/runtime/deno/LivenessManager.ts +++ b/packages/apps-engine/src/server/runtime/deno/LivenessManager.ts @@ -73,7 +73,7 @@ export class LivenessManager { if (reason instanceof Error && reason.message.startsWith('DECODE_ERROR')) { await this.restartProcess('Decode error', 'controller'); } - }) + }); } public getRuntimeData() { diff --git a/packages/apps-engine/src/server/runtime/deno/ProcessMessenger.ts b/packages/apps-engine/src/server/runtime/deno/ProcessMessenger.ts index e0eb3c225c22..4d76f4c4c10d 100644 --- a/packages/apps-engine/src/server/runtime/deno/ProcessMessenger.ts +++ b/packages/apps-engine/src/server/runtime/deno/ProcessMessenger.ts @@ -2,10 +2,11 @@ import type { ChildProcess } from 'child_process'; import type { JsonRpc } from 'jsonrpc-lite'; -import { Encoder, newEncoder } from './codec'; +import { type Encoder, newEncoder } from './codec'; export class ProcessMessenger { private deno: ChildProcess | undefined; + private encoder: Encoder | undefined; private _sendStrategy: (message: JsonRpc) => void;