server: fix cluster dependencies

koush · Dec 10, 2024 · ac882c7 · ac882c7
1 parent 02cde63
commit ac882c7
Show file tree

Hide file tree

Showing 3 changed files with 8 additions and 5 deletions.
diff --git a/server/src/plugin/cluster.ts b/server/src/plugin/cluster.ts
@@ -1,9 +1,12 @@
-import type { ClusterManager } from "@scrypted/types";
+import type { ClusterManager, ClusterWorker } from "@scrypted/types";
 import type { PluginAPI } from "./plugin-api";
-import type { ClusterForkService } from "../services/cluster-fork";
+
+export interface ClusterForkServiceInterface {
+    getClusterWorkers(): Promise<Record<string, ClusterWorker>>;
+}
 
 export class ClusterManagerImpl implements ClusterManager {
-    private clusterServicePromise: Promise<ClusterForkService>;
+    private clusterServicePromise: Promise<ClusterForkServiceInterface>;
 
     constructor(public clusterMode: undefined | 'client' | 'server', private api: PluginAPI, private clusterWorkerId: string) {
     }

diff --git a/server/src/plugin/plugin-remote.ts b/server/src/plugin/plugin-remote.ts
@@ -160,7 +160,7 @@ export function attachPluginRemote(peer: RpcPeer, options?: PluginRemoteAttachOp
             deviceManager,
             endpointManager,
             mediaManager,
-            clusterManager: undefined,
+            clusterManager,
             log,
             pluginHostAPI: api,
             pluginRemoteAPI: undefined,

diff --git a/server/src/state.ts b/server/src/state.ts
@@ -1,4 +1,4 @@
-import { EventDetails, EventListenerOptions, EventListenerRegister, Refresh, ScryptedInterface, ScryptedInterfaceProperty, ScryptedNativeId, SystemDeviceState } from "@scrypted/types";
+import { EventDetails, EventListenerOptions, EventListenerRegister, Refresh, ScryptedInterface, ScryptedInterfaceProperty, SystemDeviceState } from "@scrypted/types";
 import throttle from 'lodash/throttle';
 import { PluginDevice } from "./db-types";
 import { EventListenerRegisterImpl, EventRegistry, getMixinEventName } from "./event-registry";