Function createCustomFunctionCall

packages/steps/src/utils/customFunction.ts:43–82

(rawCustomFunctionModulePath: string)

}

export function createCustomFunctionCall(rawCustomFunctionModulePath: string): BuildStepFunction {
  return async (ctx, { env, inputs, outputs }) => {
    let customFunctionModulePath = rawCustomFunctionModulePath;
    if (!(await fs.exists(ctx.global.projectSourceDirectory))) {
      const relative = path.relative(
        path.resolve(ctx.global.projectSourceDirectory),
        customFunctionModulePath
      );
      customFunctionModulePath = path.resolve(
        path.join(ctx.global.projectTargetDirectory, relative)
      );
    }
    const serializedArguments: SerializedCustomBuildFunctionArguments = {
      env,
      inputs: serializeInputs(inputs),
      outputs: Object.fromEntries(
        Object.entries(outputs).map(([id, output]) => [id, output.serialize()])
      ),
      ctx: ctx.serialize(),
    };
    try {
      await spawnAsync(
        'node',
        [
          path.join(SCRIPTS_PATH, 'runCustomFunction.js'),
          customFunctionModulePath,
          JSON.stringify(serializedArguments),
        ],
        {
          logger: ctx.logger,
          cwd: ctx.workingDirectory,
          env,
          stdio: 'pipe',
        }
      );
    } catch {
      throw new Error(`Custom function exited with non-zero exit code.`);
    }
  };
}