PHPLIB-510: Implement FLE spec tests

Author: alcaeus

tests/FunctionalTestCase.php

@@ -375,6 +375,17 @@ protected function skipIfCausalConsistencyIsNotSupported()
         }
     }
 
+    protected function skipIfClientSideEncryptionIsNotSupported()
+    {
+        if (version_compare($this->getFeatureCompatibilityVersion(), '4.2', '<')) {
+            $this->markTestSkipped('Client Side Encryption only supported on FCV 4.2 or higher');
+        }
+
+        if ($this->getModuleInfo('libmongocrypt') === 'disabled') {
+            $this->markTestSkipped('Client Side Encryption is not enabled in the MongoDB extension');
+        }
+    }
+
     protected function skipIfTransactionsAreNotSupported()
     {
         if ($this->getPrimaryServer()->getType() === Server::TYPE_STANDALONE) {
@@ -420,6 +431,26 @@ private function disableFailPoints()
         }
     }
 
+    /**
+     * @param string $row
+     *
+     * @return string|null
+     */
+    private function getModuleInfo($row)
+    {
+        ob_start();
+        phpinfo(INFO_MODULES);
+        $info = ob_get_clean();
+
+        $pattern = sprintf('/^%s([\w ]+)$/m', preg_quote($row . ' => '));
+
+        if (preg_match($pattern, $info, $matches) !== 1) {
+            return null;
+        }
+
+        return $matches[1];
+    }
+
     /**
      * Checks if the failCommand command is supported on this server version
      *

tests/SpecTests/ChangeStreamsSpecTest.php

@@ -180,7 +180,7 @@ private function createChangeStream(stdClass $test)
 
         switch ($test->target) {
             case 'client':
-                return $context->client->watch($pipeline, $options);
+                return $context->getClient()->watch($pipeline, $options);
             case 'database':
                 return $context->getDatabase()->watch($pipeline, $options);
             case 'collection':
@@ -228,7 +228,7 @@ private function dropDatabasesAndCreateCollection($databaseName, $collectionName
     {
         $context = $this->getContext();
 
-        $database = $context->client->selectDatabase($databaseName);
+        $database = $context->getClient()->selectDatabase($databaseName);
         $database->drop($context->defaultWriteOptions);
         $database->createCollection($collectionName, $context->defaultWriteOptions);
     }