Allow passing Client as configuration option.

Prevent calling database creation if Client driver does not support QueryDriverInterface

Author: Steveb-p

InfluxDbStorage.php

@@ -204,8 +204,22 @@ public function pushSentMessageStats(SentMessageStats $stats): void
 
     private function doWrite(array $points): void
     {
-        if (!$this->client || $this->client->getDriver() instanceof QueryDriverInterface) {
-            $this->getDb()->writePoints($points, Database::PRECISION_MILLISECONDS, $this->config['retentionPolicy']);
+        if (null === $this->client) {
+            $this->client = new Client(
+                $this->config['host'],
+                $this->config['port'],
+                $this->config['user'],
+                $this->config['password']
+            );
+        }
+
+        if ($this->client->getDriver() instanceof QueryDriverInterface) {
+            if (null === $this->database) {
+                $this->database = $this->client->selectDB($this->config['db']);
+                $this->database->create();
+            }
+
+            $this->database->writePoints($points, Database::PRECISION_MILLISECONDS, $this->config['retentionPolicy']);
         } else {
             // Code below mirrors what `writePoints` method of Database does.
             try {
@@ -225,25 +239,6 @@ private function doWrite(array $points): void
         }
     }
 
-    private function getDb(): Database
-    {
-        if (null === $this->client) {
-            $this->client = new Client(
-                $this->config['host'],
-                $this->config['port'],
-                $this->config['user'],
-                $this->config['password']
-            );
-        }
-
-        if (null === $this->database) {
-            $this->database = $this->client->selectDB($this->config['db']);
-            $this->database->create();
-        }
-
-        return $this->database;
-    }
-
     private static function parseDsn(string $dsn): array
     {
         $dsn = Dsn::parseFirst($dsn);