fix: Allows reconnections to be added. (#9)

BREAKING CHANGE: `collection` property in the factory config is now a function that returns the collection to allow for reconnections.

Author: ryasmi

readme.md

@@ -28,7 +28,7 @@ import connectToCollection from '@js-entity-repos/mongo/dist/utils/connectToColl
 import parseFilterId from '@js-entity-repos/mongo/dist/utils/parseFilterId';
 import renameSortId from '@js-entity-repos/mongo/dist/utils/renameSortId';
 
-const todoFacadeConfig: FacadeConfig<TodoEntity> = {
+const todoFactoryConfig: FactoryConfig<TodoEntity> = {
   collection: connectToCollection({
     collectionName: 'todos',
     dbName: 'todoapp',
@@ -60,5 +60,5 @@ const todoFacadeConfig: FacadeConfig<TodoEntity> = {
 ```ts
 import factory from '@js-entity-repos/mongo/dist/factory';
 
-const todosFacade = factory(todoFacadeConfig);
+const todosFacade = factory(todoFactoryConfig);
 ```

src/FacadeConfig.ts

@@ -6,7 +6,7 @@ import { Collection } from 'mongodb';
 export type Document = any;
 
 export default interface FacadeConfig<E extends Entity> {
-  readonly collection: Promise<Collection>;
+  readonly collection: () => Promise<Collection>;
   readonly defaultPaginationLimit: number;
   readonly entityName: string;
   readonly constructDocument: (patch: Partial<E>) => Document;

src/FactoryConfig.ts

@@ -6,7 +6,7 @@ import { Collection } from 'mongodb';
 export type Document = any;
 
 export default interface FactoryConfig<E extends Entity> {
-  readonly collection: Promise<Collection>;
+  readonly collection: () => Promise<Collection>;
   readonly defaultPaginationLimit?: number;
   readonly entityName: string;
   readonly constructDocument?: (patch: Partial<E>) => Document;

src/functions/countEntities.ts

@@ -4,7 +4,7 @@ import FacadeConfig from '../FacadeConfig';
 
 export default <E extends Entity>(config: FacadeConfig<E>): CountEntities<E> => {
   return async ({ filter = {} }) => {
-    const collection = (await config.collection);
+    const collection = (await config.collection());
     const constructedFilter = config.constructFilter(filter);
     const count = await collection.find(constructedFilter).count();
     return { count };

src/functions/createEntity.ts

@@ -6,7 +6,7 @@ import FacadeConfig from '../FacadeConfig';
 
 export default <E extends Entity>(config: FacadeConfig<E>): CreateEntity<E> => {
   return async ({ id, entity }) => {
-    const collection = (await config.collection);
+    const collection = (await config.collection());
     const document = config.constructDocument({ ...entity as any, id });
     const update = { $setOnInsert: document };
     const opts = { returnOriginal: false, upsert: true };

src/functions/getEntities.ts

@@ -18,7 +18,7 @@ export default <E extends Entity>(config: FacadeConfig<E>): GetEntities<E> => {
   };
   const defaultSort = { id: true } as Sort<E>;
   return async ({ filter = {}, sort = defaultSort, pagination = defaultPagination }) => {
-    const collection = (await config.collection);
+    const collection = (await config.collection());
 
     const paginationFilter = createPaginationFilter(pagination, sort);
     const fullFilter = { $and: [filter, paginationFilter] };

src/functions/getEntity.ts

@@ -6,7 +6,7 @@ import constructIdFilter from '../utils/constructIdFilter';
 
 export default <E extends Entity>(config: FacadeConfig<E>): GetEntity<E> => {
   return async ({ id, filter = {} }) => {
-    const collection = (await config.collection);
+    const collection = (await config.collection());
     const constructedFilter = constructIdFilter({ id, filter, config });
     const document = await collection.findOne(constructedFilter);
 

src/functions/patchEntity.ts

@@ -6,7 +6,7 @@ import constructIdFilter from '../utils/constructIdFilter';
 
 export default <E extends Entity>(config: FacadeConfig<E>): PatchEntity<E> => {
   return async ({ id, patch, filter = {} }) => {
-    const collection = (await config.collection);
+    const collection = (await config.collection());
     const document = config.constructDocument({ ...patch as any, id });
     const update = { $set: document };
     const opts = { returnOriginal: false, upsert: false };

src/functions/removeEntities.ts

@@ -4,7 +4,7 @@ import FacadeConfig from '../FacadeConfig';
 
 export default <E extends Entity>(config: FacadeConfig<E>): RemoveEntities<E> => {
   return async ({ filter = {} }) => {
-    const collection = (await config.collection);
+    const collection = (await config.collection());
     const constructedFilter = config.constructFilter(filter);
     await collection.remove(constructedFilter);
   };

src/functions/removeEntity.ts

@@ -6,7 +6,7 @@ import constructIdFilter from '../utils/constructIdFilter';
 
 export default <E extends Entity>(config: FacadeConfig<E>): RemoveEntity<E> => {
   return async ({ id, filter = {} }) => {
-    const collection = (await config.collection);
+    const collection = (await config.collection());
     const constructedFilter = constructIdFilter({ id, filter, config });
     const { value } = await collection.findOneAndDelete(constructedFilter);
 

src/functions/replaceEntity.ts

@@ -6,7 +6,7 @@ import constructIdFilter from '../utils/constructIdFilter';
 
 export default <E extends Entity>(config: FacadeConfig<E>): ReplaceEntity<E> => {
   return async ({ id, entity, filter = {} }) => {
-    const collection = (await config.collection);
+    const collection = (await config.collection());
     const opts = { returnOriginal: false, upsert: false };
     const constructedFilter = constructIdFilter({ id, filter, config });
     const { value } = await collection.findOneAndUpdate(constructedFilter, entity, opts);

src/utils/connectToCollection.ts

@@ -1,11 +1,14 @@
+import { once } from 'lodash';
 import { Collection } from 'mongodb';
 import connectToDb, { Opts as DbConnectionOpts } from './connectToDb';
 
 export interface Opts extends DbConnectionOpts {
   readonly collectionName: string;
 }
 
-export default async ({ collectionName, ...dbConnectionOpts }: Opts): Promise<Collection> => {
-  const db = await connectToDb(dbConnectionOpts);
-  return db.collection(collectionName);
+export default ({ collectionName, ...dbConnectionOpts }: Opts) => {
+  return once(async (): Promise<Collection> => {
+    const db = await connectToDb(dbConnectionOpts)();
+    return db.collection(collectionName);
+  });
 };

src/utils/connectToDb.ts

@@ -1,11 +1,14 @@
+import { once } from 'lodash';
 import { Db, MongoClient } from 'mongodb';
 
 export interface Opts {
   readonly dbName: string;
   readonly url: string;
 }
 
-export default async ({ dbName, url }: Opts): Promise<Db> => {
-  const client = await MongoClient.connect(url);
-  return client.db(dbName);
+export default ({ dbName, url }: Opts) => {
+  return once(async (): Promise<Db> => {
+    const client = await MongoClient.connect(url);
+    return client.db(dbName);
+  });
 };