added ability to enable / disable deflate filter on write queries

Author: facedsid

src/Transport/HttpTransport.php

@@ -30,7 +30,7 @@ class HttpTransport implements TransportInterface
     protected $httpClient;
 
     /**
-     * Array with two keys (read and write) with guzzle options for corresponding requests.
+     * Array with three keys (read, write and deflate) with guzzle options for corresponding requests.
      *
      * [
      *   'read' => [
@@ -41,6 +41,7 @@ class HttpTransport implements TransportInterface
      *     'debug' => true,
      *     'timeout' => 100,
      *   ],
+     *   'deflate' => true
      * ]
      *
      * @var array
@@ -60,17 +61,32 @@ public function __construct(Client $client = null, array $options = [])
         $this->options = $options;
     }
 
+    /**
+     * Returns flag to enable / disable queries and data compression
+     *
+     * @return bool
+     */
+    protected function isDeflateEnabled(): bool
+    {
+        return $this->options['deflate'] ?? true;
+    }
+
     /**
      * Returns default headers for requests.
      *
      * @return array
      */
     protected function getHeaders()
     {
-        return [
+        $headers = [
             'Accept-Encoding'  => 'gzip',
-            'Content-Encoding' => 'gzip',
         ];
+
+        if ($this->isDeflateEnabled()) {
+            $headers['Content-Encoding'] = 'gzip';
+        }
+
+        return $headers;
     }
 
     /**
@@ -121,7 +137,7 @@ public function write(array $queries, int $concurrency = 5) : array
                             'query' => $query->getQuery(),
                         ], $query->getSettings());
 
-                        $stream = $file->open();
+                        $stream = $file->open($this->isDeflateEnabled());
                         $openedStreams[] = $stream;
 
                         $request = new Request('POST', $uri, $headers, $stream);
@@ -133,7 +149,8 @@ public function write(array $queries, int $concurrency = 5) : array
 
                     $uri = $this->buildRequestUri($query->getServer(), [], $query->getSettings());
 
-                    $request = new Request('POST', $uri, $headers, gzencode($query->getQuery()));
+                    $sql = $this->isDeflateEnabled() ? gzencode($query->getQuery()) : $query->getQuery();
+                    $request = new Request('POST', $uri, $headers, $sql);
 
                     yield $request;
                 }