pub to pubsub url as well

pdsinterop · Nov 9, 2020 · f3862bb · f3862bb
1 parent 0a699e6
commit f3862bb
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/src/Server.php b/src/Server.php
@@ -303,11 +303,15 @@ private function handleCreateDirectoryRequest(Response $response, string $path)
 	}
 
 	private function sendWebsocketUpdate($path) {
-		$client = new \WebSocket\Client("ws://localhost:8080/");
-		$client->send("pub https://localhost$path\n");
+		$baseUrl = "https://" . $request->getServerParams()["SERVER_NAME"];
+		$pubsub = getenv('PUBSUB_URL') ?: ("http://" . $request->getServerParams()["SERVER_NAME"] . ":8080/");
+		$pubsub = str_replace("https://", "ws://", $pubsub);
+		$pubsub = str_replace("http://", "ws://", $pubsub);
+		$client = new \WebSocket\Client($pubsub);
+		$client->send("pub $baseUrl$path\n");
 		while ($path != "/") {
 			$path = $this->parentPath($path);
-			$client->send("pub https://localhost$path\n");
+			$client->send("pub $baseUrl$path\n");
 		}
 	}