Started work on use cases

Jira ticket: CAMS-461

backend/functions/lib/use-cases/orders/orders.ts

@@ -64,6 +64,8 @@ export interface SyncOrdersStatus {
   maxTxId: string;
 }
 
+export interface ImportConsolidationOptions {}
+
 export class OrdersUseCase {
   private readonly casesRepo: CasesRepository;
   private readonly casesGateway: CasesInterface;
@@ -169,12 +171,41 @@ export class OrdersUseCase {
     }
   }
 
+  public async getConsolidationPageCount(
+    context: ApplicationContext,
+    _options?: ImportConsolidationOptions,
+  ): Promise<number> {
+    try {
+      //const pageCount = await this.legacyDatabaseRepo.read('', '');
+      //context.logger.info(MODULE_NAME, 'Got page count for import from repo.', pageCount);
+      //return pageCount;
+    } catch (error) {
+      const message = 'Failed to get page count for consolidation import from repo.';
+      context.logger.info(MODULE_NAME, message, error);
+      throw new CamsError(MODULE_NAME, { message });
+    }
+    return 0;
+  }
+
+  public async importConsolidationData(
+    context: ApplicationContext,
+    _options?: ImportConsolidationOptions,
+  ): Promise<void> {
+    try {
+      //const consolidations = await this.legacyDatabaseRepo.read('', '');
+    } catch (error) {
+      const message = 'Failed to get consolidation data from repo.';
+      context.logger.info(MODULE_NAME, message, error);
+      throw new CamsError(MODULE_NAME, { message });
+    }
+    return;
+  }
+
   public async syncOrders(
     context: ApplicationContext,
     options?: SyncOrdersOptions,
   ): Promise<SyncOrdersStatus> {
     let initialSyncState: OrderSyncState;
-
     try {
       initialSyncState = await this.runtimeStateRepo.read('ORDERS_SYNC_STATE', '');
       context.logger.info(

backend/functions/poc/activity/getPageCount.ts

@@ -1,10 +1,44 @@
 import { InvocationContext } from '@azure/functions';
 import { PredicateAndPage } from '../model';
+import { OrdersUseCase } from '../../lib/use-cases/orders/orders';
+import {
+  getCasesRepository,
+  getCasesGateway,
+  getOrdersRepository,
+  getOrdersGateway,
+  getRuntimeStateRepository,
+  getConsolidationOrdersRepository,
+  getStorageGateway,
+} from '../../lib/factory';
+import { OrderSyncState } from '../../lib/use-cases/gateways.types';
+import ContextCreator from '../../azure/application-context-creator';
+import { CamsError } from '../../lib/common-errors/cams-error';
 
-async function getPageCount(input: PredicateAndPage, context: InvocationContext) {
-  // Do some stuff
-  context.log('#################GetPageCount', JSON.stringify(input));
-  return 4;
+const MODULE_NAME = 'IMPORT-ACTION-GET-PAGE-COUNT';
+
+async function getPageCount(input: PredicateAndPage, invocationContext: InvocationContext) {
+  const logger = ContextCreator.getLogger(invocationContext);
+  try {
+    const context = await ContextCreator.applicationContextCreator(invocationContext, logger);
+
+    // Do some stuff
+    console.log('#################GetPageCount', JSON.stringify(input));
+    // TODO: This seems silly to have to supply all of these repos and gateways.
+    // Are we going to add yet another for ACMS?
+    const orders = new OrdersUseCase(
+      getCasesRepository(context),
+      getCasesGateway(context),
+      getOrdersRepository(context),
+      getOrdersGateway(context),
+      getRuntimeStateRepository<OrderSyncState>(context),
+      getConsolidationOrdersRepository(context),
+      getStorageGateway(context),
+    );
+
+    return orders.getConsolidationPageCount(context, {});
+  } catch (originalError) {
+    throw new CamsError(MODULE_NAME, { originalError });
+  }
 }
 
 export default {