Renamed mongoDBEventStoreConsumer file

Author: oskardudycz

src/packages/emmett-mongodb/src/eventStore/consumers/mongoDBEventStore.subscription.e2e.spec.ts

@@ -30,7 +30,7 @@ import { CancellationPromise } from './CancellablePromise';
 import {
   mongoDBEventStoreConsumer,
   type MongoDBEventStoreConsumer,
-} from './mongoDBEventsConsumer';
+} from './mongoDBEventStoreConsumer';
 import type { MongoDBProcessor } from './mongoDBProcessor';
 import { compareTwoMongoDBCheckpoints } from './subscriptions';
 import type { MongoDBCheckpoint } from './subscriptions/mongoDBCheckpoint';

src/packages/emmett-mongodb/src/eventStore/consumers/mongoDBEventStoreConsumer.handling.int.spec.ts

@@ -15,7 +15,7 @@ import {
   getMongoDBEventStore,
   type MongoDBEventStore,
 } from '../mongoDBEventStore';
-import { mongoDBEventStoreConsumer } from './mongoDBEventsConsumer';
+import { mongoDBEventStoreConsumer } from './mongoDBEventStoreConsumer';
 
 const withDeadline = { timeout: 1000000 };
 

src/packages/emmett-mongodb/src/eventStore/consumers/mongoDBEventStoreConsumer.inMemory.projections.int.spec.ts

@@ -21,7 +21,7 @@ import {
   getMongoDBEventStore,
   type MongoDBEventStore,
 } from '../mongoDBEventStore';
-import { mongoDBEventStoreConsumer } from './mongoDBEventsConsumer';
+import { mongoDBEventStoreConsumer } from './mongoDBEventStoreConsumer';
 
 const withDeadline = { timeout: 30000 };
 

src/packages/emmett-mongodb/src/eventStore/consumers/mongoDBEventStoreConsumer.int.spec.ts

@@ -15,7 +15,7 @@ import { v4 as uuid } from 'uuid';
 import {
   mongoDBEventStoreConsumer,
   type MongoDBEventStoreConsumer,
-} from './mongoDBEventsConsumer';
+} from './mongoDBEventStoreConsumer';
 import { isDatabaseUnavailableError } from './subscriptions';
 
 const withDeadline = { timeout: 30000 };

src/packages/emmett-mongodb/src/eventStore/consumers/mongoDBEventsConsumer.ts renamed to src/packages/emmett-mongodb/src/eventStore/consumers/mongoDBEventStoreConsumer.ts

@@ -15,7 +15,7 @@ import {
 import { MongoClient } from 'mongodb';
 import type { MongoDBEventStoreConnectionOptions } from '../mongoDBEventStore';
 import { mongoDBCheckpointer } from './mongoDBCheckpointer';
-import type { MongoDBChangeStreamMessageMetadata } from './mongoDBEventsConsumer';
+import type { MongoDBChangeStreamMessageMetadata } from './mongoDBEventStoreConsumer';
 
 type MongoDBConnectionOptions = {
   connectionOptions: MongoDBEventStoreConnectionOptions;

src/packages/emmett-mongodb/src/eventStore/consumers/mongoDBProcessor.ts

@@ -28,7 +28,7 @@ import type {
   EventStream,
   MongoDBReadEventMetadata,
 } from '../../mongoDBEventStore';
-import type { MongoDBChangeStreamMessageMetadata } from '../mongoDBEventsConsumer';
+import type { MongoDBChangeStreamMessageMetadata } from '../mongoDBEventStoreConsumer';
 import {
   isMongoDBCheckpoint,
   toMongoDBCheckpoint,