Fixed http to ws prefix

renoki-co · Aug 3, 2021 · 1d78d9b · 1d78d9b
1 parent 8654bf3
commit 1d78d9b
Showing 1 changed file with 11 additions and 5 deletions.
diff --git a/src/KubernetesCluster.php b/src/KubernetesCluster.php
@@ -289,11 +289,17 @@ protected function makeRequest(string $method, string $path, string $payload = '
      */
     protected function makeWsRequest(string $path, Closure $callback = null, array $query = ['pretty' => 1])
     {
-        $url = str_replace(
-            ['https://', 'http://'],
-            ['wss://', 'ws://'],
-            $this->getCallableUrl($path, $query)
-        );
+        $url = $this->getCallableUrl($path, $query);
+
+        // Replace the HTTP protocol prefixes with WS protocols.
+        $replaces = [
+            'https://' => 'wss://',
+            'http://' => 'ws://',
+        ];
+
+        foreach ($replaces as $search => $replace) {
+            $url = Str::replaceFirst($search, $replace, $url);
+        }
 
         [$loop, $ws] = $this->getWsClient($url);