Function mergeOutputPackFiles

src/nodeExecutor.ts:227–253

(
  packPath: string,
  newFiles: NewPackedFile[],
  executionContext?: FlowExecutionContext,
)

};

const mergeOutputPackFiles = async (
  packPath: string,
  newFiles: NewPackedFile[],
  executionContext?: FlowExecutionContext,
): Promise<NewPackedFile[]> => {
  const existingFiles = await loadExistingOutputPackFiles(packPath, executionContext);
  if (existingFiles.length === 0) {
    if (executionContext) {
      executionContext.outputPackByPath.set(packPath, newFiles.map(cloneNewPackedFile));
    }
    return newFiles;
  }

  const fileMap = new Map<string, NewPackedFile>();
  for (const existingFile of existingFiles) {
    fileMap.set(existingFile.name, cloneNewPackedFile(existingFile));
  }
  for (const newFile of newFiles) {
    fileMap.set(newFile.name, cloneNewPackedFile(newFile));
  }

  const mergedFiles = Array.from(fileMap.values());
  if (executionContext) {
    executionContext.outputPackByPath.set(packPath, mergedFiles.map(cloneNewPackedFile));
  }
  return mergedFiles;
};

export const executeNodeAction = async (request: NodeExecutionRequest): Promise<NodeExecutionResult> => {
  const { nodeId, nodeType, textValue, inputData, config, executionContext } = request;