unified_correlator.cpython-314.pyc
1 + 2 �Agi|: � �� a � R t10 t R t^ RIt^ RIt^ RIHtHt ^ RIHtHt ^ RI H 3 t 4 ^ RIHtH t HtHtHtHt ^ RIHt ^ RIHt ^RIHtHtHt ^R IHtHtHtHt ^R 5 IH t H!t! ^RI"H#t#H$t$ ! R R ]4 t%] ! R R4 4 t&] ! R R4 4 t' ! R R4 t(Rs)] ^ k R R lt*]+R8X d: ],! R4 ](! 4 t-]-P] ^R7 t/],! ]/Pa 4 4 R# R# )a� 6 Unified Correlator - Connects all data sources into a single correlation layer. 7 8 Brings together: 9 1. Claude sessions (from session transcripts) 10 2. Monologue voice transcripts 11 3. Comet browser history 12 4. Semantic graph (atoms, edges from Sovereign_Estate) 13 5. Claude.ai artifacts 14 15 All data flows into a unified event stream that can be: 16 - Correlated by time windows 17 - Streamed via SSE 18 - Queried for insights 19 20 Usage: 21 correlator = UnifiedCorrelator() 22 correlator.start() # Starts background watching 23 24 # Get unified view 25 report = correlator.get_unified_report(hours_back=24) 26 27 # Subscribe to events 28 correlator.subscribe('all', callback) 29 N)� dataclass�field)�datetime� timedelta)�Path)�Dict�List�Optional�Set�Any�Callable)�defaultdict)�Enum)�GraphIntegration� 30 GraphEvent� GraphAtom)�MultiSourceCorrelator�CorrelatedMoment�EventSource�SourceEvent)�ArtifactAnalyzer�Artifact)�detect_signals�SignalDetectionc �B � ] tR t^+tRtRtRtRtRtRt Rt 31 RtR tR 32 t RtRtR # )�UnifiedEventTypez#All event types across all sources.�claude_session� monologue�browser� 33 graph_atom� 34 graph_edge�gravity_well�artifact� 35 aha_moment�correlation�high_resonance� N)�__name__� 36 __module__�__qualname__�__firstlineno__�__doc__�CLAUDE_SESSION� MONOLOGUE�BROWSER� 37 GRAPH_ATOM� 38 GRAPH_EDGE�GRAVITY_WELL�ARTIFACT� 39 AHA_MOMENT�CORRELATION�HIGH_RESONANCE�__static_attributes__r&