23s2s

✏️ Editing: causal-consistency-003.phpt

--TEST--
Causal consistency: first read or write in session updates operationTime
--DESCRIPTION--
Causal consistency spec prose test #3
https://github.com/mongodb/specifications/blob/master/source/causal-consistency/causal-consistency.rst#test-plan
--SKIPIF--
<?php require __DIR__ . "/../utils/basic-skipif.inc"; ?>
<?php skip_if_not_libmongoc_crypto(); ?>
<?php skip_if_not_replica_set_or_sharded_cluster_with_replica_set(); ?>
<?php skip_if_not_clean(); ?>
--FILE--
<?php
require_once __DIR__ . "/../utils/basic.inc";

class Test implements MongoDB\Driver\Monitoring\CommandSubscriber
{
    private $lastSeenOperationTime;

public function executeBulkWrite()
    {
        $this->lastSeenOperationTime = null;

MongoDB\Driver\Monitoring\addSubscriber($this);

$manager = create_test_manager();
        $session = $manager->startSession();

$bulk = new MongoDB\Driver\BulkWrite;
        $bulk->insert(['x' => 1]);
        $manager->executeBulkWrite(NS, $bulk, ['session' => $session]);

printf("Session reports last seen operationTime: %s\n", ($session->getOperationTime() == $this->lastSeenOperationTime) ? 'yes' : 'no');

MongoDB\Driver\Monitoring\removeSubscriber($this);
    }

public function executeCommand()
    {
        $this->lastSeenOperationTime = null;

MongoDB\Driver\Monitoring\addSubscriber($this);

$manager = create_test_manager();
        $session = $manager->startSession();

$command = new MongoDB\Driver\Command(['ping' => 1]);
        $manager->executeCommand(DATABASE_NAME, $command, ['session' => $session]);

printf("Session reports last seen operationTime: %s\n", ($session->getOperationTime() == $this->lastSeenOperationTime) ? 'yes' : 'no');

MongoDB\Driver\Monitoring\removeSubscriber($this);
    }

public function executeQuery()
    {
        $this->lastSeenOperationTime = null;

MongoDB\Driver\Monitoring\addSubscriber($this);

$manager = create_test_manager();
        $session = $manager->startSession();

$query = new MongoDB\Driver\Query([]);
        $manager->executeQuery(NS, $query, ['session' => $session]);

printf("Session reports last seen operationTime: %s\n", ($session->getOperationTime() == $this->lastSeenOperationTime) ? 'yes' : 'no');

MongoDB\Driver\Monitoring\removeSubscriber($this);
    }

public function commandStarted(MongoDB\Driver\Monitoring\CommandStartedEvent $event): void
    {
    }

public function commandSucceeded(MongoDB\Driver\Monitoring\CommandSucceededEvent $event): void
    {
        $reply = $event->getReply();
        $hasOperationTime = isset($reply->{'operationTime'});

printf("%s command reply includes operationTime: %s\n", $event->getCommandName(), $hasOperationTime ? 'yes' : 'no');

if ($hasOperationTime) {
            $this->lastSeenOperationTime = $reply->operationTime;
        }
    }

public function commandFailed(MongoDB\Driver\Monitoring\CommandFailedEvent $event): void
    {
    }
}

echo "Testing executeBulkWrite()\n";
(new Test)->executeBulkWrite();

echo "\nTesting executeCommand()\n";
(new Test)->executeCommand();

echo "\nTesting executeQuery()\n";
(new Test)->executeQuery();

?>
===DONE===
<?php exit(0); ?>
--EXPECT--
Testing executeBulkWrite()
insert command reply includes operationTime: yes
Session reports last seen operationTime: yes

Testing executeCommand()
ping command reply includes operationTime: yes
Session reports last seen operationTime: yes

Testing executeQuery()
find command reply includes operationTime: yes
Session reports last seen operationTime: yes
===DONE===

Sid Gifari From Gifari Industries - BD Cyber Security Team