Skip to content

Commit f0d2014

Browse files
author
Divjot Arora
committed
Add helpers to create database and client change streams.
GODRIVER-437 GODRIVER-469 GODRIVER-591 Change-Id: I52270279e9ea05c1e64e5ec3d9d8a86478cd9986
1 parent c0711bf commit f0d2014

12 files changed

+1750
-348
lines changed
Lines changed: 78 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,78 @@
1+
{
2+
"collection_name": "test",
3+
"database_name": "change-stream-tests",
4+
"collection2_name": "test2",
5+
"database2_name": "change-stream-tests-2",
6+
"tests": [
7+
{
8+
"description": "The watch helper must not throw a custom exception when executed against a single server topology, but instead depend on a server error",
9+
"minServerVersion": "3.6.0",
10+
"target": "collection",
11+
"topology": [
12+
"single"
13+
],
14+
"changeStreamPipeline": [],
15+
"changeStreamOptions": {},
16+
"operations": [],
17+
"expectations": [],
18+
"result": {
19+
"error": {
20+
"code": 40573
21+
}
22+
}
23+
},
24+
{
25+
"description": "Change Stream should error when an invalid aggregation stage is passed in",
26+
"minServerVersion": "3.6.0",
27+
"target": "collection",
28+
"topology": [
29+
"replicaset"
30+
],
31+
"changeStreamPipeline": [
32+
{
33+
"$unsupported": "foo"
34+
}
35+
],
36+
"changeStreamOptions": {},
37+
"operations": [
38+
{
39+
"database": "change-stream-tests",
40+
"collection": "test",
41+
"name": "insertOne",
42+
"arguments": {
43+
"document": {
44+
"z": 3
45+
}
46+
}
47+
}
48+
],
49+
"expectations": [
50+
{
51+
"command_started_event": {
52+
"command": {
53+
"aggregate": "test",
54+
"cursor": {},
55+
"pipeline": [
56+
{
57+
"$changeStream": {
58+
"fullDocument": "default"
59+
}
60+
},
61+
{
62+
"$unsupported": "foo"
63+
}
64+
]
65+
},
66+
"command_name": "aggregate",
67+
"database_name": "change-stream-tests"
68+
}
69+
}
70+
],
71+
"result": {
72+
"error": {
73+
"code": 40324
74+
}
75+
}
76+
}
77+
]
78+
}

0 commit comments

Comments
 (0)