Commit 93138f0

committed

test(NODE-4763): use times:1 for failpoint to explicitly set failure

1 parent 1d20d16 commit 93138f0Copy full SHA for 93138f0

File tree

1 file changed

+36

-14

lines changed

test/integration/change-streams
- change_stream.test.ts

1 file changed

+36

-14

lines changed

`‎test/integration/change-streams/change_stream.test.ts‎`

Lines changed: 36 additions & 14 deletions

Original file line number	Diff line number	Diff line change
`@@ -1865,20 +1865,6 @@ describe('Change Streams', function () {`
`1865`	`1865`	`collection = client.db(dbName).collection(collectionName);`
`1866`	`1866`
`1867`	`1867`	`changeStream = collection.watch([]);`
`1868`		`-`
`1869`		- // Configure a fail point with skip: 1 to simulate a server failure on the second `getMore`,
`1870`		`- // triggering the resume process.`
`1871`		`- await client.db('admin').command({`
`1872`		`- configureFailPoint: is4_2Server(this.configuration.version)`
`1873`		`- ? 'failCommand'`
`1874`		`- : 'failGetMoreAfterCursorCheckout',`
`1875`		`- mode: { skip: 1 },`
`1876`		`- data: {`
`1877`		`- failCommands: ['getMore'],`
`1878`		`- errorCode: resumableError.code,`
`1879`		`- errmsg: resumableError.message`
`1880`		`- }`
`1881`		`- } as FailCommandFailPoint);`
`1882`	`1868`	`});`
`1883`	`1869`
`1884`	`1870`	`afterEach(async function () {`
`@@ -1905,6 +1891,18 @@ describe('Change Streams', function () {`
`1905`	`1891`	`fullDocument: { a: 1 }`
`1906`	`1892`	`});`
`1907`	`1893`
	`1894`	`+ await client.db('admin').command({`
	`1895`	`+ configureFailPoint: is4_2Server(this.configuration.version)`
	`1896`	`+ ? 'failCommand'`
	`1897`	`+ : 'failGetMoreAfterCursorCheckout',`
	`1898`	`+ mode: { times: 1 },`
	`1899`	`+ data: {`
	`1900`	`+ failCommands: ['getMore'],`
	`1901`	`+ errorCode: resumableError.code,`
	`1902`	`+ errmsg: resumableError.message`
	`1903`	`+ }`
	`1904`	`+ } as FailCommandFailPoint);`
	`1905`	`+`
`1908`	`1906`	`await collection.insertOne({ a: 2 });`
`1909`	`1907`	`const change2 = await changeStream.next();`
`1910`	`1908`	`expect(change2).to.containSubset({`
`@@ -1925,6 +1923,18 @@ describe('Change Streams', function () {`
`1925`	`1923`	`fullDocument: { a: 1 }`
`1926`	`1924`	`});`
`1927`	`1925`
	`1926`	`+ await client.db('admin').command({`
	`1927`	`+ configureFailPoint: is4_2Server(this.configuration.version)`
	`1928`	`+ ? 'failCommand'`
	`1929`	`+ : 'failGetMoreAfterCursorCheckout',`
	`1930`	`+ mode: { times: 1 },`
	`1931`	`+ data: {`
	`1932`	`+ failCommands: ['getMore'],`
	`1933`	`+ errorCode: resumableError.code,`
	`1934`	`+ errmsg: resumableError.message`
	`1935`	`+ }`
	`1936`	`+ } as FailCommandFailPoint);`
	`1937`	`+`
`1928`	`1938`	`await collection.insertOne({ a: 2 });`
`1929`	`1939`	`const change2 = await changeStream.tryNext();`
`1930`	`1940`	`expect(change2).to.containSubset({`
`@@ -1947,6 +1957,18 @@ describe('Change Streams', function () {`
`1947`	`1957`	`fullDocument: { a: 1 }`
`1948`	`1958`	`});`
`1949`	`1959`
	`1960`	`+ await client.db('admin').command({`
	`1961`	`+ configureFailPoint: is4_2Server(this.configuration.version)`
	`1962`	`+ ? 'failCommand'`
	`1963`	`+ : 'failGetMoreAfterCursorCheckout',`
	`1964`	`+ mode: { times: 1 },`
	`1965`	`+ data: {`
	`1966`	`+ failCommands: ['getMore'],`
	`1967`	`+ errorCode: resumableError.code,`
	`1968`	`+ errmsg: resumableError.message`
	`1969`	`+ }`
	`1970`	`+ } as FailCommandFailPoint);`
	`1971`	`+`
`1950`	`1972`	`await collection.insertOne({ a: 2 });`
`1951`	`1973`	`const change2 = await willBeChange.next();`
`1952`	`1974`	`expect(change2.value[0]).to.containSubset({`

0 commit comments

Comments

(0)

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit 93138f0

File tree

1 file changed

1 file changed

`‎test/integration/change-streams/change_stream.test.ts‎`

0 commit comments