23s2s

✏️ Editing: causal-consistency-006.phpt

--TEST--
Causal consistency: second read's afterClusterTime uses last reply's operationTime (even on error)
--DESCRIPTION--
Causal consistency spec prose test #4 and #5
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 executeReadAfterReadError()
    {
        $this->lastSeenOperationTime = null;

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

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

$query = new MongoDB\Driver\Query(['$unsupportedOperator' => 1]);

throws(function() use ($manager, $query, $session) {
            $manager->executeQuery(NS, $query, ['session' => $session]);
        }, 'MongoDB\Driver\Exception\RuntimeException');

/* We cannot access the server reply if an exception is thrown for a
         * failed command (see: PHPC-1076). For the time being, just assert that
         * the operationTime is not null. */
        printf("Session has non-null operationTime: %s\n", ($session->getOperationTime() !== null ? 'yes' : 'no'));

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

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

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

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

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

$bulk = new MongoDB\Driver\BulkWrite;
        $bulk->insert(['_id' => 1]);
        $bulk->insert(['_id' => 1]);

throws(function() use ($manager, $bulk, $session) {
            $manager->executeBulkWrite(NS, $bulk, ['session' => $session]);
        }, 'MongoDB\Driver\Exception\BulkWriteException');

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

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

public function commandStarted(MongoDB\Driver\Monitoring\CommandStartedEvent $event): void
    {
        $command = $event->getCommand();
        $hasAfterClusterTime = isset($command->readConcern->afterClusterTime);
        printf("%s command includes afterClusterTime: %s\n", $event->getCommandName(), ($hasAfterClusterTime ? 'yes' : 'no'));

if ($hasAfterClusterTime && $this->lastSeenOperationTime !== null) {
            printf("%s command uses last seen operationTime: %s\n", $event->getCommandName(), ($command->readConcern->afterClusterTime == $this->lastSeenOperationTime) ? 'yes' : 'no');
        }
    }

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 "\nTesting read after read error\n";
(new Test)->executeReadAfterReadError();

echo "\nTesting read after write error\n";
(new Test)->executeReadAfterWriteError();

?>
===DONE===
<?php exit(0); ?>
--EXPECT--
Testing read after read error
find command includes afterClusterTime: no
OK: Got MongoDB\Driver\Exception\RuntimeException
Session has non-null operationTime: yes
find command includes afterClusterTime: yes
find command reply includes operationTime: yes

Testing read after write error
insert command includes afterClusterTime: no
insert command reply includes operationTime: yes
OK: Got MongoDB\Driver\Exception\BulkWriteException
find command includes afterClusterTime: yes
find command uses last seen operationTime: yes
find command reply includes operationTime: yes
===DONE===

Sid Gifari From Gifari Industries - BD Cyber Security Team