Function executeSaveChangesNode

src/nodeExecutor.ts:2707–2970

(
  nodeId: string,
  textValue: string,
  inputData: any,
  config?: unknown,
  executionContext?: FlowExecutionContext,
)

}

async function executeSaveChangesNode(
  nodeId: string,
  textValue: string,
  inputData: any,
  config?: unknown,
  executionContext?: FlowExecutionContext,
): Promise<NodeExecutionResult> {
  console.log(`SaveChanges Node ${nodeId}: Processing save configuration "${textValue}" with tables:`, {
    tableCount: inputData?.tables?.length,
    tableNames: inputData?.tables?.map((t: any) => t.name),
  });

  // Parse configuration from textValue
  let packName = "";
  let packedFileName = "";
  let additionalConfig = "";
  let flowExecutionId = "";

  const parsedConfig = getNodeConfig<{
    packName?: string;
    packedFileName?: string;
    additionalConfig?: string;
    flowExecutionId?: string;
  }>(config, textValue);
  if (parsedConfig) {
    packName = parsedConfig.packName || "";
    packedFileName = parsedConfig.packedFileName || "";
    additionalConfig = parsedConfig.additionalConfig || "";
    flowExecutionId = parsedConfig.flowExecutionId || "";
  } else {
    // If not JSON, treat textValue as additionalConfig
    additionalConfig = textValue.trim();
  }

  console.log(`Save Changes Node ${nodeId}: Received inputData type:`, inputData?.type);
  console.log(`Save Changes Node ${nodeId}: inputData exists:`, !!inputData);

  // Handle Text input - save as text file
  if (inputData && inputData.type === "Text") {
    return await executeSaveTextNode(nodeId, inputData.text || "", packName, packedFileName);
  }

  // Handle TableSelection input - save table data
  if (inputData && inputData.type === "TableSelection") {
    const toSave = [] as NewPackedFile[];

    for (const table of inputData.tables || []) {
      if (!table.table.schemaFields || !table.table.tableSchema) continue;

      toSave.push({
        name: "", // Will be set after we determine pack name
        schemaFields: table.table.schemaFields,
        version: table.table.version,
        tableSchema: table.table.tableSchema,
        tableName: table.name, // Store table name for later use
      } as any);
    }