Inline compression and decompression instead of delegating

Author: thekid

src/main/php/com/mongodb/io/Compressor.class.php

@@ -12,14 +12,6 @@ public function __construct(int $id, Algorithm $algorithm, $options= null) {
     $this->options= $options;
   }
 
-  public function compress($data) {
-    return $this->algorithm->compress($data, $this->options);
-  }
-
-  public function decompress($compressed) {
-    return $this->algorithm->decompress($compressed);
-  }
-
   public function toString() { return nameof($this).'(id: '.$this->id.', options: '.$this->options.')'; }
 
   public function hashCode() { return 'C'.$this->id; }

src/main/php/com/mongodb/io/Connection.class.php

@@ -239,7 +239,7 @@ public function send($operation, $header, $sections, $readPreference= null) {
     $length= strlen($body);
 
     if ($this->compression && $compressor= $this->compression->for($sections, $length)) {
-      $compressed= $compressor->compress($body);
+      $compressed= $compressor->algorithm->compress($body, $compressor->options);
       $this->socket->write(pack(
         'VVVVVVCa*',
         strlen($compressed) + 25,
@@ -284,7 +284,7 @@ public function send($operation, $header, $sections, $readPreference= null) {
         $compressed= unpack('VoriginalOpcode/VuncompressedSize/CcompressorId', $response);
 
         if ($this->compression && $compressor= $this->compression->select($compressed['compressorId'] ?? null)) {
-          $response= $compressor->decompress(substr($response, 9));
+          $response= $compressor->algorithm->decompress(substr($response, 9));
           $meta['opCode']= $compressed['originalOpcode'];
           goto opcode;
         }

src/test/php/com/mongodb/unittest/ConnectionTest.class.php

@@ -32,7 +32,7 @@ private function msg(array $document): array {
   /** Creates an OP_COMPRESSED message with an embedded OP_MSG opcode */
   private function compressed(Compressor $compressor, array $document): array {
     $payload= pack('VC', 0, 0).$this->bson->sections($document);
-    $compressed= $compressor->compress($payload);
+    $compressed= $compressor->algorithm->compress($payload, $compressor->options);
     return [
       pack('VVVV', strlen($compressed) + 25, 0, 0, Connection::OP_COMPRESSED),
       pack('VVC', Connection::OP_MSG, strlen($payload), $compressor->id).$compressed