Skip to content

Commit 63046a6

Browse files
committed
Replace string values with ReadPreference constants
1 parent fe605d7 commit 63046a6

File tree

7 files changed

+9
-9
lines changed

7 files changed

+9
-9
lines changed

tests/FunctionalTestCase.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -328,7 +328,7 @@ protected function getServerStorageEngine(?ReadPreference $readPreference = null
328328
$cursor = $this->manager->executeCommand(
329329
$this->getDatabaseName(),
330330
new Command(['serverStatus' => 1]),
331-
$readPreference ?: new ReadPreference('primary')
331+
$readPreference ?: new ReadPreference(ReadPreference::PRIMARY)
332332
);
333333

334334
$result = current($cursor->toArray());

tests/Operation/AggregateFunctionalTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -315,7 +315,7 @@ public function testReadPreferenceWithinTransaction(): void
315315

316316
$pipeline = [['$match' => ['_id' => ['$lt' => 3]]]];
317317
$options = [
318-
'readPreference' => new ReadPreference('primary'),
318+
'readPreference' => new ReadPreference(ReadPreference::PRIMARY),
319319
'session' => $session,
320320
];
321321

tests/Operation/FindFunctionalTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -288,7 +288,7 @@ public function testReadPreferenceWithinTransaction(): void
288288

289289
$filter = ['_id' => ['$lt' => 3]];
290290
$options = [
291-
'readPreference' => new ReadPreference('primary'),
291+
'readPreference' => new ReadPreference(ReadPreference::PRIMARY),
292292
'session' => $session,
293293
];
294294

tests/Operation/WatchFunctionalTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1322,7 +1322,7 @@ public function testOriginalReadPreferenceIsPreservedOnResume(): void
13221322
$this->markTestSkipped('Test does not apply to sharded clusters');
13231323
}
13241324

1325-
$readPreference = new ReadPreference('secondary');
1325+
$readPreference = new ReadPreference(ReadPreference::SECONDARY);
13261326
$options = ['readPreference' => $readPreference] + $this->defaultOptions;
13271327
$operation = new Watch($this->manager, $this->getDatabaseName(), $this->getCollectionName(), [], $options);
13281328

tests/SpecTests/Context.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -163,7 +163,7 @@ public static function fromCrud(stdClass $test, $databaseName, $collectionName)
163163

164164
$o->outcomeReadOptions = [
165165
'readConcern' => new ReadConcern('local'),
166-
'readPreference' => new ReadPreference('primary'),
166+
'readPreference' => new ReadPreference(ReadPreference::PRIMARY),
167167
];
168168

169169
$o->client = self::createTestClient(null, $clientOptions);
@@ -224,7 +224,7 @@ public static function fromTransactions(stdClass $test, $databaseName, $collecti
224224

225225
$o->outcomeReadOptions = [
226226
'readConcern' => new ReadConcern('local'),
227-
'readPreference' => new ReadPreference('primary'),
227+
'readPreference' => new ReadPreference(ReadPreference::PRIMARY),
228228
];
229229

230230
$clientOptions = isset($test->clientOptions) ? (array) $test->clientOptions : [];

tests/SpecTests/PrimaryStepDownSpecTest.php

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -267,7 +267,7 @@ private function dropAndRecreateCollection(): void
267267

268268
private function getTotalConnectionsCreated(?Server $server = null)
269269
{
270-
$server = $server ?: $this->client->getManager()->selectServer(new ReadPreference('primary'));
270+
$server = $server ?: $this->client->getManager()->selectServer(new ReadPreference(ReadPreference::PRIMARY));
271271

272272
$cursor = $server->executeCommand(
273273
$this->getDatabaseName(),
@@ -292,7 +292,7 @@ private function waitForPrimaryReelection(): void
292292

293293
return;
294294
} catch (DriverException $e) {
295-
$this->client->getManager()->selectServer(new ReadPreference('primary'));
295+
$this->client->getManager()->selectServer(new ReadPreference(ReadPreference::PRIMARY));
296296

297297
return;
298298
}

tests/SpecTests/TransactionsSpecTest.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -324,7 +324,7 @@ private static function killAllSessions(): void
324324
}
325325

326326
$manager = static::createTestManager();
327-
$primary = $manager->selectServer(new ReadPreference('primary'));
327+
$primary = $manager->selectServer(new ReadPreference(ReadPreference::PRIMARY));
328328

329329
$servers = $primary->getType() === Server::TYPE_MONGOS
330330
? $manager->getServers()

0 commit comments

Comments
 (0)