auto detect ip address if not provided

Author: randilfernando

node/mesh_peer.ts

@@ -12,7 +12,7 @@ async function main() {
             heartbeat_threshold: 3
         },
         pubsub: {},
-        host: '127.0.0.1',
+        // host: '127.0.0.1', 
         port: 0
     };
 

node/src/demo_client.ts

@@ -8,7 +8,7 @@ async function main() {
             heartbeat_threshold: 3
         },
         pubsub: {},
-        host: '127.0.0.1',
+        // host: '127.0.0.1', // Auto-detected
         port: 0
     };
 

node/src/mesh.ts

@@ -1,4 +1,5 @@
 import { v4 as uuidv4 } from 'uuid';
+import * as os from 'os';
 import { MeshConfig, Node, Message } from './shared/types';
 import { RedisServiceDiscovery } from './discovery/redis-discovery';
 import { H2Communication } from './communication/h2-communication';
@@ -28,6 +29,12 @@ export class Mesh implements IMesh {
 
     constructor(config: MeshConfig) {
         this.config = config;
+
+        if (!this.config.host) {
+            this.config.host = this.getLocalIP();
+            console.log(`[Mesh] Auto-detected host IP: ${this.config.host}`);
+        }
+
         this.discovery = new RedisServiceDiscovery(config.redis, config.service_discovery);
         this.communication = new H2Communication(config);
         this.pubsub = new RedisPubSub(config.redis);
@@ -51,7 +58,7 @@ export class Mesh implements IMesh {
         // Register with SD
         const node: Node = {
             id: this.nodeId,
-            host: this.config.host,
+            host: this.config.host!, // Detected in constructor
             port: this.config.port,
             service_name: serviceName
         };
@@ -60,6 +67,20 @@ export class Mesh implements IMesh {
         console.log(`[Mesh] Registered service '${serviceName}' on ${node.host}:${node.port}`);
     }
 
+    private getLocalIP(): string {
+        const interfaces = os.networkInterfaces();
+        for (const name of Object.keys(interfaces)) {
+            for (const iface of interfaces[name]!) {
+                // Skip internal and non-IPv4 addresses
+                if ('IPv4' !== iface.family || iface.internal) {
+                    continue;
+                }
+                return iface.address;
+            }
+        }
+        return '127.0.0.1'; // Fallback
+    }
+
     public service(name: string): IServiceClient {
         return new ServiceClient(name, this.discovery, this.communication);
     }

node/src/shared/types.ts

@@ -31,7 +31,7 @@ export interface MeshConfig {
     redis: RedisConfig; // Shared Redis Configuration
     service_discovery: ServiceDiscoveryConfig;
     pubsub?: PubSubConfig;
-    host: string;
+    host?: string;
     port: number; // 0 for dynamic
     debug?: boolean;
 }

python/mesh_peer.py

@@ -18,7 +18,7 @@ async def main():
             heartbeat_interval=2,
             heartbeat_threshold=3
         ),
-        host="127.0.0.1",
+        # host="127.0.0.1", # Auto-detected
         port=0
     )
 

python/src/mesh_lib/mesh.py

@@ -1,5 +1,6 @@
 import asyncio
 import uuid
+import socket
 from typing import Optional, List, Callable, Awaitable
 from mesh_lib.shared.types import MeshConfig, Node, Message
 from mesh_lib.service_discovery import RedisServiceDiscovery
@@ -9,9 +10,27 @@
 from mesh_lib.abstract import IMesh, IChannel, ITopic, IServiceHandlers
 from mesh_lib.service_client import ServiceClient
 
-class Mesh(IMesh):
+class Mesh(IMesh):    
+    @staticmethod
+    def _get_local_ip() -> str:
+        try:
+            # Trick to finding local IP by connecting to a public DNS
+            # (doesn't actually establish connection)
+            s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
+            s.connect(("8.8.8.8", 80))
+            ip = s.getsockname()[0]
+            s.close()
+            return ip
+        except Exception:
+            return "127.0.0.1"
+
     def __init__(self, config: MeshConfig):
         self.config = config
+        
+        if not self.config.host:
+            self.config.host = self._get_local_ip()
+            print(f"[Mesh] Auto-detected host IP: {self.config.host}")
+            
         self.service_discovery = RedisServiceDiscovery(config.redis, config.service_discovery)
         self.communication = H2Communication(config, self.service_discovery)
         self.pubsub = RedisPubSub(config.redis)

python/src/mesh_lib/shared/types.py

@@ -21,7 +21,7 @@ class PubSubConfig:
 class MeshConfig:
     service_discovery: ServiceDiscoveryConfig
     pubsub: PubSubConfig = field(default_factory=PubSubConfig)
-    host: str = "127.0.0.1"
+    host: Optional[str] = None
     port: int = 8000
     debug: bool = False
     redis: Dict[str, Any] = field(default_factory=dict) # Shared Redis Config