All files / builtins/multiply index.ts

100% Statements 28/28
100% Branches 3/3
100% Functions 8/8
100% Lines 27/27

Press n or j to go to the next uncovered block, b, p or k for the previous block.

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 874x 4x             4x   4x   4x 4x   4x 2x             2x 3x         3x                 2x       3x 6x       1x       2x           2x 3x 3x 3x   3x 3x   2x                   2x 2x 5x       2x          
import {z} from 'zod';
import {ERRORS} from '@grnsft/if-core/utils';
import {
  ExecutePlugin,
  PluginParams,
  MultiplyConfig,
} from '@grnsft/if-core/types';
 
import {validate} from '../../util/validations';
 
import {STRINGS} from '../../config';
 
const {MissingInputDataError} = ERRORS;
const {MISSING_INPUT_DATA} = STRINGS;
 
export const Multiply = (globalConfig: MultiplyConfig): ExecutePlugin => {
  const metadata = {
    kind: 'execute',
  };
 
  /**
   * Checks global config value are valid.
   */
  const validateGlobalConfig = () => {
    const globalConfigSchema = z.object({
      'input-parameters': z.array(z.string()),
      'output-parameter': z.string().min(1),
    });
 
    return validate<z.infer<typeof globalConfigSchema>>(
      globalConfigSchema,
      globalConfig
    );
  };
 
  /**
   * Checks for required fields in input.
   */
  const validateSingleInput = (
    input: PluginParams,
    inputParameters: string[]
  ) => {
    inputParameters.forEach(metricToMultiply => {
      if (
        input[metricToMultiply] === undefined ||
        isNaN(input[metricToMultiply])
      ) {
        throw new MissingInputDataError(MISSING_INPUT_DATA(metricToMultiply));
      }
    });
 
    return input;
  };
 
  /**
   * Calculate the product of each input parameter.
   */
  const execute = (inputs: PluginParams[]): PluginParams[] => {
    const safeGlobalConfig = validateGlobalConfig();
    const inputParameters = safeGlobalConfig['input-parameters'];
    const outputParameter = safeGlobalConfig['output-parameter'];
 
    return inputs.map(input => {
      const safeInput = validateSingleInput(input, inputParameters);
 
      return {
        ...input,
        [outputParameter]: calculateProduct(safeInput, inputParameters),
      };
    });
  };
 
  /**
   * Calculates the product of the energy components.
   */
  const calculateProduct = (input: PluginParams, inputParameters: string[]) =>
    inputParameters.reduce(
      (accumulator, metricToMultiply) => accumulator * input[metricToMultiply],
      1
    );
 
  return {
    metadata,
    execute,
  };
};