Merge pull request #103

Author: jmikola

src/Database.php

@@ -170,6 +170,10 @@ public function command($command, array $options = [])
      */
     public function createCollection($collectionName, array $options = [])
     {
+        if ( ! isset($options['typeMap'])) {
+            $options['typeMap'] = $this->typeMap;
+        }
+
         $operation = new CreateCollection($this->databaseName, $collectionName, $options);
         $server = $this->manager->selectServer(new ReadPreference(ReadPreference::RP_PRIMARY));
 

src/Operation/CreateCollection.php

@@ -51,6 +51,9 @@ class CreateCollection implements Executable
      *
      *  * storageEngine (document): Storage engine options.
      *
+     *  * typeMap (array): Type map for BSON deserialization. This will only be
+     *    used for the returned command result document.
+     *
      *  * validationAction (string): Validation action.
      *
      *  * validationLevel (string): Validation level.
@@ -98,6 +101,10 @@ public function __construct($databaseName, $collectionName, array $options = [])
             throw InvalidArgumentException::invalidType('"storageEngine" option', $options['storageEngine'], 'array or object');
         }
 
+        if (isset($options['typeMap']) && ! is_array($options['typeMap'])) {
+            throw InvalidArgumentException::invalidType('"typeMap" option', $options['typeMap'], 'array');
+        }
+
         if (isset($options['validationAction']) && ! is_string($options['validationAction'])) {
             throw InvalidArgumentException::invalidType('"validationAction" option', $options['validationAction'], 'string');
         }
@@ -126,6 +133,10 @@ public function execute(Server $server)
     {
         $cursor = $server->executeCommand($this->databaseName, $this->createCommand());
 
+        if (isset($this->options['typeMap'])) {
+            $cursor->setTypeMap($this->options['typeMap']);
+        }
+
         return current($cursor->toArray());
     }
 

tests/Operation/CreateCollectionTest.php

@@ -51,6 +51,10 @@ public function provideInvalidConstructorOptions()
             $options[][] = ['storageEngine' => $value];
         }
 
+        foreach ($this->getInvalidArrayValues() as $value) {
+            $options[][] = ['typeMap' => $value];
+        }
+
         foreach ($this->getInvalidStringValues() as $value) {
             $options[][] = ['validationAction' => $value];
         }