Ensure no MongoDB driver classes are serialized

README.md

@@ -54,6 +54,11 @@ counterparts in `ext-mongo`. Do not rely on exception messages being the same.
 Methods that return a result array containing a `connectionId` field will always
 return `0` as connection ID.
 
+## Serialization of objects
+Serialization of any Mongo* objects (e.g. MongoGridFSFile, MongoCursor, etc.)
+will not work properly. The objects can be serialized but are not usable after
+unserializing them.
+
 ## Mongo
 
  - The Mongo class is deprecated and was not implemented in this library. If you

lib/Alcaeus/MongoDbAdapter/AbstractCursor.php

@@ -375,4 +375,12 @@ protected function reset()
         $this->cursor = null;
         $this->iterator = null;
     }
+
+    /**
+     * @return array
+     */
+    public function __sleep()
+    {
+        return ['batchSize', 'connection', 'iterator', 'ns', 'optionNames', 'position', 'startedIterating'];
+    }
 }

lib/Mongo/MongoClient.php

@@ -334,5 +334,15 @@ private function notImplemented()
     {
         throw new \Exception('Not implemented');
     }
+
+    /**
+     * @return array
+     */
+    function __sleep()
+    {
+        return [
+            'connected', 'status', 'server', 'persistent'
+        ];
+    }
 }
 

lib/Mongo/MongoCollection.php

@@ -958,5 +958,13 @@ private function checkCollectionName($name)
             throw new Exception('Collection name cannot contain null bytes');
         }
     }
+
+    /**
+     * @return array
+     */
+    public function __sleep()
+    {
+        return ['db', 'name'];
+    }
 }
 

lib/Mongo/MongoCommandCursor.php

@@ -100,4 +100,12 @@ protected function getIterationInfo()
 
         return $iterationInfo;
     }
+
+    /**
+     * @return array
+     */
+    public function __sleep()
+    {
+        return ['command'] + parent::__sleep();
+    }
 }

lib/Mongo/MongoCursor.php

@@ -455,4 +455,28 @@ protected function getCursorInfo()
             'fields' => $this->projection,
         ];
     }
+
+    /**
+     * @return array
+     */
+    public function __sleep()
+    {
+        return [
+            'allowPartialResults',
+            'awaitData',
+            'flags',
+            'hint',
+            'limit',
+            'maxTimeMS',
+            'noCursorTimeout',
+            'optionNames',
+            'options',
+            'projection',
+            'query',
+            'skip',
+            'snapshot',
+            'sort',
+            'tailable',
+        ] + parent::__sleep();
+    }
 }

lib/Mongo/MongoDB.php

@@ -541,4 +541,12 @@ private function getSystemCollectionFilterClosure($includeSystemCollections = fa
             return $includeSystemCollections || ! preg_match('#^system\.#', $collectionInfo->getName());
         };
     }
+
+    /**
+     * @return array
+     */
+    public function __sleep()
+    {
+        return ['connection', 'name'];
+    }
 }

lib/Mongo/MongoGridFS.php

@@ -444,4 +444,12 @@ private function isOKResult($result)
         return (is_array($result) && $result['ok'] == 1.0) ||
                (is_bool($result) && $result);
     }
+
+    /**
+     * @return array
+     */
+    public function __sleep()
+    {
+        return ['chunks', 'chunksName', 'database', 'defaultChunkSize', 'filesName', 'prefix'] + parent::__sleep();
+    }
 }

tests/Alcaeus/MongoDbAdapter/Mongo/MongoClientTest.php

