feat: Allows async connections. (#29)

BREAKING CHANGE: `axios` property in `FactoryConfig` must be an async function returning an `AxiosInstance` instead of an `AxiosInstance` itself.

Author: ryasmi

src/FacadeConfig.ts

@@ -6,7 +6,7 @@ import { AxiosInstance } from 'axios';
 export type Document = any;
 
 export default interface FacadeConfig<E extends Entity> {
-  readonly axios: AxiosInstance;
+  readonly axios: () => Promise<AxiosInstance>;
   readonly constructDocument: (patch: Partial<E>) => Document;
   readonly constructEntity: (document: Document) => E;
   readonly constructFilter: (filter: Filter<E>) => any;

src/FactoryConfig.ts

@@ -6,7 +6,7 @@ import { AxiosInstance } from 'axios';
 export type Document = any;
 
 export default interface FactoryConfig<E extends Entity> {
-  readonly axios: AxiosInstance;
+  readonly axios: () => Promise<AxiosInstance>;
   readonly constructDocument?: (patch: Partial<E>) => Document;
   readonly constructEntity?: (document: Document) => E;
   readonly constructFilter?: (filter: Filter<E>) => any;

src/factory.test.ts

@@ -32,7 +32,7 @@ after(async () => {
 });
 
 facadeTest(factory<TestEntity>({
-  axios: axios.create({
+  axios: async () => axios.create({
     baseURL: `http://localhost:${testServerPort}${testServerRoute}`,
   }),
   entityName: 'Test Entity',

src/functions/countEntities.ts

@@ -4,9 +4,10 @@ import FacadeConfig from '../FacadeConfig';
 
 export default <E extends Entity>(config: FacadeConfig<E>): CountEntities<E> => {
   return async ({ filter = {} }) => {
+    const connection = await config.axios();
     const constructedFilter = config.constructFilter(filter);
     const params = { filter: JSON.stringify(constructedFilter) };
-    const response = await Promise.resolve(config.axios.get('/count', { params }));
+    const response = await Promise.resolve(connection.get('/count', { params }));
     return { count: response.data };
   };
 };

src/functions/createEntity.ts

@@ -6,8 +6,9 @@ import FacadeConfig from '../FacadeConfig';
 
 export default <E extends Entity>(config: FacadeConfig<E>): CreateEntity<E> => {
   return async ({ id, entity }) => {
+    const connection = await config.axios();
     const data = config.constructDocument({ ...entity as any, id });
-    const response = await config.axios.post('', data).catch((err) => {
+    const response = await connection.post('', data).catch((err) => {
       if (err.response.status === CONFLICT) {
         throw new ConflictingEntityError(config.entityName, id);
       }

src/functions/getEntities.ts

@@ -14,6 +14,7 @@ export default <E extends Entity>(config: FacadeConfig<E>): GetEntities<E> => {
   };
   const defaultSort = { id: asc } as Sort<E>;
   return async ({ filter = {}, sort = defaultSort, pagination = defaultPagination }) => {
+    const connection = await config.axios();
     const constructedFilter = config.constructFilter(filter);
     const constructedSort = config.constructSort(sort);
     const params = {
@@ -23,7 +24,7 @@ export default <E extends Entity>(config: FacadeConfig<E>): GetEntities<E> => {
       limit: pagination.limit,
       sort: JSON.stringify(constructedSort),
     };
-    const response = await Promise.resolve(config.axios.get('', { params }));
+    const response = await Promise.resolve(connection.get('', { params }));
 
     const entities = response.data.map(config.constructEntity);
     const backwardCursor = response.headers['x-entities-backward-cursor'];

src/functions/getEntity.ts

@@ -6,9 +6,10 @@ import FacadeConfig from '../FacadeConfig';
 
 export default <E extends Entity>(config: FacadeConfig<E>): GetEntity<E> => {
   return async ({ id, filter = {} }) => {
+    const connection = await config.axios();
     const constructedFilter = config.constructFilter(filter);
     const params = { filter: JSON.stringify(constructedFilter) };
-    const response = await config.axios.get(`/${id}`, { params }).catch((err) => {
+    const response = await connection.get(`/${id}`, { params }).catch((err) => {
       if (err.response.status === NOT_FOUND) {
         throw new MissingEntityError(config.entityName, id);
       }

src/functions/patchEntity.ts

@@ -6,10 +6,11 @@ import FacadeConfig from '../FacadeConfig';
 
 export default <E extends Entity>(config: FacadeConfig<E>): PatchEntity<E> => {
   return async ({ id, patch, filter = {} }) => {
+    const connection = await config.axios();
     const data = config.constructDocument({ ...patch as any, id });
     const constructedFilter = config.constructFilter(filter);
     const params = { filter: JSON.stringify(constructedFilter) };
-    const response = await config.axios.patch(`/${id}`, data, { params }).catch((err) => {
+    const response = await connection.patch(`/${id}`, data, { params }).catch((err) => {
       if (err.response.status === NOT_FOUND) {
         throw new MissingEntityError(config.entityName, id);
       }

src/functions/removeEntities.ts

@@ -4,8 +4,9 @@ import FacadeConfig from '../FacadeConfig';
 
 export default <E extends Entity>(config: FacadeConfig<E>): RemoveEntities<E> => {
   return async ({ filter = {} }) => {
+    const connection = await config.axios();
     const constructedFilter = config.constructFilter(filter);
     const params = { filter: JSON.stringify(constructedFilter) };
-    await Promise.resolve(config.axios.delete('', { params }));
+    await Promise.resolve(connection.delete('', { params }));
   };
 };

src/functions/removeEntity.ts

@@ -6,9 +6,10 @@ import FacadeConfig from '../FacadeConfig';
 
 export default <E extends Entity>(config: FacadeConfig<E>): RemoveEntity<E> => {
   return async ({ id, filter = {} }) => {
+    const connection = await config.axios();
     const constructedFilter = config.constructFilter(filter);
     const params = { filter: JSON.stringify(constructedFilter) };
-    await config.axios.delete(`/${id}`, { params }).catch((err) => {
+    await connection.delete(`/${id}`, { params }).catch((err) => {
       if (err.response.status === NOT_FOUND) {
         throw new MissingEntityError(config.entityName, id);
       }