fix: Set unique ingress hostnames for local Kind clusters

cli/cmd/ingress.go

@@ -111,6 +111,11 @@
 				}
 			}
 
+			// Necessary for WebSocket support with Contour
+			if ingressClassName == "contour" {
+				annotationsMap["projectcontour.io/websocket-routes"] = "/"
+			}
+
 			if useExisting {
 				output.InfoMessage("Configuring Drasi to use existing ingress controller")
 				output.InfoMessage(fmt.Sprintf("IngressClass: %s", ingressClassName))
@@ -143,12 +148,23 @@
 
 				// Get configuration from the installer
 				installerConfig := ingressInstaller.GetIngressConfig()
-				config := &sdk.IngressConfig{
-					IngressClassName:   installerConfig.ClassName,
-					IngressService:     installerConfig.ServiceName,
-					IngressNamespace:   installerConfig.Namespace,
-					GatewayIPAddress:   "",
-					IngressAnnotations: annotationsMap, // Include annotations for Contour too
+				var config *sdk.IngressConfig
+				if localCluster {
+					config = &sdk.IngressConfig{
+						IngressClassName:   installerConfig.ClassName,
+						IngressService:     installerConfig.ServiceName,
+						IngressNamespace:   installerConfig.Namespace,
+						GatewayIPAddress:   "127.0.0.1",
+						IngressAnnotations: annotationsMap, // Include annotations for Contour too
+					}
+				} else {
+					config = &sdk.IngressConfig{
+						IngressClassName:   installerConfig.ClassName,
+						IngressService:     installerConfig.ServiceName,
+						IngressNamespace:   installerConfig.Namespace,
+						GatewayIPAddress:   "",
+						IngressAnnotations: annotationsMap, // Include annotations for Contour too
+					}
 				}
 				if err := k8sPlatformClient.UpdateIngressConfig(config, output); err != nil {
 					return err

control-planes/kubernetes_provider/src/controller/reconciler.rs

@@ -608,8 +608,10 @@
                                     if ip_suffix != "UNAVAILABLE" {
                                         rule.host = Some(host.replace("PLACEHOLDER", &ip_suffix));
                                     } else {
-                                        log::warn!("Could not determine external IP, using None");
-                                        rule.host = None;
+                                        log::warn!(
+                                            "Could not determine external IP, using 127.0.0.1"
+                                        );
+                                        rule.host = Some(host.replace("PLACEHOLDER", "127.0.0.1"));
                                     }
                                 }
                             }

e2e-tests/fixtures/signalr-fixture.js

@@ -45,11 +45,11 @@
     this.localPort = parseInt(process.env.INGRESS_PORT) || 8001;
 
     // Generate the hostname that the ingress expects
-    // Format: {reaction-name}.drasi.{ip}.nip.io
-    // For local testing with kind, we can use localhost
-    this.hostname = `${this.reactionManifest.name}.drasi.localhost`;
+    // Format: {reaction-name}.drasi.127.0.0.1.nip.io
+    // This matches the format used by drasi ingress init --local-cluster
+    this.hostname = `${this.reactionManifest.name}.drasi.127.0.0.1.nip.io`;
 
-    console.log(`SignalRFixture: Using localhost access on port ${this.localPort}`);
+    console.log(`SignalRFixture: Using ingress access on port ${this.localPort}`);
     console.log(`SignalRFixture: Using hostname: ${this.hostname}`);
 
     // Initialize SignalR connection through ingress
@@ -62,14 +62,12 @@
   }
 
   async connectSignalR() {
-    // Create SignalR connection through ingress via localhost
-    const hubUrl = `http://localhost:${this.localPort}/hub`;
-
+    // Create SignalR connection through ingress using nip.io hostname
+    // nip.io automatically resolves *.127.0.0.1.nip.io to 127.0.0.1
+    const hubUrl = `http://${this.hostname}:${this.localPort}/hub`;
+
     this.signalr = new signalR.HubConnectionBuilder()
       .withUrl(hubUrl, {
-        headers: {
-          'Host': this.hostname  // Set Host header for ingress routing
-        },
         transport: signalR.HttpTransportType.LongPolling, // Force long polling instead of WebSockets
       })
       .withAutomaticReconnect()

e2e-tests/kind-config.yaml

@@ -2,11 +2,10 @@ kind: Cluster
 apiVersion: kind.x-k8s.io/v1alpha4
 nodes:
 - role: control-plane
-- role: worker
   extraPortMappings:
   - containerPort: 30080  # Maps to contour-envoy NodePort 30080
     hostPort: 8001
     listenAddress: "0.0.0.0"
-  - containerPort: 30443  # Maps to contour-envoy NodePort 30443  
+  - containerPort: 30443  # Maps to contour-envoy NodePort 30443
     hostPort: 443
     listenAddress: "0.0.0.0"