@@ -9,6 +9,11 @@
  */
 class MongoClientTest extends TestCase
 {
+    public function testSerialize()
+    {
+        $this->assertInternalType('string', serialize($this->getClient()));
+    }
+
     public function testGetDb()
     {
         $client = $this->getClient();

tests/Alcaeus/MongoDbAdapter/Mongo/MongoCollectionTest.php

@@ -10,6 +10,11 @@
  */
 class MongoCollectionTest extends TestCase
 {
+    public function testSerialize()
+    {
+        $this->assertInternalType('string', serialize($this->getCollection()));
+    }
+
     public function testGetNestedCollections()
     {
         $collection = $this->getCollection()->foo->bar;

tests/Alcaeus/MongoDbAdapter/Mongo/MongoCommandCursorTest.php

@@ -10,6 +10,13 @@
  */
 class MongoCommandCursorTest extends TestCase
 {
+    public function testSerialize()
+    {
+        $this->prepareData();
+        $cursor = $this->getCollection()->aggregateCursor([['$match' => ['foo' => 'bar']]]);
+        $this->assertInternalType('string', serialize($cursor));
+    }
+
     public function testInfo()
     {
         $this->prepareData();

tests/Alcaeus/MongoDbAdapter/Mongo/MongoCursorTest.php

@@ -12,6 +12,13 @@
  */
 class MongoCursorTest extends TestCase
 {
+    public function testSerialize()
+    {
+        $this->prepareData();
+        $cursor = $this->getCollection()->find(['foo' => 'bar']);
+        $this->assertInternalType('string', serialize($cursor));
+    }
+
     public function testCursorConvertsTypes()
     {
         $this->prepareData();

tests/Alcaeus/MongoDbAdapter/Mongo/MongoDBTest.php

@@ -10,6 +10,11 @@
  */
 class MongoDBTest extends TestCase
 {
+    public function testSerialize()
+    {
+        $this->assertInternalType('string', serialize($this->getDatabase()));
+    }
+
     public function testEmptyDatabaseName()
     {
         $this->setExpectedException('Exception', 'Database name cannot be empty');

tests/Alcaeus/MongoDbAdapter/Mongo/MongoDeleteBatchTest.php

@@ -6,6 +6,12 @@
 
 class MongoDeleteBatchTest extends TestCase
 {
+    public function testSerialize()
+    {
+        $batch = new \MongoDeleteBatch($this->getCollection());
+        $this->assertInternalType('string', serialize($batch));
+    }
+
     public function testDeleteOne()
     {
         $collection = $this->getCollection();

tests/Alcaeus/MongoDbAdapter/Mongo/MongoGridFSCursorTest.php

@@ -6,6 +6,16 @@
 
 class MongoGridFSCursorTest extends TestCase
 {
+    public function testSerialize()
+    {
+        $gridfs = $this->getGridFS();
+        $gridfs->storeBytes('foo', ['filename' => 'foo.txt']);
+        $gridfs->storeBytes('bar', ['filename' => 'bar.txt']);
+        $cursor = $gridfs->find(['filename' => 'foo.txt']);
+
+        $this->assertInternalType('string', serialize($cursor));
+    }
+
     public function testCursorItems()
     {
         $gridfs = $this->getGridFS();

tests/Alcaeus/MongoDbAdapter/Mongo/MongoGridFSFileTest.php

@@ -6,6 +6,15 @@
 
 class MongoGridFSFileTest extends TestCase
 {
+    public function testSerialize()
+    {
+        $this->prepareFile('abcd', ['filename' => 'foo']);
+        $file = $this->getGridFS()->findOne(['filename' => 'foo']);
+        $this->assertInstanceOf(\MongoGridFSFile::class, $file);
+
+        $this->assertInternalType('string', serialize($file));
+    }
+
     public function testFileProperty()
     {
         $file = $this->getFile();

tests/Alcaeus/MongoDbAdapter/Mongo/MongoGridFSTest.php

@@ -6,6 +6,11 @@
 
 class MongoGridFSTest extends TestCase
 {
+    public function testSerialize()
+    {
+        $this->assertInternalType('string', serialize($this->getGridFS()));
+    }
+
     public function testChunkProperty()
     {
         $collection = $this->getGridFS();

tests/Alcaeus/MongoDbAdapter/Mongo/MongoInsertBatchTest.php

@@ -6,6 +6,12 @@
 
 class MongoInsertBatchTest extends TestCase
 {
+    public function testSerialize()
+    {
+        $batch = new \MongoInsertBatch($this->getCollection());
+        $this->assertInternalType('string', serialize($batch));
+    }
+
     public function testInsertBatch()
     {
         $batch = new \MongoInsertBatch($this->getCollection());

tests/Alcaeus/MongoDbAdapter/Mongo/MongoUpdateBatchTest.php

@@ -6,7 +6,11 @@
 
 class MongoUpdateBatchTest extends TestCase
 {
-
+    public function testSerialize()
+    {
+        $batch = new \MongoUpdateBatch($this->getCollection());
+        $this->assertInternalType('string', serialize($batch));
+    }
 
     public function testUpdateOne()
     {