Function runCustomJsFunctionAsync

packages/steps/src/scripts/runCustomFunction.ts:12–114

()

import { spawnAsync } from '../utils/shell/spawn';

async function runCustomJsFunctionAsync(): Promise<void> {
  const customJavascriptFunctionModulePath = process.argv[2];
  const functionArgs = process.argv[3];

  assert(customJavascriptFunctionModulePath, 'customJavascriptFunctionModulePath is required');
  assert(functionArgs, 'serializedFunctionParams is required');

  let serializedFunctionArguments: SerializedCustomBuildFunctionArguments;
  try {
    serializedFunctionArguments = JSON.parse(functionArgs);
  } catch (e) {
    console.error('Failed to parse serializedFunctionParams');
    throw e;
  }

  const logger = createLogger({
    name: 'customFunctionLogger',
    streams: [
      {
        type: 'raw',
        stream: {
          write: (rec: any) => {
            if (rec) {
              switch (rec.level) {
                case 20: // Debug level
                  if (rec.msg) {
                    console.debug(rec.msg);
                  }
                  break;
                case 30: // Info level
                  if (rec.msg) {
                    console.log(rec.msg);
                  }
                  break;
                case 40: // Warn level
                  if (rec.msg) {
                    console.warn(rec.msg);
                  }
                  break;
                case 50: // Error level
                case 60: // Fatal level
                  if (rec.msg) {
                    console.error(rec.msg);
                  }
                  break;
                default:
                  break;
              }
            }
          },
        },
      },
    ],
  });

  const ctx = BuildStepContext.deserialize(serializedFunctionArguments.ctx, logger);
  const inputs = deserializeInputs(serializedFunctionArguments.inputs);
  const outputs = Object.fromEntries(