refactor: Update processing pipeline export for consistency and backward compatibility

This commit is contained in:
defiQUG
2025-10-05 09:22:17 -07:00
parent ad8e763750
commit c997f33d62
2 changed files with 7 additions and 7 deletions

View File

@@ -434,15 +434,15 @@ export class RealTimeProcessingPipeline {
getConfig(): ProcessingPipelineConfig {
return { ...this.config }
}
updateConfig(newConfig: Partial<ProcessingPipelineConfig>): void {
this.config = { ...this.config, ...newConfig }
console.log('🔧 Pipeline configuration updated')
}
}
// Export singleton instance
export const processingPipeline = new RealTimeProcessingPipeline()
// Export singleton instance for backward compatibility
export const pipeline = new RealTimeProcessingPipeline()
// Export classes for testing and advanced usage
export { NotificationService, AssignmentManager, ReviewManager }

View File

@@ -11,7 +11,7 @@ import type {
UrgencyLevel,
AssistanceCategory
} from '../ai/types'
import { processingPipeline } from '../ai/ProcessingPipeline'
import { pipeline } from '../ai/ProcessingPipeline'
// Icons (using the existing icon system)
const Brain = ({ className = "w-5 h-5" }: { className?: string }) => (
@@ -98,7 +98,7 @@ export function AIAssistancePortal({ userRole }: AIAssistancePortalProps) {
useEffect(() => {
// Subscribe to real-time AI updates
const unsubscribe = processingPipeline.subscribe(handleRealTimeUpdate)
const unsubscribe = pipeline.subscribe(handleRealTimeUpdate)
// Generate initial insights
generateInsights()
@@ -133,7 +133,7 @@ export function AIAssistancePortal({ userRole }: AIAssistancePortalProps) {
const generateInsights = async () => {
try {
const insights = await processingPipeline.generateInsights(requests)
const insights = await pipeline.generateInsights(requests)
setAIInsights(insights)
} catch (error) {
console.error('Error generating insights:', error)
@@ -172,7 +172,7 @@ export function AIAssistancePortal({ userRole }: AIAssistancePortalProps) {
}
// Submit to AI processing pipeline
await processingPipeline.submitRequest(newRequest)
await pipeline.submitRequest(newRequest)
setRequests(prev => [newRequest, ...prev])