Update default database filenames and enhance TinyDB event handling

- Changed default database filenames from "events.db" to "logs.db" and "events.json" to "logs.json" based on storage backend.
- Added cache clearing and table reloading in TinyDBEventBusDatabase to ensure fresh reads of unprocessed events and improve cleanup accuracy.

Author: Dylan Huang

eval_protocol/event_bus/__init__.py

@@ -35,7 +35,7 @@ def get_event_bus_database(db_path: str) -> EventBusDatabase:
 def _get_default_db_filename() -> str:
     """Get the default database filename based on storage backend."""
     storage_type = os.getenv("EP_STORAGE", "tinydb").lower()
-    return "events.db" if storage_type == "sqlite" else "events.json"
+    return "logs.db" if storage_type == "sqlite" else "logs.json"
 
 
 def _get_default_event_bus():

eval_protocol/event_bus/tinydb_event_bus_database.py

@@ -51,9 +51,19 @@ def publish_event(self, event_type: str, data: Any, process_id: str) -> None:
     def get_unprocessed_events(self, process_id: str) -> List[dict]:
         """Get unprocessed events from other processes."""
         try:
+            # Clear query cache to force fresh read from disk
+            # TinyDB caches query results, so we need to clear cache to see
+            # events written by other processes. The search() method will
+            # automatically call _read_table() on a cache miss.
+            self._table.clear_cache()
+
             Event = Query()
             results = self._table.search((Event.process_id != process_id) & (Event.processed == False))  # noqa: E712
 
+            logger.debug(
+                f"TinyDBEventBusDatabase: Found {len(results)} unprocessed events for process_id: {process_id} in database: {self._db_path}"
+            )
+
             events = []
             # Sort by timestamp
             for event in sorted(results, key=lambda x: x.get("timestamp", 0)):
@@ -83,6 +93,9 @@ def mark_event_processed(self, event_id: str) -> None:
     def cleanup_old_events(self, max_age_hours: int = 24) -> None:
         """Clean up old processed events."""
         try:
+            # Reload table from disk to see latest data before cleanup
+            self._table._read_table()
+
             cutoff_time = time.time() - (max_age_hours * 3600)
             Event = Query()
             self._table.remove((Event.processed == True) & (Event.timestamp < cutoff_time))  # noqa: E712