Skip to content

Commit 6f6d9de

Browse files
authored
GODRIVER-2393 Sync unified tests for wallTime field in the change stream event output (#963)
1 parent 1380613 commit 6f6d9de

File tree

2 files changed

+63
-0
lines changed

2 files changed

+63
-0
lines changed

data/change-streams/change-streams.json

Lines changed: 42 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -1749,6 +1749,48 @@
17491749
]
17501750
}
17511751
]
1752+
},
1753+
{
1754+
"description": "Test wallTime field is set in a change event",
1755+
"runOnRequirements": [
1756+
{
1757+
"minServerVersion": "6.0.0"
1758+
}
1759+
],
1760+
"operations": [
1761+
{
1762+
"name": "createChangeStream",
1763+
"object": "collection0",
1764+
"arguments": {
1765+
"pipeline": []
1766+
},
1767+
"saveResultAsEntity": "changeStream0"
1768+
},
1769+
{
1770+
"name": "insertOne",
1771+
"object": "collection0",
1772+
"arguments": {
1773+
"document": {
1774+
"_id": 1,
1775+
"a": 1
1776+
}
1777+
}
1778+
},
1779+
{
1780+
"name": "iterateUntilDocumentOrError",
1781+
"object": "changeStream0",
1782+
"expectResult": {
1783+
"operationType": "insert",
1784+
"ns": {
1785+
"db": "database0",
1786+
"coll": "collection0"
1787+
},
1788+
"wallTime": {
1789+
"$$exists": true
1790+
}
1791+
}
1792+
}
1793+
]
17521794
}
17531795
]
17541796
}

data/change-streams/change-streams.yml

Lines changed: 21 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -905,3 +905,24 @@ tests:
905905
pipeline: [ { $changeStream: {} } ]
906906
commandName: aggregate
907907
databaseName: *database0
908+
909+
- description: "Test wallTime field is set in a change event"
910+
runOnRequirements:
911+
- minServerVersion: "6.0.0"
912+
operations:
913+
- name: createChangeStream
914+
object: *collection0
915+
arguments: { pipeline: [] }
916+
saveResultAsEntity: &changeStream0 changeStream0
917+
- name: insertOne
918+
object: *collection0
919+
arguments:
920+
document: { "_id": 1, "a": 1 }
921+
- name: iterateUntilDocumentOrError
922+
object: *changeStream0
923+
expectResult:
924+
operationType: "insert"
925+
ns:
926+
db: *database0
927+
coll: *collection0
928+
wallTime: { $$exists: true }

0 commit comments

Comments
 (0)