fix domain ports: add EventConsumer, use ID newtypes

crates/domain/src/ports/schedule.rs

@@ -4,11 +4,9 @@ use std::collections::HashMap;
 
 use async_trait::async_trait;
 use chrono::{DateTime, Utc};
-use uuid::Uuid;
-
 use crate::errors::DomainResult;
 use crate::models::{GeneratedSchedule, PlaybackRecord};
-use crate::value_objects::{BlockId, ChannelId, MediaItemId};
+use crate::value_objects::{BlockId, ChannelId, MediaItemId, ScheduleId};
 
 /// Write-side port for schedule and playback persistence.
 #[async_trait]
@@ -71,6 +69,6 @@ pub trait ScheduleQuery: Send + Sync {
     async fn get_schedule_by_id(
         &self,
         channel_id: ChannelId,
-        schedule_id: Uuid,
+        schedule_id: ScheduleId,
     ) -> DomainResult<Option<GeneratedSchedule>>;
 }