Skip to content

Commit befdd4d

Browse files
Copilothotlong
andcommitted
Fix MongoDB change stream tests by using replica set
Co-authored-by: hotlong <50353452+hotlong@users.noreply.github.com>
1 parent 8407d6b commit befdd4d

1 file changed

Lines changed: 9 additions & 5 deletions

File tree

packages/drivers/mongo/test/integration.test.ts

Lines changed: 9 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -8,7 +8,7 @@
88

99
import { MongoDriver } from '../src';
1010
import { MongoClient } from 'mongodb';
11-
import { MongoMemoryServer } from 'mongodb-memory-server';
11+
import { MongoMemoryReplSet } from 'mongodb-memory-server';
1212

1313
/**
1414
* Integration tests for MongoDriver with real MongoDB operations.
@@ -32,18 +32,22 @@ const skipIfMongoUnavailable = () => {
3232
describe('MongoDriver Integration Tests', () => {
3333
let driver: MongoDriver;
3434
let client: MongoClient;
35-
let mongod: MongoMemoryServer;
35+
let mongod: MongoMemoryReplSet;
3636
let mongoUrl: string;
3737
let dbName: string;
3838

3939
beforeAll(async () => {
4040
try {
41-
// Use existing MONGO_URL if provided (e.g. implementation in CI services)
42-
// Otherwise start an in-memory instance
41+
// Use existing MONGO_URL if provided (e.g. in CI services)
42+
// Otherwise start an in-memory replica set
4343
if (process.env.MONGO_URL) {
4444
mongoUrl = process.env.MONGO_URL;
4545
} else {
46-
mongod = await MongoMemoryServer.create();
46+
// Create MongoDB Memory Replica Set
47+
// This is required for change streams to work
48+
mongod = await MongoMemoryReplSet.create({
49+
replSet: { count: 1, storageEngine: 'wiredTiger' }
50+
});
4751
mongoUrl = mongod.getUri();
4852
}
4953

0 commit comments

Comments
 (0)