From 6e235a00b4d39dd4562007ba0951215b42d9cc31 Mon Sep 17 00:00:00 2001 From: David Snelling Date: Fri, 20 Jun 2025 12:03:58 -0700 Subject: [PATCH] **feat: expand pipeline exports to include unified and augmentation factories** ### Changes: - Updated `src/index.ts` exports to streamline pipeline and augmentation factory usage: - Consolidated augmentation and streamlined pipeline exports under unified `Pipeline` module (e.g., `pipeline`, `createPipeline`, `executeStreamlined`). - Added new augmentation factory exports: - `createSenseAugmentation`, `addWebSocketSupport`, `executeAugmentation`, `loadAugmentationModule`. - Enhanced backward compatibility with separate sequential pipeline exports. - Introduced streamlined type exports, including `StreamlinedExecutionMode`, `StreamlinedPipelineOptions`, and `StreamlinedPipelineResult`. ### Purpose: Standardized pipeline and augmentation factory exports for better modularity and backward compatibility. These changes improve developer experience by simplifying imports and aligning with the unified augmentation pipeline system. --- src/index.ts | 63 ++++++++++++++++++++++++++++++++++++++++++++-------- 1 file changed, 54 insertions(+), 9 deletions(-) diff --git a/src/index.ts b/src/index.ts index 1adf052c..6001fd2d 100644 --- a/src/index.ts +++ b/src/index.ts @@ -57,30 +57,75 @@ export { createStorage } -// Export augmentation pipeline +// Export unified pipeline import { - AugmentationPipeline, + Pipeline, + pipeline, augmentationPipeline, ExecutionMode, - PipelineOptions -} from './augmentationPipeline.js' + PipelineOptions, + PipelineResult, + executeStreamlined, + executeByType, + executeSingle, + processStaticData, + processStreamingData, + createPipeline, + createStreamingPipeline, + StreamlinedExecutionMode, + StreamlinedPipelineOptions, + StreamlinedPipelineResult +} from './pipeline.js' -// Export sequential pipeline +// Export sequential pipeline (for backward compatibility) import { SequentialPipeline, sequentialPipeline, - PipelineResult, SequentialPipelineOptions } from './sequentialPipeline.js' +// Export augmentation factory +import { + createSenseAugmentation, + addWebSocketSupport, + executeAugmentation, + loadAugmentationModule, + AugmentationOptions +} from './augmentationFactory.js' + export { - AugmentationPipeline, + // Unified pipeline exports + Pipeline, + pipeline, augmentationPipeline, ExecutionMode, SequentialPipeline, - sequentialPipeline + sequentialPipeline, + + // Streamlined pipeline exports (now part of unified pipeline) + executeStreamlined, + executeByType, + executeSingle, + processStaticData, + processStreamingData, + createPipeline, + createStreamingPipeline, + StreamlinedExecutionMode, + + // Augmentation factory exports + createSenseAugmentation, + addWebSocketSupport, + executeAugmentation, + loadAugmentationModule +} +export type { + PipelineOptions, + PipelineResult, + SequentialPipelineOptions, + StreamlinedPipelineOptions, + StreamlinedPipelineResult, + AugmentationOptions } -export type { PipelineOptions, PipelineResult, SequentialPipelineOptions } // Export augmentation registry for build-time loading import {