Function collectPipeline

ui/src/components/pipeline/pipeline.ts:69–89

(
  input: LoadingInput,
  ctx: PipelineContext,
  store?: Store,
)

/** Collect all events and return aggregated nodes/relationships (convenience for tests). */
export function collectPipeline(
  input: LoadingInput,
  ctx: PipelineContext,
  store?: Store,
): {
  events: PipelineEvent[];
  nodes: GraphNode[];
  relationships: GraphRelationship[];
} {
  const events: PipelineEvent[] = [];
  const nodes: GraphNode[] = [];
  const relationships: GraphRelationship[] = [];

  for (const event of runPipeline(input, ctx, store)) {
    events.push(event);
    if (event.nodes) nodes.push(...event.nodes);
    if (event.relationships) relationships.push(...event.relationships);
  }

  return { events, nodes, relationships };
}