@@ -1745,11 +1745,23 @@ describe('Change Streams', function () {
1745
1745
} )
1746
1746
. createEntities ( [
1747
1747
{ client : { id : 'client0' } } ,
1748
- { database : { id : 'database0' , client : 'client0' , databaseName : 'changeStreamDocShape' } } ,
1749
- { collection : { id : 'collection0' , database : 'database0' , collectionName : 'collection0' } } ,
1750
1748
1751
1749
// transaction test
1752
1750
{ session : { id : 'session0' , client : 'client0' } } ,
1751
+ {
1752
+ database : {
1753
+ id : 'changeStreamDocShape' ,
1754
+ client : 'client0' ,
1755
+ databaseName : 'changeStreamDocShape'
1756
+ }
1757
+ } ,
1758
+ {
1759
+ collection : {
1760
+ id : 'collection0' ,
1761
+ database : 'changeStreamDocShape' ,
1762
+ collectionName : 'collection0'
1763
+ }
1764
+ } ,
1753
1765
1754
1766
// rename test
1755
1767
{ database : { id : 'admin' , databaseName : 'admin' , client : 'client0' } } ,
@@ -1839,15 +1851,15 @@ describe('Change Streams', function () {
1839
1851
. test (
1840
1852
TestBuilder . it ( 'change stream event inside transaction' )
1841
1853
. operation ( {
1842
- object : 'database0 ' ,
1843
- name : 'createCollection ' ,
1844
- arguments : { collection : 'collection0' } ,
1854
+ object : 'changeStreamDocShape ' ,
1855
+ name : 'runCommand ' ,
1856
+ arguments : { command : { dropDatabase : 1 } } ,
1845
1857
ignoreResultAndError : true
1846
1858
} )
1847
1859
. operation ( {
1848
- object : 'database0 ' ,
1849
- name : 'runCommand ' ,
1850
- arguments : { command : { dropDatabase : 1 } } ,
1860
+ object : 'changeStreamDocShape ' ,
1861
+ name : 'createCollection ' ,
1862
+ arguments : { collection : 'collection0' } ,
1851
1863
ignoreResultAndError : true
1852
1864
} )
1853
1865
. operation ( {
0 commit comments