Update event_bus.py

event_bus.py

@@ -64,11 +64,41 @@ class EventType(Enum):
 class Event:
     """Event data structure"""
     type: EventType
-    session_id: str
     data: Dict[str, Any]
-    timestamp: datetime = None
-    priority: int = 0  # Higher priority = processed first
+    session_id: Optional[str] = None
+    timestamp: datetime = field(default_factory=datetime.utcnow)
+    priority: int = 0
     
+    def __lt__(self, other):
+        """Compare events by priority for PriorityQueue"""
+        if not isinstance(other, Event):
+            return NotImplemented
+        # Önce priority'ye göre karşılaştır
+        if self.priority != other.priority:
+            return self.priority < other.priority
+        # Priority eşitse timestamp'e göre karşılaştır
+        return self.timestamp < other.timestamp
+    
+    def __eq__(self, other):
+        """Check event equality"""
+        if not isinstance(other, Event):
+            return NotImplemented
+        return (self.priority == other.priority and 
+                self.timestamp == other.timestamp and
+                self.type == other.type)
+    
+    def __le__(self, other):
+        """Less than or equal comparison"""
+        return self == other or self < other
+    
+    def __gt__(self, other):
+        """Greater than comparison"""
+        return not self <= other
+    
+    def __ge__(self, other):
+        """Greater than or equal comparison"""
+        return not self < other
+        
     def __post_init__(self):
         if self.timestamp is None:
             self.timestamp = datetime.utcnow()