Wala shell

Advanced PHP File Manager

Server IP: 127.0.0.1 | PHP Version: 8.3.30 | Domains Hosted: 54

Name	Size	Last Modified	Actions
📁 ..	-	2025-05-25 12:27
📄 runCommand.json { "description": "runCommand", "schemaVersion": "1.3", "createEntities": [ { "client": { "id": "client", "useMultipleMongoses": false, "observeEvents": [ "commandStartedEvent" ] } }, { "database": { "id": "db", "client": "client", "databaseName": "db" } }, { "collection": { "id": "collection", "database": "db", "collectionName": "collection" } }, { "database": { "id": "dbWithRC", "client": "client", "databaseName": "dbWithRC", "databaseOptions": { "readConcern": { "level": "local" } } } }, { "database": { "id": "dbWithWC", "client": "client", "databaseName": "dbWithWC", "databaseOptions": { "writeConcern": { "w": 0 } } } }, { "session": { "id": "session", "client": "client" } }, { "client": { "id": "clientWithStableApi", "observeEvents": [ "commandStartedEvent" ], "serverApi": { "version": "1", "strict": true } } }, { "database": { "id": "dbWithStableApi", "client": "clientWithStableApi", "databaseName": "dbWithStableApi" } } ], "initialData": [ { "collectionName": "collection", "databaseName": "db", "documents": [] } ], "tests": [ { "description": "always attaches $db and implicit lsid to given command and omits default readPreference", "operations": [ { "name": "runCommand", "object": "db", "arguments": { "commandName": "ping", "command": { "ping": 1 } }, "expectResult": { "ok": 1 } } ], "expectEvents": [ { "client": "client", "events": [ { "commandStartedEvent": { "command": { "ping": 1, "$db": "db", "lsid": { "$$exists": true }, "$readPreference": { "$$exists": false } }, "commandName": "ping" } } ] } ] }, { "description": "always gossips the $clusterTime on the sent command", "runOnRequirements": [ { "topologies": [ "replicaset", "sharded" ] } ], "operations": [ { "name": "runCommand", "object": "db", "arguments": { "commandName": "ping", "command": { "ping": 1 } }, "expectResult": { "ok": 1 } }, { "name": "runCommand", "object": "db", "arguments": { "commandName": "ping", "command": { "ping": 1 } }, "expectResult": { "ok": 1 } } ], "expectEvents": [ { "client": "client", "events": [ { "commandStartedEvent": { "commandName": "ping" } }, { "commandStartedEvent": { "command": { "ping": 1, "$clusterTime": { "$$exists": true } }, "commandName": "ping" } } ] } ] }, { "description": "attaches the provided session lsid to given command", "operations": [ { "name": "runCommand", "object": "db", "arguments": { "commandName": "ping", "command": { "ping": 1 }, "session": "session" }, "expectResult": { "ok": 1 } } ], "expectEvents": [ { "client": "client", "events": [ { "commandStartedEvent": { "command": { "ping": 1, "lsid": { "$$sessionLsid": "session" }, "$db": "db" }, "commandName": "ping" } } ] } ] }, { "description": "attaches the provided $readPreference to given command", "runOnRequirements": [ { "topologies": [ "replicaset", "sharded-replicaset", "load-balanced", "sharded" ] } ], "operations": [ { "name": "runCommand", "object": "db", "arguments": { "commandName": "ping", "command": { "ping": 1 }, "readPreference": { "mode": "nearest" } }, "expectResult": { "ok": 1 } } ], "expectEvents": [ { "client": "client", "events": [ { "commandStartedEvent": { "command": { "ping": 1, "$readPreference": { "mode": "nearest" }, "$db": "db" }, "commandName": "ping" } } ] } ] }, { "description": "does not attach $readPreference to given command on standalone", "runOnRequirements": [ { "topologies": [ "single" ] } ], "operations": [ { "name": "runCommand", "object": "db", "arguments": { "commandName": "ping", "command": { "ping": 1 }, "readPreference": { "mode": "nearest" } }, "expectResult": { "ok": 1 } } ], "expectEvents": [ { "client": "client", "events": [ { "commandStartedEvent": { "command": { "ping": 1, "$readPreference": { "$$exists": false }, "$db": "db" }, "commandName": "ping" } } ] } ] }, { "description": "does not attach primary $readPreference to given command", "operations": [ { "name": "runCommand", "object": "db", "arguments": { "commandName": "ping", "command": { "ping": 1 }, "readPreference": { "mode": "primary" } }, "expectResult": { "ok": 1 } } ], "expectEvents": [ { "client": "client", "events": [ { "commandStartedEvent": { "command": { "ping": 1, "$readPreference": { "$$exists": false }, "$db": "db" }, "commandName": "ping" } } ] } ] }, { "description": "does not inherit readConcern specified at the db level", "operations": [ { "name": "runCommand", "object": "dbWithRC", "arguments": { "commandName": "aggregate", "command": { "aggregate": "collection", "pipeline": [], "cursor": {} } } } ], "expectEvents": [ { "client": "client", "events": [ { "commandStartedEvent": { "command": { "aggregate": "collection", "readConcern": { "$$exists": false }, "$db": "dbWithRC" }, "commandName": "aggregate" } } ] } ] }, { "description": "does not inherit writeConcern specified at the db level", "operations": [ { "name": "runCommand", "object": "dbWithWC", "arguments": { "commandName": "insert", "command": { "insert": "collection", "documents": [ { "foo": "bar" } ], "ordered": true } }, "expectResult": { "ok": 1 } } ], "expectEvents": [ { "client": "client", "events": [ { "commandStartedEvent": { "command": { "insert": "collection", "writeConcern": { "$$exists": false }, "$db": "dbWithWC" }, "commandName": "insert" } } ] } ] }, { "description": "does not retry retryable errors on given command", "runOnRequirements": [ { "minServerVersion": "4.2" } ], "operations": [ { "name": "failPoint", "object": "testRunner", "arguments": { "client": "client", "failPoint": { "configureFailPoint": "failCommand", "mode": { "times": 1 }, "data": { "failCommands": [ "ping" ], "closeConnection": true } } } }, { "name": "runCommand", "object": "db", "arguments": { "commandName": "ping", "command": { "ping": 1 } }, "expectError": { "isClientError": true } } ] }, { "description": "attaches transaction fields to given command", "runOnRequirements": [ { "minServerVersion": "4.0", "topologies": [ "replicaset" ] }, { "minServerVersion": "4.2", "topologies": [ "sharded-replicaset", "load-balanced" ] } ], "operations": [ { "name": "withTransaction", "object": "session", "arguments": { "callback": [ { "name": "runCommand", "object": "db", "arguments": { "session": "session", "commandName": "insert", "command": { "insert": "collection", "documents": [ { "foo": "transaction" } ], "ordered": true } }, "expectResult": { "$$unsetOrMatches": { "insertedId": { "$$unsetOrMatches": 1 } } } } ] } } ], "expectEvents": [ { "client": "client", "events": [ { "commandStartedEvent": { "command": { "insert": "collection", "documents": [ { "foo": "transaction" } ], "ordered": true, "lsid": { "$$sessionLsid": "session" }, "txnNumber": 1, "startTransaction": true, "autocommit": false, "readConcern": { "$$exists": false }, "writeConcern": { "$$exists": false } }, "commandName": "insert", "databaseName": "db" } }, { "commandStartedEvent": { "command": { "commitTransaction": 1, "lsid": { "$$sessionLsid": "session" }, "txnNumber": 1, "autocommit": false, "writeConcern": { "$$exists": false }, "readConcern": { "$$exists": false } }, "commandName": "commitTransaction", "databaseName": "admin" } } ] } ] }, { "description": "attaches apiVersion fields to given command when stableApi is configured on the client", "runOnRequirements": [ { "minServerVersion": "5.0" } ], "operations": [ { "name": "runCommand", "object": "dbWithStableApi", "arguments": { "commandName": "ping", "command": { "ping": 1 } }, "expectResult": { "ok": 1 } } ], "expectEvents": [ { "client": "clientWithStableApi", "events": [ { "commandStartedEvent": { "command": { "ping": 1, "$db": "dbWithStableApi", "apiVersion": "1", "apiStrict": true, "apiDeprecationErrors": { "$$unsetOrMatches": false } }, "commandName": "ping" } } ] } ] } ] }	14.37 KB	2025-05-25 12:27
📄 runCommand.yml description: runCommand schemaVersion: "1.3" createEntities: - client: id: &client client useMultipleMongoses: false observeEvents: [commandStartedEvent] - database: id: &db db client: client databaseName: db - collection: id: &collection collection database: db collectionName: collection - database: id: &dbWithRC dbWithRC client: client databaseName: dbWithRC databaseOptions: readConcern: { level: 'local' } - database: id: &dbWithWC dbWithWC client: client databaseName: dbWithWC databaseOptions: writeConcern: { w: 0 } - session: id: &session session client: client # Stable API test - client: id: &clientWithStableApi clientWithStableApi observeEvents: [commandStartedEvent] serverApi: version: "1" strict: true - database: id: &dbWithStableApi dbWithStableApi client: clientWithStableApi databaseName: dbWithStableApi initialData: - collectionName: collection databaseName: db documents: [] tests: - description: always attaches $db and implicit lsid to given command and omits default readPreference operations: - name: runCommand object: db arguments: commandName: ping command: { ping: 1 } expectResult: { ok: 1 } expectEvents: - client: client events: - commandStartedEvent: command: ping: 1 $db: db lsid: { $$exists: true } $readPreference: { $$exists: false } commandName: ping - description: always gossips the $clusterTime on the sent command runOnRequirements: # Only replicasets and sharded clusters have a $clusterTime - topologies: [ replicaset, sharded ] operations: # We have to run one command to obtain a clusterTime to gossip - name: runCommand object: db arguments: commandName: ping command: { ping: 1 } expectResult: { ok: 1 } - name: runCommand object: db arguments: commandName: ping command: { ping: 1 } expectResult: { ok: 1 } expectEvents: - client: client events: - commandStartedEvent: commandName: ping # Only check the shape of the second ping which should have the $clusterTime received from the first operation - commandStartedEvent: command: ping: 1 $clusterTime: { $$exists: true } commandName: ping - description: attaches the provided session lsid to given command operations: - name: runCommand object: db arguments: commandName: ping command: { ping: 1 } session: session expectResult: { ok: 1 } expectEvents: - client: client events: - commandStartedEvent: command: ping: 1 lsid: { $$sessionLsid: session } $db: db commandName: ping - description: attaches the provided $readPreference to given command runOnRequirements: # Exclude single topology, which is most likely a standalone server - topologies: [ replicaset, sharded-replicaset, load-balanced, sharded ] operations: - name: runCommand object: db arguments: commandName: ping command: { ping: 1 } readPreference: &readPreference { mode: 'nearest' } expectResult: { ok: 1 } expectEvents: - client: client events: - commandStartedEvent: command: ping: 1 $readPreference: readPreference $db: db commandName: ping - description: does not attach $readPreference to given command on standalone runOnRequirements: # This test assumes that the single topology contains a standalone server; # however, it is possible for a single topology to contain a direct # connection to another server type. # See: https://github.com/mongodb/specifications/blob/master/source/server-selection/server-selection.rst#topology-type-single - topologies: [ single ] operations: - name: runCommand object: db arguments: commandName: ping command: { ping: 1 } readPreference: { mode: 'nearest' } expectResult: { ok: 1 } expectEvents: - client: client events: - commandStartedEvent: command: ping: 1 $readPreference: { $$exists: false } $db: db commandName: ping - description: does not attach primary $readPreference to given command operations: - name: runCommand object: db arguments: commandName: ping command: { ping: 1 } readPreference: { mode: 'primary' } expectResult: { ok: 1 } expectEvents: - client: client events: - commandStartedEvent: command: ping: 1 $readPreference: { $$exists: false } $db: db commandName: ping - description: does not inherit readConcern specified at the db level operations: - name: runCommand object: dbWithRC # Test with a command that supports a readConcern option. # expectResult is intentionally omitted because some drivers # may automatically convert command responses into cursors. arguments: commandName: aggregate command: { aggregate: collection, pipeline: [], cursor: {} } expectEvents: - client: client events: - commandStartedEvent: command: aggregate: collection readConcern: { $$exists: false } $db: dbWithRC commandName: aggregate - description: does not inherit writeConcern specified at the db level operations: - name: runCommand object: dbWithWC arguments: commandName: insert command: insert: collection documents: [ { foo: 'bar' } ] ordered: true expectResult: { ok: 1 } expectEvents: - client: client events: - commandStartedEvent: command: insert: collection writeConcern: { $$exists: false } $db: dbWithWC commandName: insert - description: does not retry retryable errors on given command runOnRequirements: - minServerVersion: "4.2" operations: - name: failPoint object: testRunner arguments: client: client failPoint: configureFailPoint: failCommand mode: { times: 1 } data: failCommands: [ping] closeConnection: true - name: runCommand object: db arguments: commandName: ping command: { ping: 1 } expectError: isClientError: true - description: attaches transaction fields to given command runOnRequirements: - minServerVersion: "4.0" topologies: [ replicaset ] - minServerVersion: "4.2" topologies: [ sharded-replicaset, load-balanced ] operations: - name: withTransaction object: session arguments: callback: - name: runCommand object: db arguments: session: session commandName: insert command: insert: collection documents: [ { foo: 'transaction' } ] ordered: true expectResult: { $$unsetOrMatches: { insertedId: { $$unsetOrMatches: 1 } } } expectEvents: - client: client events: - commandStartedEvent: command: insert: collection documents: [ { foo: 'transaction' } ] ordered: true lsid: { $$sessionLsid: session } txnNumber: 1 startTransaction: true autocommit: false # omitted fields readConcern: { $$exists: false } writeConcern: { $$exists: false } commandName: insert databaseName: db - commandStartedEvent: command: commitTransaction: 1 lsid: { $$sessionLsid: session } txnNumber: 1 autocommit: false # omitted fields writeConcern: { $$exists: false } readConcern: { $$exists: false } commandName: commitTransaction databaseName: admin - description: attaches apiVersion fields to given command when stableApi is configured on the client runOnRequirements: - minServerVersion: "5.0" operations: - name: runCommand object: dbWithStableApi arguments: commandName: ping command: ping: 1 expectResult: { ok: 1 } expectEvents: - client: clientWithStableApi events: - commandStartedEvent: command: ping: 1 $db: dbWithStableApi apiVersion: "1" apiStrict: true apiDeprecationErrors: { $$unsetOrMatches: false } commandName: ping	9.56 KB	2025-05-25 12:27
📄 runCursorCommand.json { "description": "runCursorCommand", "schemaVersion": "1.9", "createEntities": [ { "client": { "id": "client", "useMultipleMongoses": false, "observeEvents": [ "commandStartedEvent", "connectionReadyEvent", "connectionCheckedOutEvent", "connectionCheckedInEvent" ] } }, { "session": { "id": "session", "client": "client" } }, { "database": { "id": "db", "client": "client", "databaseName": "db" } }, { "collection": { "id": "collection", "database": "db", "collectionName": "collection" } } ], "initialData": [ { "collectionName": "collection", "databaseName": "db", "documents": [ { "_id": 1, "x": 11 }, { "_id": 2, "x": 22 }, { "_id": 3, "x": 33 }, { "_id": 4, "x": 44 }, { "_id": 5, "x": 55 } ] } ], "tests": [ { "description": "successfully executes checkMetadataConsistency cursor creating command", "runOnRequirements": [ { "minServerVersion": "7.0", "topologies": [ "sharded" ] } ], "operations": [ { "name": "runCursorCommand", "object": "db", "arguments": { "commandName": "checkMetadataConsistency", "command": { "checkMetadataConsistency": 1 } } } ], "expectEvents": [ { "client": "client", "eventType": "command", "events": [ { "commandStartedEvent": { "command": { "checkMetadataConsistency": 1, "$db": "db", "lsid": { "$$exists": true } }, "commandName": "checkMetadataConsistency" } } ] } ] }, { "description": "errors if the command response is not a cursor", "operations": [ { "name": "createCommandCursor", "object": "db", "arguments": { "commandName": "ping", "command": { "ping": 1 } }, "expectError": { "isClientError": true } } ] }, { "description": "creates an implicit session that is reused across getMores", "operations": [ { "name": "runCursorCommand", "object": "db", "arguments": { "commandName": "find", "command": { "find": "collection", "batchSize": 2 } }, "expectResult": [ { "_id": 1, "x": 11 }, { "_id": 2, "x": 22 }, { "_id": 3, "x": 33 }, { "_id": 4, "x": 44 }, { "_id": 5, "x": 55 } ] }, { "name": "assertSameLsidOnLastTwoCommands", "object": "testRunner", "arguments": { "client": "client" } } ], "expectEvents": [ { "client": "client", "eventType": "command", "events": [ { "commandStartedEvent": { "command": { "find": "collection", "batchSize": 2, "$db": "db", "lsid": { "$$exists": true } }, "commandName": "find" } }, { "commandStartedEvent": { "command": { "getMore": { "$$type": [ "int", "long" ] }, "collection": "collection", "$db": "db", "lsid": { "$$exists": true } }, "commandName": "getMore" } } ] } ] }, { "description": "accepts an explicit session that is reused across getMores", "operations": [ { "name": "runCursorCommand", "object": "db", "arguments": { "commandName": "find", "session": "session", "command": { "find": "collection", "batchSize": 2 } }, "expectResult": [ { "_id": 1, "x": 11 }, { "_id": 2, "x": 22 }, { "_id": 3, "x": 33 }, { "_id": 4, "x": 44 }, { "_id": 5, "x": 55 } ] }, { "name": "assertSameLsidOnLastTwoCommands", "object": "testRunner", "arguments": { "client": "client" } } ], "expectEvents": [ { "client": "client", "eventType": "command", "events": [ { "commandStartedEvent": { "command": { "find": "collection", "batchSize": 2, "$db": "db", "lsid": { "$$sessionLsid": "session" } }, "commandName": "find" } }, { "commandStartedEvent": { "command": { "getMore": { "$$type": [ "int", "long" ] }, "collection": "collection", "$db": "db", "lsid": { "$$sessionLsid": "session" } }, "commandName": "getMore" } } ] } ] }, { "description": "returns pinned connections to the pool when the cursor is exhausted", "runOnRequirements": [ { "topologies": [ "load-balanced" ] } ], "operations": [ { "name": "createCommandCursor", "object": "db", "arguments": { "commandName": "find", "batchSize": 2, "session": "session", "command": { "find": "collection", "batchSize": 2 } }, "saveResultAsEntity": "cursor" }, { "name": "assertNumberConnectionsCheckedOut", "object": "testRunner", "arguments": { "client": "client", "connections": 1 } }, { "name": "iterateUntilDocumentOrError", "object": "cursor", "expectResult": { "_id": 1, "x": 11 } }, { "name": "iterateUntilDocumentOrError", "object": "cursor", "expectResult": { "_id": 2, "x": 22 } }, { "name": "iterateUntilDocumentOrError", "object": "cursor", "expectResult": { "_id": 3, "x": 33 } }, { "name": "iterateUntilDocumentOrError", "object": "cursor", "expectResult": { "_id": 4, "x": 44 } }, { "name": "iterateUntilDocumentOrError", "object": "cursor", "expectResult": { "_id": 5, "x": 55 } }, { "name": "assertNumberConnectionsCheckedOut", "object": "testRunner", "arguments": { "client": "client", "connections": 0 } } ], "expectEvents": [ { "client": "client", "eventType": "command", "events": [ { "commandStartedEvent": { "command": { "find": "collection", "batchSize": 2, "$db": "db", "lsid": { "$$sessionLsid": "session" } }, "commandName": "find" } }, { "commandStartedEvent": { "command": { "getMore": { "$$type": [ "int", "long" ] }, "collection": "collection", "$db": "db", "lsid": { "$$sessionLsid": "session" } }, "commandName": "getMore" } }, { "commandStartedEvent": { "command": { "getMore": { "$$type": [ "int", "long" ] }, "collection": "collection", "$db": "db", "lsid": { "$$sessionLsid": "session" } }, "commandName": "getMore" } } ] }, { "client": "client", "eventType": "cmap", "events": [ { "connectionReadyEvent": {} }, { "connectionCheckedOutEvent": {} }, { "connectionCheckedInEvent": {} } ] } ] }, { "description": "returns pinned connections to the pool when the cursor is closed", "runOnRequirements": [ { "topologies": [ "load-balanced" ] } ], "operations": [ { "name": "createCommandCursor", "object": "db", "arguments": { "commandName": "find", "command": { "find": "collection", "batchSize": 2 } }, "saveResultAsEntity": "cursor" }, { "name": "assertNumberConnectionsCheckedOut", "object": "testRunner", "arguments": { "client": "client", "connections": 1 } }, { "name": "close", "object": "cursor" }, { "name": "assertNumberConnectionsCheckedOut", "object": "testRunner", "arguments": { "client": "client", "connections": 0 } } ] }, { "description": "supports configuring getMore batchSize", "operations": [ { "name": "runCursorCommand", "object": "db", "arguments": { "commandName": "find", "batchSize": 5, "command": { "find": "collection", "batchSize": 1 } }, "expectResult": [ { "_id": 1, "x": 11 }, { "_id": 2, "x": 22 }, { "_id": 3, "x": 33 }, { "_id": 4, "x": 44 }, { "_id": 5, "x": 55 } ] } ], "expectEvents": [ { "client": "client", "eventType": "command", "events": [ { "commandStartedEvent": { "command": { "find": "collection", "batchSize": 1, "$db": "db", "lsid": { "$$exists": true } }, "commandName": "find" } }, { "commandStartedEvent": { "command": { "getMore": { "$$type": [ "int", "long" ] }, "collection": "collection", "batchSize": 5, "$db": "db", "lsid": { "$$exists": true } }, "commandName": "getMore" } } ] } ] }, { "description": "supports configuring getMore maxTimeMS", "operations": [ { "name": "runCursorCommand", "object": "db", "arguments": { "commandName": "find", "maxTimeMS": 300, "command": { "find": "collection", "maxTimeMS": 200, "batchSize": 1 } }, "ignoreResultAndError": true } ], "expectEvents": [ { "client": "client", "eventType": "command", "ignoreExtraEvents": true, "events": [ { "commandStartedEvent": { "command": { "find": "collection", "maxTimeMS": 200, "batchSize": 1, "$db": "db", "lsid": { "$$exists": true } }, "commandName": "find" } }, { "commandStartedEvent": { "command": { "getMore": { "$$type": [ "int", "long" ] }, "collection": "collection", "$db": "db", "maxTimeMS": 300, "lsid": { "$$exists": true } }, "commandName": "getMore" } } ] } ] }, { "description": "supports configuring getMore comment", "runOnRequirements": [ { "minServerVersion": "4.4" } ], "operations": [ { "name": "runCursorCommand", "object": "db", "arguments": { "commandName": "find", "comment": { "hello": "getMore" }, "command": { "find": "collection", "batchSize": 1, "comment": { "hello": "find" } } }, "expectResult": [ { "_id": 1, "x": 11 }, { "_id": 2, "x": 22 }, { "_id": 3, "x": 33 }, { "_id": 4, "x": 44 }, { "_id": 5, "x": 55 } ] } ], "expectEvents": [ { "client": "client", "eventType": "command", "events": [ { "commandStartedEvent": { "command": { "find": "collection", "batchSize": 1, "comment": { "hello": "find" }, "$db": "db", "lsid": { "$$exists": true } }, "commandName": "find" } }, { "commandStartedEvent": { "command": { "getMore": { "$$type": [ "int", "long" ] }, "collection": "collection", "comment": { "hello": "getMore" }, "$db": "db", "lsid": { "$$exists": true } }, "commandName": "getMore" } } ] } ] }, { "description": "does not close the cursor when receiving an empty batch", "runOnRequirements": [ { "serverless": "forbid" } ], "operations": [ { "name": "dropCollection", "object": "db", "arguments": { "collection": "cappedCollection" } }, { "name": "createCollection", "object": "db", "arguments": { "collection": "cappedCollection", "capped": true, "size": 4096, "max": 3 }, "saveResultAsEntity": "cappedCollection" }, { "name": "insertMany", "object": "cappedCollection", "arguments": { "documents": [ { "_id": 1, "x": 11 }, { "_id": 2, "x": 22 } ] } }, { "name": "createCommandCursor", "object": "db", "arguments": { "cursorType": "tailable", "commandName": "find", "batchSize": 2, "command": { "find": "cappedCollection", "tailable": true } }, "saveResultAsEntity": "cursor" }, { "name": "iterateOnce", "object": "cursor" }, { "name": "iterateOnce", "object": "cursor" }, { "name": "iterateOnce", "object": "cursor" }, { "name": "close", "object": "cursor" } ], "expectEvents": [ { "client": "client", "eventType": "command", "events": [ { "commandStartedEvent": { "command": { "drop": "cappedCollection" }, "commandName": "drop" } }, { "commandStartedEvent": { "command": { "create": "cappedCollection" }, "commandName": "create" } }, { "commandStartedEvent": { "command": { "insert": "cappedCollection" }, "commandName": "insert" } }, { "commandStartedEvent": { "command": { "find": "cappedCollection", "$db": "db", "lsid": { "$$exists": true } }, "commandName": "find" } }, { "commandStartedEvent": { "command": { "getMore": { "$$type": [ "int", "long" ] }, "collection": "cappedCollection", "$db": "db", "lsid": { "$$exists": true } }, "commandName": "getMore" } }, { "commandStartedEvent": { "command": { "killCursors": "cappedCollection", "cursors": { "$$type": "array" } }, "commandName": "killCursors" } } ] } ] } ] }	20.37 KB	2025-05-25 12:27
📄 runCursorCommand.yml description: runCursorCommand schemaVersion: '1.9' createEntities: - client: id: &client client useMultipleMongoses: false observeEvents: [commandStartedEvent, connectionReadyEvent, connectionCheckedOutEvent, connectionCheckedInEvent] - session: id: &session session client: client - database: id: &db db client: client databaseName: db - collection: id: &collection collection database: db collectionName: collection initialData: - collectionName: collection databaseName: db documents: &documents - { _id: 1, x: 11 } - { _id: 2, x: 22 } - { _id: 3, x: 33 } - { _id: 4, x: 44 } - { _id: 5, x: 55 } tests: # This is what this API was invented to do. - description: successfully executes checkMetadataConsistency cursor creating command runOnRequirements: - minServerVersion: '7.0' topologies: [sharded] operations: - name: runCursorCommand object: db arguments: commandName: checkMetadataConsistency command: { checkMetadataConsistency: 1 } expectEvents: - client: client eventType: command events: - commandStartedEvent: command: checkMetadataConsistency: 1 $db: db lsid: { $$exists: true } commandName: checkMetadataConsistency - description: errors if the command response is not a cursor operations: - name: createCommandCursor object: db arguments: commandName: ping command: { ping: 1 } expectError: isClientError: true # Driver Sessions - description: creates an implicit session that is reused across getMores operations: - name: runCursorCommand object: db arguments: commandName: find command: { find: collection, batchSize: 2 } expectResult: documents - name: assertSameLsidOnLastTwoCommands object: testRunner arguments: client: client expectEvents: - client: client eventType: command events: - commandStartedEvent: command: find: collection batchSize: 2 $db: db lsid: { $$exists: true } commandName: find - commandStartedEvent: command: getMore: { $$type: [int, long] } collection: collection $db: db lsid: { $$exists: true } commandName: getMore - description: accepts an explicit session that is reused across getMores operations: - name: runCursorCommand object: db arguments: commandName: find session: session command: { find: collection, batchSize: 2 } expectResult: documents - name: assertSameLsidOnLastTwoCommands object: testRunner arguments: client: client expectEvents: - client: client eventType: command events: - commandStartedEvent: command: find: collection batchSize: 2 $db: db lsid: { $$sessionLsid: session } commandName: find - commandStartedEvent: command: getMore: { $$type: [int, long] } collection: collection $db: db lsid: { $$sessionLsid: session } commandName: getMore # Load Balancers - description: returns pinned connections to the pool when the cursor is exhausted runOnRequirements: - topologies: [ load-balanced ] operations: - name: createCommandCursor object: db arguments: commandName: find batchSize: 2 session: session command: { find: collection, batchSize: 2 } saveResultAsEntity: &cursor cursor - name: assertNumberConnectionsCheckedOut object: testRunner arguments: client: client connections: 1 - name: iterateUntilDocumentOrError object: cursor expectResult: { _id: 1, x: 11 } - name: iterateUntilDocumentOrError object: cursor expectResult: { _id: 2, x: 22 } - name: iterateUntilDocumentOrError object: cursor expectResult: { _id: 3, x: 33 } - name: iterateUntilDocumentOrError object: cursor expectResult: { _id: 4, x: 44 } - name: iterateUntilDocumentOrError object: cursor expectResult: { _id: 5, x: 55 } - name: assertNumberConnectionsCheckedOut object: testRunner arguments: client: client connections: 0 expectEvents: - client: client eventType: command events: - commandStartedEvent: command: find: collection batchSize: 2 $db: db lsid: { $$sessionLsid: session } commandName: find # 2 documents - commandStartedEvent: command: getMore: { $$type: [int, long] } collection: collection $db: db lsid: { $$sessionLsid: session } commandName: getMore # 2 documents - commandStartedEvent: command: getMore: { $$type: [int, long] } collection: collection $db: db lsid: { $$sessionLsid: session } commandName: getMore # 1 document # Total documents: 5 - client: client eventType: cmap events: - connectionReadyEvent: {} - connectionCheckedOutEvent: {} - connectionCheckedInEvent: {} - description: returns pinned connections to the pool when the cursor is closed runOnRequirements: - topologies: [ load-balanced ] operations: - name: createCommandCursor object: db arguments: commandName: find command: { find: collection, batchSize: 2 } saveResultAsEntity: cursor - name: assertNumberConnectionsCheckedOut object: testRunner arguments: client: client connections: 1 - name: close object: cursor - name: assertNumberConnectionsCheckedOut object: testRunner arguments: client: client connections: 0 # Iterating the Cursor / Executing GetMores - description: supports configuring getMore batchSize operations: - name: runCursorCommand object: db arguments: commandName: find batchSize: 5 command: { find: collection, batchSize: 1 } expectResult: documents expectEvents: - client: client eventType: command events: - commandStartedEvent: command: find: collection batchSize: 1 $db: db lsid: { $$exists: true } commandName: find - commandStartedEvent: command: getMore: { $$type: [int, long] } collection: collection batchSize: 5 $db: db lsid: { $$exists: true } commandName: getMore - description: supports configuring getMore maxTimeMS operations: - name: runCursorCommand object: db arguments: commandName: find maxTimeMS: 300 command: { find: collection, maxTimeMS: 200, batchSize: 1 } ignoreResultAndError: true expectEvents: - client: client eventType: command # The getMore should receive an error here because we do not have the right kind of cursor # So drivers should run a killCursors, but neither the error nor the killCursors command is relevant to this test ignoreExtraEvents: true events: - commandStartedEvent: command: find: collection maxTimeMS: 200 batchSize: 1 $db: db lsid: { $$exists: true } commandName: find - commandStartedEvent: command: getMore: { $$type: [int, long] } collection: collection $db: db maxTimeMS: 300 lsid: { $$exists: true } commandName: getMore - description: supports configuring getMore comment runOnRequirements: - minServerVersion: '4.4' operations: - name: runCursorCommand object: db arguments: commandName: find comment: { hello: 'getMore' } command: { find: collection, batchSize: 1, comment: { hello: 'find' } } expectResult: documents expectEvents: - client: client eventType: command events: - commandStartedEvent: command: find: collection batchSize: 1 comment: { hello: 'find' } $db: db lsid: { $$exists: true } commandName: find - commandStartedEvent: command: getMore: { $$type: [int, long] } collection: collection comment: { hello: 'getMore' } $db: db lsid: { $$exists: true } commandName: getMore # Tailable cursor - description: does not close the cursor when receiving an empty batch runOnRequirements: - serverless: forbid operations: - name: dropCollection object: db arguments: collection: &cappedCollection cappedCollection - name: createCollection object: db arguments: collection: cappedCollection capped: true size: 4096 max: 3 saveResultAsEntity: cappedCollection - name: insertMany object: cappedCollection arguments: documents: - { _id: 1, x: 11 } - { _id: 2, x: 22 } - name: createCommandCursor object: db arguments: cursorType: tailable commandName: find batchSize: 2 command: { find: cappedCollection, tailable: true } saveResultAsEntity: &cursor cursor - name: iterateOnce object: cursor - name: iterateOnce object: cursor - name: iterateOnce object: cursor - name: close object: cursor expectEvents: - client: client eventType: command events: - commandStartedEvent: command: drop: cappedCollection commandName: drop - commandStartedEvent: command: create: cappedCollection commandName: create - commandStartedEvent: command: insert: cappedCollection commandName: insert - commandStartedEvent: command: find: cappedCollection $db: db lsid: { $$exists: true } commandName: find - commandStartedEvent: command: getMore: { $$type: [int, long] } collection: cappedCollection $db: db lsid: { $$exists: true } commandName: getMore - commandStartedEvent: command: killCursors: *cappedCollection cursors: { $$type: array } commandName: killCursors	11.71 KB	2025-05-25 12:27

Terminal