server: fixup address, make it available on cluster manager

Author: koush

sdk/package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "@scrypted/sdk",
-  "version": "0.3.112",
+  "version": "0.3.113",
   "description": "",
   "main": "dist/src/index.js",
   "exports": {

sdk/package.json

@@ -1,6 +1,6 @@
 {
   "name": "@scrypted/types",
-  "version": "0.3.104",
+  "version": "0.3.105",
   "description": "",
   "main": "dist/index.js",
   "author": "",

sdk/types/package-lock.json

@@ -957,7 +957,7 @@ class TamperState(TypedDict):
     pass
 
 
-TYPES_VERSION = "0.3.104"
+TYPES_VERSION = "0.3.105"
 
 
 class AirPurifier:
@@ -1859,6 +1859,9 @@ async def setLocalAddresses(self, addresses: list[str]) -> None:
 
 class ClusterManager:
 
+    def getClusterAddress(self) -> str:
+        pass
+
     def getClusterMode(self) -> Any | Any:
         pass
 

sdk/types/package.json

@@ -2722,6 +2722,7 @@ export interface ClusterManager {
    * Returns undefined if this is not a cluster worker.
    */
   getClusterWorkerId(): string;
+  getClusterAddress(): string;
   getClusterMode(): 'server' | 'client' | undefined;
   getClusterWorkers(): Promise<Record<string, ClusterWorker>>;
 }

sdk/types/scrypted_python/scrypted_sdk/types.py

@@ -1,11 +1,11 @@
 {
   "name": "@scrypted/server",
-  "version": "0.136.1",
+  "version": "0.137.0",
   "description": "",
   "dependencies": {
     "@scrypted/ffmpeg-static": "^6.1.0-build3",
     "@scrypted/node-pty": "^1.0.22",
-    "@scrypted/types": "^0.3.104",
+    "@scrypted/types": "^0.3.105",
     "adm-zip": "^0.5.16",
     "body-parser": "^1.20.3",
     "cookie-parser": "^1.4.7",

sdk/types/src/types.input.ts

@@ -243,6 +243,9 @@ def __init__(self, remote: PluginRemote):
     def getClusterMode(self) -> Any | Any:
         return os.getenv("SCRYPTED_CLUSTER_MODE", None)
 
+    def getClusterAddress(self) -> str:
+        return os.getenv("SCRYPTED_CLUSTER_ADDRESS", None)
+
     def getClusterWorkerId(self) -> str:
         return self.remote.clusterSetup.clusterWorkerId
 

server/package-lock.json

@@ -15,6 +15,10 @@ export class ClusterManagerImpl implements ClusterManager {
         return this.clusterWorkerId;
     }
 
+    getClusterAddress(): string {
+        return process.env.SCRYPTED_CLUSTER_ADDRESS;
+    }
+
     getClusterMode(): 'server' | 'client' | undefined {
         return this.clusterMode;
     }

server/package.json

@@ -5,6 +5,7 @@ import type { RuntimeWorkerOptions } from "../plugin/runtime/runtime-worker";
 import { RpcPeer } from "../rpc";
 import type { ScryptedRuntime } from "../runtime";
 import type { ClusterForkOptions, ClusterForkParam, ClusterForkResultInterface, PeerLiveness, RunningClusterWorker } from "../scrypted-cluster-main";
+import { removeIPv4EmbeddedIPv6 } from "../ip";
 
 class WrappedForkResult implements ClusterForkResultInterface {
     [RpcPeer.PROPERTY_PROXY_PROPERTIES] = {
@@ -109,7 +110,7 @@ export class ClusterForkService {
                 labels: worker.labels,
                 forks: [...worker.forks] as ClusterFork[],
                 mode: worker.mode,
-                address: worker.address,
+                address: removeIPv4EmbeddedIPv6(worker.address),
             };
         }
         return ret;