Function executeReadTSVFromPackNode

src/nodeExecutor.ts:6203–6444

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

}

async function executeReadTSVFromPackNode(
  nodeId: string,
  textValue: string,
  inputData: any,
  config?: unknown,
  executionContext?: FlowExecutionContext,
): Promise<NodeExecutionResult> {
  hotPathLog(executionContext, `ReadTSVFromPack Node ${nodeId}: Processing with input:`, inputData);

  // Handle both array input (new format with two inputs) and single input (backward compatibility)
  let schemaData: any;
  let packsData: any = null;

  if (Array.isArray(inputData)) {
    // New format: [schemaData, packsData]
    [schemaData, packsData] = inputData;
  } else {
    // Old format: single schemaData input
    schemaData = inputData;
  }

  if (!schemaData || schemaData.type !== "CustomSchema") {
    return { success: false, error: "Invalid input: Expected CustomSchema data" };
  }

  // Parse configuration from textValue
  let tsvFileName = "";
  const schemaColumns = (schemaData.schemaColumns || []) as CustomSchemaColumn[];

  hotPathLog(executionContext, `ReadTSVFromPack Node ${nodeId}: textValue received:`, textValue);

  const parsed = getNodeConfig<{ tsvFileName?: string }>(config, textValue);
  if (!parsed) {
    return {
      success: false,
      error: "Invalid configuration: Failed to parse node settings",
    };
  }
  tsvFileName = parsed.tsvFileName || "";

  if (!tsvFileName) {
    hotPathLog(executionContext, `ReadTSVFromPack Node ${nodeId}: No TSV file specified - returning empty output`);
    return {
      success: true,
      data: {
        type: "TableSelection",
        tables: [],
        sourceFiles: [],
        tableCount: 0,
      } as DBTablesNodeData,
    };
  }

  if (schemaColumns.length === 0) {
    hotPathLog(executionContext, `ReadTSVFromPack Node ${nodeId}: No schema columns - returning empty output`);
    return {
      success: true,
      data: {