refactor exhaust export csv to comply with functional arch

Signed-off-by: Paz Barda <[email protected]>

src/lib/exhaust.ts

@@ -1,18 +1,17 @@
-import {ExhaustCsvExporter} from '../models/exhaust-csv-export';
-import {ExhaustPluginInterface} from '../models/exhaust-plugin';
+import {ExhaustExportCsv} from '../models/exhaust-export-csv';
 
 const createExhaustPlugin = (pluginTypeName: string) => {
   switch (pluginTypeName) {
     case 'csv':
-      return new ExhaustCsvExporter();
+      return ExhaustExportCsv;
     default:
       throw new Error(`unkonwn exhaust plugin type: ${pluginTypeName}`);
   }
 };
 
 const initialize = (pipeline: string[]) => {
-  const exhaustPlugins: ExhaustPluginInterface[] = pipeline.map(
-    exhaustPluginName => createExhaustPlugin(exhaustPluginName)
+  const exhaustPlugins: any[] = pipeline.map(exhaustPluginName =>
+    createExhaustPlugin(exhaustPluginName)
   );
   return exhaustPlugins;
 };

src/models/exhaust-csv-export.ts → src/models/exhaust-export-csv.ts

@@ -4,24 +4,12 @@ import {ERRORS} from '../util/errors';
 import {ExhaustPluginInterface} from './exhaust-plugin';
 const {InputValidationError} = ERRORS;
 
-export class ExhaustCsvExporter implements ExhaustPluginInterface {
-  private createCsvContent(tree: any, headers: string[]): string {
-    return [
-      headers.join(','),
-      ...tree.map((row: {[x: string]: any}) =>
-        headers.map(fieldName => row[fieldName]).join(',')
-      ),
-    ].join('\r\n');
-  }
-
-  /**
-   * Export to CSV
-   */
-  async execute(
+export const ExhaustExportCsv = (): ExhaustPluginInterface => {
+  const execute: (
     context: any,
     tree: any,
     basePath: string
-  ): Promise<[any, any, string]> {
+  ) => Promise<[any, any, string]> = async (context, tree, basePath) => {
     // create directory in base path, if doesnt exist
     try {
       await fs.mkdir(basePath, {recursive: true});
@@ -36,7 +24,12 @@ export class ExhaustCsvExporter implements ExhaustPluginInterface {
     const headers = Object.keys(tree[0]);
 
     // create csv content from tree with headers
-    const contents = this.createCsvContent(tree, headers);
+    const contents = [
+      headers.join(','),
+      ...tree.map((row: {[x: string]: any}) =>
+        headers.map(fieldName => row[fieldName]).join(',')
+      ),
+    ].join('\r\n');
 
     // write content to csv file
     const outputPath = path.join(basePath, 'csv-export.csv');
@@ -50,5 +43,7 @@ export class ExhaustCsvExporter implements ExhaustPluginInterface {
     }
 
     return Promise.resolve([context, tree, basePath]);
-  }
-}
+  };
+
+  return {execute};
+};

src/models/index.ts

@@ -1 +1,2 @@
 export {TimeSyncModel} from './time-sync';
+export {ExhaustExportCsv} from './exhaust-export-csv';