Added exclusion for Relay connection

vladvildanov · vladvildanov · commit 15de538b0d11 · 2023-08-01T09:59:50.000+03:00
diff --git a/src/Connection/Factory.php b/src/Connection/Factory.php
@@ -175,13 +175,15 @@ protected function prepareConnection(NodeConnectionInterface $connection)
             );
         }
 
-        $connection->addConnectCommand(
-            new RawCommand('CLIENT', ['SETINFO', 'LIB-NAME', 'predis'])
-        );
+        if (!$connection instanceof RelayConnection) {
+            $connection->addConnectCommand(
+                new RawCommand('CLIENT', ['SETINFO', 'LIB-NAME', 'predis'])
+            );
 
-        $connection->addConnectCommand(
-            new RawCommand('CLIENT', ['SETINFO', 'LIB-VER', Client::VERSION])
-        );
+            $connection->addConnectCommand(
+                new RawCommand('CLIENT', ['SETINFO', 'LIB-VER', Client::VERSION])
+            );
+        }
 
         if (isset($parameters->database) && strlen($parameters->database)) {
             $connection->addConnectCommand(
diff --git a/src/Connection/RelayConnection.php b/src/Connection/RelayConnection.php
@@ -257,24 +257,6 @@ public function executeCommand(CommandInterface $command)
         }
     }
 
-    /**
-     * @throws ConnectionException
-     * @throws ClientException
-     * @throws ServerException
-     */
-    public function connect()
-    {
-        foreach ($this->initCommands as $command) {
-            try {
-                $this->executeCommand($command);
-            } catch (ServerException $ex) {
-                if ($command->getId() !== 'CLIENT') {
-                    throw $ex;
-                }
-            }
-        }
-    }
-
     /**
      * {@inheritdoc}
      */
