main.py

from event_analyzer.generator import event_stream
from event_analyzer.processor import EventProcessor
from event_analyzer.detector import BurstDetector


def run():
    processor = EventProcessor(window_seconds=30)
    error_detector = BurstDetector(threshold=5)

    try:
        for event in event_stream(delay_seconds=1):
            processor.process_event(event)

            error_count = processor.count("ERROR")

            if error_detector.check(error_count):
                print(
                    f"[HIGH] ERROR_BURST: {error_count} ERROR events in sliding window"
                )

    except KeyboardInterrupt:
        print("\nShutting down cleanly.")
        print("Final counts:", dict(processor.count_by_type))


if __name__ == "__main__":
    run()