Fixed #692

Author: Geolim4

lib/Phpfastcache/Drivers/Mongodb/Config.php

@@ -70,6 +70,11 @@ class Config extends ConfigurationOption
      */
     protected $driverOptions = [];
 
+    /**
+     * @var string
+     */
+    protected $protocol = 'mongodb';
+
     /**
      * @return string
      */
@@ -250,4 +255,22 @@ public function setDriverOptions(array $driverOptions): self
         $this->driverOptions = $driverOptions;
         return $this;
     }
+
+    /**
+     * @return string
+     */
+    public function getProtocol(): string
+    {
+        return $this->protocol;
+    }
+
+    /**
+     * @param string $protocol
+     * @return self
+     */
+    public function setProtocol(string $protocol): self
+    {
+        $this->protocol = $protocol;
+        return $this;
+    }
 }

lib/Phpfastcache/Drivers/Mongodb/Driver.php

@@ -228,28 +228,29 @@ protected function buildConnectionURI($databaseName = ''): string
         $servers = $this->getConfig()->getServers();
         $options = $this->getConfig()->getOptions();
 
+        $protocol = $this->getConfig()->getProtocol();
         $host = $this->getConfig()->getHost();
         $port = $this->getConfig()->getPort();
         $username = $this->getConfig()->getUsername();
         $password = $this->getConfig()->getPassword();
 
         if( \count($servers) > 0 ){
-            $host = \array_reduce($servers, function($carry, $data){
+            $host = \array_reduce($servers, static function($carry, $data){
                 $carry .= ($carry === '' ? '' : ',').$data['host'].':'.$data['port'];
                 return $carry;
             }, '');
             $port = false;
         }
 
-        return implode('', [
-            'mongodb://',
-            ($username ?: ''),
-            ($password ? ":{$password}" : ''),
-            ($username ? '@' : ''),
+        return \implode('', [
+            "{$protocol}://",
+            $username ?: '',
+            $password ? ":{$password}" : '',
+            $username ? '@' : '',
             $host,
-            ($port !== 27017 && $port !== false ? ":{$port}" : ''),
-            ($databaseName ? "/{$databaseName}" : ''),
-            (\count($options) > 0 ? '?'.\http_build_query($options) : ''),
+            $port !== 27017 && $port !== false ? ":{$port}" : '',
+            $databaseName ? "/{$databaseName}" : '',
+            \count($options) > 0 ? '?'.\http_build_query($options) : '',
         ]);
     }