manasight-parser 0.2.0

//! MTG Arena log file parser.
//!
//! This library crate reads Arena's `Player.log`, parses raw log entries
//! into typed game events, and distributes them via an async broadcast
//! channel. It is designed to run on the caller's Tokio runtime — it does
//! not initialize its own runtime or logger.
//!
//! # Quick start
//!
//! ```rust,no_run
//! use std::path::Path;
//! use manasight_parser::MtgaEventStream;
//!
//! # async fn example() -> Result<(), Box<dyn std::error::Error>> {
//! let (stream, mut subscriber) = MtgaEventStream::start(Path::new("Player.log")).await?;
//!
//! while let Some(event) = subscriber.recv().await {
//!     println!("got event: {event:?}");
//! }
//! # Ok(())
//! # }
//! ```
//!
//! # Architecture
//!
//! ```text
//! Player.log → File Tailer → Entry Buffer → Router → Parsers → Event Bus
//! ```
//!
//! - **`log`** module: file discovery, polling tailer, entry accumulation, timestamps
//! - **`router`**: dispatches raw entries to the correct category parser
//! - **`parsers`**: one sub-module per event category
//! - **`events`**: public event type enums/structs (the parser's output contract)
//! - **`event_bus`**: `tokio::broadcast` channel for fan-out to subscribers
//! - **`stream`**: public entry point ([`MtgaEventStream`])

pub mod event_bus;
pub mod events;
pub mod log;
pub mod parsers;
pub mod router;
pub mod sanitize;
pub mod stream;
pub mod util;

// ---------------------------------------------------------------------------
// Re-exports — public API surface
// ---------------------------------------------------------------------------

pub use event_bus::Subscriber;
pub use events::{
    ClientActionEvent, DetailedLoggingStatusEvent, DraftBotEvent, DraftCompleteEvent,
    DraftHumanEvent, EventLifecycleEvent, EventMetadata, GameEvent, GameResultEvent,
    GameStateEvent, InventoryEvent, LogFileRotatedEvent, MatchStateEvent, PerformanceClass,
    RankEvent, SessionEvent,
};
pub use sanitize::scrub_raw_log;
pub use stream::{MtgaEventStream, StreamError};
pub use util::{compress_log, content_hash};