Create collection before change stream tests

Author: jmikola

tests/DocumentationExamplesTest.php

@@ -930,6 +930,7 @@ public function testChangeStreamExample_1_4()
 
         $db = new Database($this->manager, $this->getDatabaseName());
         $db->dropCollection('inventory');
+        $db->createCollection('inventory');
 
         // Start Changestream Example 1
         $changeStream = $db->inventory->watch();

tests/Operation/WatchFunctionalTest.php

@@ -29,46 +29,45 @@ public function setUp()
         parent::setUp();
 
         $this->skipIfChangeStreamIsNotSupported();
+        $this->createCollection();
     }
 
     public function testNextResumesAfterCursorNotFound()
     {
-        $this->insertDocument(['_id' => 1, 'x' => 'foo']);
-
         $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], $this->defaultOptions);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
         $changeStream->rewind();
         $this->assertFalse($changeStream->valid());
 
-        $this->insertDocument(['_id' => 2, 'x' => 'bar']);
+        $this->insertDocument(['_id' => 1, 'x' => 'foo']);
 
         $changeStream->next();
         $this->assertTrue($changeStream->valid());
 
         $expectedResult = [
             '_id' => $changeStream->current()->_id,
             'operationType' => 'insert',
-            'fullDocument' => ['_id' => 2, 'x' => 'bar'],
+            'fullDocument' => ['_id' => 1, 'x' => 'foo'],
             'ns' => ['db' => $this->getDatabaseName(), 'coll' => $this->getCollectionName()],
-            'documentKey' => ['_id' => 2],
+            'documentKey' => ['_id' => 1],
         ];
 
         $this->assertMatchesDocument($expectedResult, $changeStream->current());
 
         $this->killChangeStreamCursor($changeStream);
 
-        $this->insertDocument(['_id' => 3, 'x' => 'baz']);
+        $this->insertDocument(['_id' => 2, 'x' => 'bar']);
 
         $changeStream->next();
         $this->assertTrue($changeStream->valid());
 
         $expectedResult = [
             '_id' => $changeStream->current()->_id,
             'operationType' => 'insert',
-            'fullDocument' => ['_id' => 3, 'x' => 'baz'],
+            'fullDocument' => ['_id' => 2, 'x' => 'bar'],
             'ns' => ['db' => $this->getDatabaseName(), 'coll' => $this->getCollectionName()],
-            'documentKey' => ['_id' => 3]
+            'documentKey' => ['_id' => 2]
         ];
 
         $this->assertMatchesDocument($expectedResult, $changeStream->current());
@@ -335,25 +334,23 @@ public function testRewindMultipleTimesWithNoResults()
 
     public function testNoChangeAfterResumeBeforeInsert()
     {
-        $this->insertDocument(['_id' => 1, 'x' => 'foo']);
-
         $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], $this->defaultOptions);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
         $this->assertNoCommandExecuted(function() use ($changeStream) { $changeStream->rewind(); });
         $this->assertFalse($changeStream->valid());
 
-        $this->insertDocument(['_id' => 2, 'x' => 'bar']);
+        $this->insertDocument(['_id' => 1, 'x' => 'foo']);
 
         $changeStream->next();
         $this->assertTrue($changeStream->valid());
 
         $expectedResult = [
             '_id' => $changeStream->current()->_id,
             'operationType' => 'insert',
-            'fullDocument' => ['_id' => 2, 'x' => 'bar'],
+            'fullDocument' => ['_id' => 1, 'x' => 'foo'],
             'ns' => ['db' => $this->getDatabaseName(), 'coll' => $this->getCollectionName()],
-            'documentKey' => ['_id' => 2],
+            'documentKey' => ['_id' => 1],
         ];
 
         $this->assertMatchesDocument($expectedResult, $changeStream->current());
@@ -363,27 +360,24 @@ public function testNoChangeAfterResumeBeforeInsert()
         $changeStream->next();
         $this->assertFalse($changeStream->valid());
 
-        $this->insertDocument(['_id' => 3, 'x' => 'baz']);
+        $this->insertDocument(['_id' => 2, 'x' => 'bar']);
 
         $changeStream->next();
         $this->assertTrue($changeStream->valid());
 
         $expectedResult = [
             '_id' => $changeStream->current()->_id,
             'operationType' => 'insert',
-            'fullDocument' => ['_id' => 3, 'x' => 'baz'],
+            'fullDocument' => ['_id' => 2, 'x' => 'bar'],
             'ns' => ['db' => $this->getDatabaseName(), 'coll' => $this->getCollectionName()],
-            'documentKey' => ['_id' => 3],
+            'documentKey' => ['_id' => 2],
         ];
 
         $this->assertMatchesDocument($expectedResult, $changeStream->current());
     }
 
     public function testResumeMultipleTimesInSuccession()
     {
-        $operation = new CreateCollection($this->getDatabaseName(), $this->getCollectionName());
-        $operation->execute($this->getPrimaryServer());
-
         $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], $this->defaultOptions);
         $changeStream = $operation->execute($this->getPrimaryServer());
 
@@ -966,9 +960,6 @@ function (array $event) use (&$sessionAfterResume, &$commands) {
 
     public function testSessionFreed()
     {
-        // Create collection so we can drop it later
-        $this->createCollection();
-
         $operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], $this->defaultOptions);
         $changeStream = $operation->execute($this->getPrimaryServer());