<?php
 namespace MongoDB\Tests\Operation;
 use InvalidArgumentException;
 use MongoDB\Driver\Exception\RuntimeException;
 use MongoDB\Model\IndexInfo;
 use MongoDB\Operation\CreateIndexes;
 use MongoDB\Operation\ListIndexes;
 use MongoDB\Tests\CommandObserver;
 use function call_user_func;
 use function is_callable;
 use function sprintf;
 use function version_compare;
 class CreateIndexesFunctionalTest extends FunctionalTestCase {
 public function testCreateSparseUniqueIndex() {
 $indexes = [['key' => ['x' => 1], 'sparse' => true, 'unique' => true]];
 $operation = new CreateIndexes($this->getDatabaseName(), $this->getCollectionName(), $indexes);
 $createdIndexNames = $operation->execute($this->getPrimaryServer());
 $this->assertSame('x_1', $createdIndexNames[0]);
 $this->assertIndexExists('x_1', function (IndexInfo $info) {
 $this->assertTrue($info->isSparse());
 $this->assertTrue($info->isUnique());
 $this->assertFalse($info->isTtl());
 }
);
 }
 public function testCreateCompoundIndex() {
 $indexes = [['key' => ['y' => -1, 'z' => 1]]];
 $operation = new CreateIndexes($this->getDatabaseName(), $this->getCollectionName(), $indexes);
 $createdIndexNames = $operation->execute($this->getPrimaryServer());
 $this->assertSame('y_-1_z_1', $createdIndexNames[0]);
 $this->assertIndexExists('y_-1_z_1', function (IndexInfo $info) {
 $this->assertFalse($info->isSparse());
 $this->assertFalse($info->isUnique());
 $this->assertFalse($info->isTtl());
 }
);
 }
 public function testCreateGeospatialIndex() {
 $indexes = [['key' => ['g' => '2dsphere', 'z' => 1]]];
 $operation = new CreateIndexes($this->getDatabaseName(), $this->getCollectionName(), $indexes);
 $createdIndexNames = $operation->execute($this->getPrimaryServer());
 $this->assertSame('g_2dsphere_z_1', $createdIndexNames[0]);
 $this->assertIndexExists('g_2dsphere_z_1', function (IndexInfo $info) {
 $this->assertFalse($info->isSparse());
 $this->assertFalse($info->isUnique());
 $this->assertFalse($info->isTtl());
 }
);
 }
 public function testCreateTTLIndex() {
 $indexes = [['key' => ['t' => 1], 'expireAfterSeconds' => 0, 'name' => 'my_ttl']];
 $operation = new CreateIndexes($this->getDatabaseName(), $this->getCollectionName(), $indexes);
 $createdIndexNames = $operation->execute($this->getPrimaryServer());
 $this->assertSame('my_ttl', $createdIndexNames[0]);
 $this->assertIndexExists('my_ttl', function (IndexInfo $info) {
 $this->assertFalse($info->isSparse());
 $this->assertFalse($info->isUnique());
 $this->assertTrue($info->isTtl());
 }
);
 }
 public function testCreateIndexes() {
 $expectedNames = ['x_1', 'y_-1_z_1', 'g_2dsphere_z_1', 'my_ttl'];
 $indexes = [ ['key' => ['x' => 1], 'sparse' => true, 'unique' => true], ['key' => ['y' => -1, 'z' => 1]], ['key' => ['g' => '2dsphere', 'z' => 1]], ['key' => ['t' => 1], 'expireAfterSeconds' => 0, 'name' => 'my_ttl'], ];
 $operation = new CreateIndexes($this->getDatabaseName(), $this->getCollectionName(), $indexes);
 $createdIndexNames = $operation->execute($this->getPrimaryServer());
 $this->assertSame($expectedNames, $createdIndexNames);
 $this->assertIndexExists('x_1', function (IndexInfo $info) {
 $this->assertTrue($info->isSparse());
 $this->assertTrue($info->isUnique());
 $this->assertFalse($info->isTtl());
 }
);
 $this->assertIndexExists('y_-1_z_1', function (IndexInfo $info) {
 $this->assertFalse($info->isSparse());
 $this->assertFalse($info->isUnique());
 $this->assertFalse($info->isTtl());
 }
);
 $this->assertIndexExists('g_2dsphere_z_1', function (IndexInfo $info) {
 $this->assertFalse($info->isSparse());
 $this->assertFalse($info->isUnique());
 $this->assertFalse($info->isTtl());
 }
);
 $this->assertIndexExists('my_ttl', function (IndexInfo $info) {
 $this->assertFalse($info->isSparse());
 $this->assertFalse($info->isUnique());
 $this->assertTrue($info->isTtl());
 }
);
 }
 public function testCreateConflictingIndexesWithCommand() {
 $indexes = [ ['key' => ['x' => 1], 'sparse' => true, 'unique' => false], ['key' => ['x' => 1], 'sparse' => false, 'unique' => true], ];
 $operation = new CreateIndexes($this->getDatabaseName(), $this->getCollectionName(), $indexes);
 $this->expectException(RuntimeException::class);
 $operation->execute($this->getPrimaryServer());
 }
 public function testDefaultWriteConcernIsOmitted() {
 (new CommandObserver())->observe( function () {
 $operation = new CreateIndexes( $this->getDatabaseName(), $this->getCollectionName(), [['key' => ['x' => 1]]], ['writeConcern' => $this->createDefaultWriteConcern()] );
 $operation->execute($this->getPrimaryServer());
 }
, function (array $event) {
 $this->assertObjectNotHasAttribute('writeConcern', $event['started']->getCommand());
 }
 );
 }
 public function testSessionOption() {
 if (version_compare($this->getServerVersion(), '3.6.0', '<')) {
 $this->markTestSkipped('Sessions are not supported');
 }
 (new CommandObserver())->observe( function () {
 $operation = new CreateIndexes( $this->getDatabaseName(), $this->getCollectionName(), [['key' => ['x' => 1]]], ['session' => $this->createSession()] );
 $operation->execute($this->getPrimaryServer());
 }
, function (array $event) {
 $this->assertObjectHasAttribute('lsid', $event['started']->getCommand());
 }
 );
 }
 private function assertIndexExists($indexName, $callback = null) {
 if ($callback !== null && ! is_callable($callback)) {
 throw new InvalidArgumentException('$callback is not a callable');
 }
 $operation = new ListIndexes($this->getDatabaseName(), $this->getCollectionName());
 $indexes = $operation->execute($this->getPrimaryServer());
 $foundIndex = null;
 foreach ($indexes as $index) {
 if ($index->getName() === $indexName) {
 $foundIndex = $index;
 break;
 }
 }
 $this->assertNotNull($foundIndex, sprintf('Index %s does not exist', $indexName));
 if ($callback !== null) {
 call_user_func($callback, $foundIndex);
 }
 }
 }
 