feat(src): call storeAggregationMethods function from impactEngine

src/if-run/index.ts

@@ -1,19 +1,20 @@
 #!/usr/bin/env node
-import {aggregate, storeAggregateMetrics} from './lib/aggregate';
-import {compute} from './lib/compute';
+import {STRINGS as COMMON_STRINGS} from '../common/config';
+import {validateManifest} from '../common/util/validations';
+import {debugLogger} from '../common/util/debug-logger';
+import {logger} from '../common/util/logger';
+import {load} from '../common/lib/load';
+
+import {aggregate, storeAggregationMetrics} from './lib/aggregate';
 import {injectEnvironment} from './lib/environment';
-import {exhaust} from './lib/exhaust';
 import {initialize} from './lib/initialize';
-import {load} from '../common/lib/load';
+import {compute} from './lib/compute';
+import {exhaust} from './lib/exhaust';
 
 import {parseIfRunProcessArgs} from './util/args';
-import {andHandle} from './util/helpers';
-import {logger} from '../common/util/logger';
-import {validateManifest} from '../common/util/validations';
-import {debugLogger} from '../common/util/debug-logger';
+import {andHandle, storeAggregationMethods} from './util/helpers';
 
 import {STRINGS} from './config';
-import {STRINGS as COMMON_STRINGS} from '../common/config';
 
 const {EXITING_IF, STARTING_IF} = STRINGS;
 const {DISCLAIMER_MESSAGE} = COMMON_STRINGS;
@@ -32,11 +33,14 @@ const impactEngine = async () => {
 
   try {
     const {tree, ...context} = validateManifest(envManifest);
+    const pluginStorage = await initialize(context.initialize.plugins);
+
+    if (context.aggregation) {
+      storeAggregationMetrics({metrics: context.aggregation?.metrics});
+    }
 
-    // TODO: remove this after resolving timeSync to be a builtin functionality.
-    storeAggregateMetrics(context.aggregation);
+    storeAggregationMethods(context.initialize.plugins, pluginStorage);
 
-    const pluginStorage = await initialize(context.initialize.plugins);
     const computedTree = await compute(tree, {context, pluginStorage});
     const aggregatedTree = aggregate(computedTree, context.aggregation);
     await exhaust(aggregatedTree, context, outputOptions);