Addition of gzip feature

composer.json

@@ -15,6 +15,7 @@
         "ext-curl": "*",
         "ext-json": "*",
         "ext-mbstring": "*",
+        "ext-zlib": "^7.3",
         "psr/http-message": "^1.0",
         "psr/log": "^1.0",
         "psr/simple-cache": "^1.0"

src/Config/AbstractConfig.php

@@ -29,6 +29,7 @@ public function getDefaultConfig()
             'writeTimeout' => $this->defaultWriteTimeout,
             'connectTimeout' => $this->defaultConnectTimeout,
             'defaultHeaders' => array(),
+            'gzipEnabled' => false,
         );
     }
 
@@ -115,4 +116,28 @@ public function setDefaultHeaders(array $defaultHeaders)
 
         return $this;
     }
+
+    /**
+     * @return boolean
+     */
+    public function getGzipEnabled()
+    {
+        return $this->config['gzipEnabled'];
+    }
+
+    /**
+     * @param boolean $gzipEnabled
+     *
+     * @return $this
+     */
+    public function setGzipEnabled($gzipEnabled)
+    {
+        if (!is_bool($gzipEnabled)) {
+            throw new \InvalidArgumentException('Default configuration for GzipEnabled must be a boolean');
+        }
+
+        $this->config['gzipEnabled'] = $gzipEnabled;
+
+        return $this;
+    }
 }

src/Config/SearchConfig.php

@@ -29,6 +29,7 @@ public function getDefaultConfig()
             'defaultHeaders' => array(),
             'defaultForwardToReplicas' => null,
             'batchSize' => 1000,
+            'gzipEnabled' => true,
         );
     }
 

src/Http/Psr7/Request.php

@@ -62,6 +62,10 @@ public function __construct(
             $this->updateHostFromUri();
         }
 
+        if ($this->hasHeader('Content-Encoding')) {
+            $body = gzencode($body, 9);
+        }
+
         if ('' !== $body && null !== $body) {
             $this->stream = stream_for($body);
         }

src/RetryStrategy/ApiWrapper.php

@@ -111,6 +111,10 @@ public function send($method, $path, $requestOptions = array(), $hosts = null)
 
     private function request($method, $path, RequestOptions $requestOptions, $hosts, $timeout, $data = array())
     {
+        if ($this->canEnableGzipCompress($method)) {
+            $requestOptions->addHeader('Content-Encoding', 'gzip');
+        }
+
         $uri = $this->createUri($path)
             ->withQuery($requestOptions->getBuiltQueryParameters())
             ->withScheme('https');
@@ -215,6 +219,14 @@ private function createUri($uri)
         throw new \InvalidArgumentException('URI must be a string or UriInterface');
     }
 
+    /**
+     * @param $method
+     * @param $uri
+     * @param array $headers
+     * @param null $body
+     * @param string $protocolVersion
+     * @return Request
+     */
     private function createRequest(
         $method,
         $uri,
@@ -239,6 +251,12 @@ private function createRequest(
         return new Request($method, $uri, $headers, $body, $protocolVersion);
     }
 
+    private function canEnableGzipCompress($method)
+    {
+        return (strtoupper($method) === 'POST' || strtoupper($method) === 'PUT')
+            && $this->config->getGzipEnabled();
+    }
+
     /**
      * @param string $level
      * @param string $message

tests/Integration/IndexingTest.php

@@ -56,7 +56,6 @@ public function testIndexing()
         $multiResponse->wait();
 
         /* Check 6 first records with getObject */
-
         $objectID1 = $responses[0][0]['objectIDs'][0];
         $objectID2 = $responses[1][0]['objectIDs'][0];
         $objectID3 = $responses[2][0]['objectIDs'][0];