feat: setup windows system console output detection for dynamic console attach

Cargo.lock

@@ -618,7 +618,8 @@ dependencies = [
  "tracing",
  "tracing-error",
  "tracing-subscriber",
- "winapi",
+ "windows",
+ "windows-sys",
 ]
 
 [[package]]
@@ -1304,6 +1305,108 @@ version = "0.4.0"
 source = "registry+https://github.com/rust-lang/crates.io-index"
 checksum = "712e227841d057c1ee1cd2fb22fa7e5a5461ae8e48fa2ca79ec42cfc1931183f"
 
+[[package]]
+name = "windows"
+version = "0.61.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9babd3a767a4c1aef6900409f85f5d53ce2544ccdfaa86dad48c91782c6d6893"
+dependencies = [
+ "windows-collections",
+ "windows-core",
+ "windows-future",
+ "windows-link",
+ "windows-numerics",
+]
+
+[[package]]
+name = "windows-collections"
+version = "0.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "3beeceb5e5cfd9eb1d76b381630e82c4241ccd0d27f1a39ed41b2760b255c5e8"
+dependencies = [
+ "windows-core",
+]
+
+[[package]]
+name = "windows-core"
+version = "0.61.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "c0fdd3ddb90610c7638aa2b3a3ab2904fb9e5cdbecc643ddb3647212781c4ae3"
+dependencies = [
+ "windows-implement",
+ "windows-interface",
+ "windows-link",
+ "windows-result",
+ "windows-strings",
+]
+
+[[package]]
+name = "windows-future"
+version = "0.2.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "fc6a41e98427b19fe4b73c550f060b59fa592d7d686537eebf9385621bfbad8e"
+dependencies = [
+ "windows-core",
+ "windows-link",
+ "windows-threading",
+]
+
+[[package]]
+name = "windows-implement"
+version = "0.60.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "a47fddd13af08290e67f4acabf4b459f647552718f683a7b415d290ac744a836"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "windows-interface"
+version = "0.59.1"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "bd9211b69f8dcdfa817bfd14bf1c97c9188afa36f4750130fcdf3f400eca9fa8"
+dependencies = [
+ "proc-macro2",
+ "quote",
+ "syn",
+]
+
+[[package]]
+name = "windows-link"
+version = "0.1.3"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "5e6ad25900d524eaabdbbb96d20b4311e1e7ae1699af4fb28c17ae66c80d798a"
+
+[[package]]
+name = "windows-numerics"
+version = "0.2.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "9150af68066c4c5c07ddc0ce30421554771e528bde427614c61038bc2c92c2b1"
+dependencies = [
+ "windows-core",
+ "windows-link",
+]
+
+[[package]]
+name = "windows-result"
+version = "0.3.4"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "56f42bd332cc6c8eac5af113fc0c1fd6a8fd2aa08a0119358686e5160d0586c6"
+dependencies = [
+ "windows-link",
+]
+
+[[package]]
+name = "windows-strings"
+version = "0.4.2"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "56e6c93f3a0c3b36176cb1327a4958a0353d5d166c2a35cb268ace15e91d3b57"
+dependencies = [
+ "windows-link",
+]
+
 [[package]]
 name = "windows-sys"
 version = "0.60.2"
@@ -1345,6 +1448,15 @@ dependencies = [
  "windows_x86_64_msvc 0.53.0",
 ]
 
+[[package]]
+name = "windows-threading"
+version = "0.1.0"
+source = "registry+https://github.com/rust-lang/crates.io-index"
+checksum = "b66463ad2e0ea3bbf808b7f1d371311c80e115c0b71d60efc142cafbcfb057a6"
+dependencies = [
+ "windows-link",
+]
+
 [[package]]
 name = "windows_aarch64_gnullvm"
 version = "0.52.6"

Cargo.toml

@@ -35,9 +35,12 @@ lto = true
 panic = "abort"
 opt-level = "z"
 
-[target.'cfg(target_os = "windows")'.dependencies.winapi]
-version = "0.3"
-features = ["consoleapi", "fileapi", "handleapi", "processenv", "winbase", "wincon", "winnt", "winuser", "windef", "minwindef"]
+[target.'cfg(target_os = "windows")'.dependencies]
+windows = { version = "0.61.3", features = ["Win32_Security", "Win32_Storage_FileSystem", "Win32_System_Console"] }
+windows-sys = { version = "0.60.2", features = ["Win32_System_Console"] }
+
+[target.'cfg(not(target_os = "windows"))'.dependencies]
+libc = "0.2"
 
 
 [target.'cfg(target_os = "emscripten")'.dependencies.sdl2]

src/app.rs

@@ -25,8 +25,8 @@ pub struct App {
 impl App {
     /// Initializes SDL subsystems, creates the game window, and sets up the game state.
     ///
-    /// Performs comprehensive initialization including video/audio subsystems, platform-specific
-    /// console setup, window creation with proper scaling, and canvas configuration. All SDL
+    /// Performs comprehensive initialization including video/audio subsystems,
+    /// window creation with proper scaling, and canvas configuration. All SDL
     /// resources are leaked to maintain 'static lifetimes required by the game architecture.
     ///
     /// # Errors
@@ -44,9 +44,6 @@ impl App {
         let event_pump: &'static mut EventPump =
             Box::leak(Box::new(sdl_context.event_pump().map_err(|e| GameError::Sdl(e.to_string()))?));
 
-        // Initialize platform-specific console
-        get_platform().init_console()?;
-
         let window = video_subsystem
             .window(
                 "Pac-Man",
@@ -96,31 +93,6 @@ impl App {
         {
             let start = Instant::now();
 
-            // for event in self
-            //     .game
-            //     .world
-            //     .get_non_send_resource_mut::<&'static mut EventPump>()
-            //     .unwrap()
-            //     .poll_iter()
-            // {
-            //     match event {
-            //         Event::Window { win_event, .. } => match win_event {
-            //             WindowEvent::FocusGained => {
-            //                 self.focused = true;
-            //             }
-            //             WindowEvent::FocusLost => {
-            //                 self.focused = false;
-            //             }
-            //             _ => {}
-            //         },
-            //         Event::MouseMotion { x, y, .. } => {
-            //             // Convert window coordinates to logical coordinates
-            //             self.cursor_pos = Vec2::new(x as f32, y as f32);
-            //         }
-            //         _ => {}
-            //     }
-            // }
-
             let dt = self.last_tick.elapsed().as_secs_f32();
             self.last_tick = Instant::now();
 

src/constants.rs

@@ -49,6 +49,26 @@ pub const CANVAS_SIZE: UVec2 = UVec2::new(
     (BOARD_CELL_SIZE.y + BOARD_CELL_OFFSET.y) * CELL_SIZE,
 );
 
+/// Collider size constants for different entity types
+pub mod collider {
+    use super::CELL_SIZE;
+
+    /// Collider size for player and ghosts (1.375x cell size)
+    pub const PLAYER_GHOST_SIZE: f32 = CELL_SIZE as f32 * 1.375;
+    /// Collider size for pellets (0.4x cell size)
+    pub const PELLET_SIZE: f32 = CELL_SIZE as f32 * 0.4;
+    /// Collider size for power pellets/energizers (0.95x cell size)
+    pub const POWER_PELLET_SIZE: f32 = CELL_SIZE as f32 * 0.95;
+}
+
+/// UI and rendering constants
+pub mod ui {
+    /// Debug font size in points
+    pub const DEBUG_FONT_SIZE: u16 = 12;
+    /// Power pellet blink rate in seconds
+    pub const POWER_PELLET_BLINK_RATE: f32 = 0.2;
+}
+
 /// Map tile types that define gameplay behavior and collision properties.
 #[derive(Debug, Clone, Copy, PartialEq)]
 pub enum MapTile {
@@ -100,3 +120,17 @@ pub const RAW_BOARD: [&str; BOARD_CELL_SIZE.y as usize] = [
     "#..........................#",
     "############################",
 ];
+
+/// Game initialization constants
+pub mod startup {
+    /// Number of frames for the startup sequence (3 seconds at 60 FPS)
+    pub const STARTUP_FRAMES: u32 = 60 * 3;
+    /// Number of ticks per frame during startup
+    pub const STARTUP_TICKS_PER_FRAME: u32 = 60;
+}
+
+/// Game mechanics constants
+pub mod mechanics {
+    /// Player movement speed multiplier
+    pub const PLAYER_SPEED: f32 = 1.15;
+}

src/game.rs

@@ -110,7 +110,7 @@ impl Game {
         let static_font_data: &'static [u8] = Box::leak(font_data.to_vec().into_boxed_slice());
         let font_asset = RWops::from_bytes(static_font_data).map_err(|_| GameError::Sdl("Failed to load font".to_string()))?;
         let debug_font = ttf_context
-            .load_font_from_rwops(font_asset, 12)
+            .load_font_from_rwops(font_asset, constants::ui::DEBUG_FONT_SIZE)
             .map_err(|e| GameError::Sdl(e.to_string()))?;
 
         // Initialize audio system
@@ -213,7 +213,7 @@ impl Game {
                 node: map.start_positions.pacman,
             },
             velocity: Velocity {
-                speed: 1.15,
+                speed: constants::mechanics::PLAYER_SPEED,
                 direction: Direction::Left,
             },
             movement_modifiers: MovementModifiers::default(),
@@ -226,7 +226,7 @@ impl Game {
             directional_animation: DirectionalAnimation::new(moving_tiles, stopped_tiles, 5),
             entity_type: EntityType::Player,
             collider: Collider {
-                size: constants::CELL_SIZE as f32 * 1.375,
+                size: constants::collider::PLAYER_GHOST_SIZE,
             },
             pacman_collider: PacmanCollider,
         };
@@ -249,7 +249,10 @@ impl Game {
         world.insert_resource(DebugState::default());
         world.insert_resource(AudioState::default());
         world.insert_resource(CursorPosition::default());
-        world.insert_resource(StartupSequence::new(60 * 3, 60));
+        world.insert_resource(StartupSequence::new(
+            constants::startup::STARTUP_FRAMES,
+            constants::startup::STARTUP_TICKS_PER_FRAME,
+        ));
 
         world.insert_non_send_resource(atlas);
         world.insert_non_send_resource(event_pump);
@@ -337,12 +340,12 @@ impl Game {
             .resource::<Map>()
             .iter_nodes()
             .filter_map(|(id, tile)| match tile {
-                MapTile::Pellet => Some((*id, EntityType::Pellet, pellet_sprite, constants::CELL_SIZE as f32 * 0.4)),
+                MapTile::Pellet => Some((*id, EntityType::Pellet, pellet_sprite, constants::collider::PELLET_SIZE)),
                 MapTile::PowerPellet => Some((
                     *id,
                     EntityType::PowerPellet,
                     energizer_sprite,
-                    constants::CELL_SIZE as f32 * 0.95,
+                    constants::collider::POWER_PELLET_SIZE,
                 )),
                 _ => None,
             })
@@ -360,7 +363,7 @@ impl Game {
 
             // Make power pellets blink
             if item_type == EntityType::PowerPellet {
-                item.insert((Frozen, Blinking::new(0.2)));
+                item.insert((Frozen, Blinking::new(constants::ui::POWER_PELLET_BLINK_RATE)));
             }
         }
 
@@ -412,7 +415,7 @@ impl Game {
                     directional_animation: animations,
                     entity_type: EntityType::Ghost,
                     collider: Collider {
-                        size: constants::CELL_SIZE as f32 * 1.375,
+                        size: constants::collider::PLAYER_GHOST_SIZE,
                     },
                     ghost_collider: GhostCollider,
                     ghost_state: GhostState::Normal,

src/main.rs

@@ -1,9 +1,8 @@
+// Note: This disables the console window on Windows. We manually re-attach to the parent terminal or process later on.
 #![windows_subsystem = "windows"]
 
 use crate::{app::App, constants::LOOP_TIME};
 use tracing::info;
-use tracing_error::ErrorLayer;
-use tracing_subscriber::layer::SubscriberExt;
 
 mod app;
 mod asset;
@@ -23,14 +22,22 @@ mod texture;
 /// This function initializes SDL, the window, the game state, and then enters
 /// the main game loop.
 pub fn main() {
-    // Setup tracing
-    let subscriber = tracing_subscriber::fmt()
-        .with_ansi(cfg!(not(target_os = "emscripten")))
-        .with_max_level(tracing::Level::DEBUG)
-        .finish()
-        .with(ErrorLayer::default());
+    // Setup buffered tracing subscriber that will buffer logs until console is ready
+    let switchable_writer = platform::tracing_buffer::setup_switchable_subscriber();
 
-    tracing::subscriber::set_global_default(subscriber).expect("Could not set global default");
+    // Log early to show buffering is working
+    tracing::debug!("Tracing subscriber initialized with buffering - logs will be buffered until console is ready");
+
+    // Initialize platform-specific console
+    tracing::debug!("Starting console initialization...");
+    platform::get_platform().init_console().expect("Could not initialize console");
+    tracing::debug!("Console initialization completed");
+
+    // Now that console is initialized, flush buffered logs and switch to direct output
+    tracing::debug!("Switching to direct logging mode and flushing buffer...");
+    if let Err(e) = switchable_writer.switch_to_direct_mode() {
+        tracing::warn!("Failed to flush buffered logs to console: {}", e);
+    }
 
     let mut app = App::new().expect("Could not create app");
 

src/platform/buffered_writer.rs

@@ -0,0 +1,55 @@
+//! Buffered writer for tracing logs that can store logs before console attachment.
+
+use parking_lot::Mutex;
+use std::io::{self, Write};
+use std::sync::Arc;
+
+/// A thread-safe buffered writer that stores logs in memory until flushed.
+#[derive(Clone)]
+pub struct BufferedWriter {
+    buffer: Arc<Mutex<Vec<u8>>>,
+}
+
+impl BufferedWriter {
+    /// Creates a new buffered writer.
+    pub fn new() -> Self {
+        Self {
+            buffer: Arc::new(Mutex::new(Vec::new())),
+        }
+    }
+
+    /// Flushes all buffered content to the provided writer and clears the buffer.
+    pub fn flush_to<W: Write>(&self, mut writer: W) -> io::Result<()> {
+        let mut buffer = self.buffer.lock();
+        if !buffer.is_empty() {
+            writer.write_all(&buffer)?;
+            writer.flush()?;
+            buffer.clear();
+        }
+        Ok(())
+    }
+
+    /// Returns the current buffer size in bytes.
+    pub fn buffer_size(&self) -> usize {
+        self.buffer.lock().len()
+    }
+}
+
+impl Write for BufferedWriter {
+    fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
+        let mut buffer = self.buffer.lock();
+        buffer.extend_from_slice(buf);
+        Ok(buf.len())
+    }
+
+    fn flush(&mut self) -> io::Result<()> {
+        // For buffered writer, flush is a no-op since we're storing in memory
+        Ok(())
+    }
+}
+
+impl Default for BufferedWriter {
+    fn default() -> Self {
+        Self::new()
+    }
+}

src/platform/desktop.rs

@@ -6,6 +6,7 @@ use std::time::Duration;
 use crate::asset::Asset;
 use crate::error::{AssetError, PlatformError};
 use crate::platform::CommonPlatform;
+use tracing::{debug, info, warn};
 
 /// Desktop platform implementation.
 pub struct Platform;
@@ -24,6 +25,29 @@ impl CommonPlatform for Platform {
     }
 
     fn init_console(&self) -> Result<(), PlatformError> {
+        #[cfg(windows)]
+        {
+            use windows::Win32::System::Console::GetConsoleWindow;
+
+            // Check if we already have a console window
+            if unsafe { !GetConsoleWindow().0.is_null() } {
+                debug!("Already have a console window");
+                return Ok(());
+            } else {
+                debug!("No existing console window found");
+            }
+
+            if let Some(file_type) = Self::is_output_setup()? {
+                debug!(r#type = file_type, "Existing output detected");
+            } else {
+                debug!("No existing output detected");
+
+                // Try to attach to parent console for direct cargo run
+                Self::attach_to_parent_console()?;
+                info!("Successfully attached to parent console");
+            }
+        }
+
         Ok(())
     }
 
@@ -42,3 +66,102 @@ impl CommonPlatform for Platform {
         }
     }
 }
+
+#[cfg(windows)]
+impl Platform {
+    /// Check if the output stream has been setup by a parent process
+    fn is_output_setup() -> Result<Option<&'static str>, PlatformError> {
+        use windows::Win32::Storage::FileSystem::{
+            GetFileType, FILE_TYPE_CHAR, FILE_TYPE_DISK, FILE_TYPE_PIPE, FILE_TYPE_REMOTE, FILE_TYPE_UNKNOWN,
+        };
+
+        use windows_sys::Win32::{
+            Foundation::INVALID_HANDLE_VALUE,
+            System::Console::{GetStdHandle, STD_OUTPUT_HANDLE},
+        };
+
+        // Get the process's standard output handle, check if it's invalid
+        let handle = match unsafe { GetStdHandle(STD_OUTPUT_HANDLE) } {
+            INVALID_HANDLE_VALUE => {
+                return Err(PlatformError::ConsoleInit("Invalid handle".to_string()));
+            }
+            handle => handle,
+        };
+
+        // Identify the file type of the handle
+        let (well_known, file_type) = match unsafe {
+            use windows::Win32::Foundation::HANDLE;
+            GetFileType(HANDLE(handle))
+        } {
+            FILE_TYPE_PIPE => (true, "pipe"),
+            FILE_TYPE_CHAR => (true, "char"),
+            FILE_TYPE_DISK => (true, "disk"),
+            FILE_TYPE_UNKNOWN => (false, "unknown"),
+            FILE_TYPE_REMOTE => (false, "remote"),
+            unexpected => {
+                warn!("Unexpected file type: {unexpected:?}");
+                (false, "unknown")
+            }
+        };
+
+        debug!("File type: {file_type:?}, well known: {well_known}");
+
+        // If it's anything recognizable and valid, assume that a parent process has setup an output stream
+        Ok(well_known.then(|| file_type))
+    }
+
+    /// Try to attach to parent console
+    fn attach_to_parent_console() -> Result<(), PlatformError> {
+        use windows::{
+            core::PCSTR,
+            Win32::{
+                Foundation::{GENERIC_READ, GENERIC_WRITE},
+                Storage::FileSystem::{CreateFileA, FILE_FLAGS_AND_ATTRIBUTES, FILE_SHARE_READ, FILE_SHARE_WRITE, OPEN_EXISTING},
+                System::Console::{
+                    AttachConsole, FreeConsole, SetStdHandle, ATTACH_PARENT_PROCESS, STD_ERROR_HANDLE, STD_OUTPUT_HANDLE,
+                },
+            },
+        };
+
+        // Attach the process to the parent's console
+        unsafe { AttachConsole(ATTACH_PARENT_PROCESS) }
+            .map_err(|e| PlatformError::ConsoleInit(format!("Failed to attach to parent console: {:?}", e)))?;
+
+        let handle = unsafe {
+            let pcstr = PCSTR::from_raw("CONOUT$\0".as_ptr());
+            CreateFileA::<PCSTR>(
+                pcstr,
+                (GENERIC_READ | GENERIC_WRITE).0,
+                FILE_SHARE_READ | FILE_SHARE_WRITE,
+                None,
+                OPEN_EXISTING,
+                FILE_FLAGS_AND_ATTRIBUTES(0),
+                None,
+            )
+        }
+        .map_err(|e| PlatformError::ConsoleInit(format!("Failed to create console handle: {:?}", e)))?;
+
+        // Set the console's output and then error handles
+        if let Some(handle_error) = unsafe { SetStdHandle(STD_OUTPUT_HANDLE, handle) }
+            .map_err(|e| PlatformError::ConsoleInit(format!("Failed to set console output handle: {:?}", e)))
+            .and_then(|_| {
+                unsafe { SetStdHandle(STD_ERROR_HANDLE, handle) }
+                    .map_err(|e| PlatformError::ConsoleInit(format!("Failed to set console error handle: {:?}", e)))
+            })
+            .err()
+        {
+            // If either set handle call fails, free the console
+            unsafe { FreeConsole() }
+                // Free the console if the SetStdHandle calls fail
+                .map_err(|free_error| {
+                    PlatformError::ConsoleInit(format!(
+                        "Failed to free console after SetStdHandle failed: {free_error:?} ({handle_error:?})"
+                    ))
+                })
+                // And then return the original error if the FreeConsole call succeeds
+                .and(Err(handle_error))?;
+        }
+
+        Ok(())
+    }
+}

src/platform/mod.rs

@@ -10,6 +10,8 @@ mod desktop;
 #[cfg(target_os = "emscripten")]
 mod emscripten;
 
+pub mod buffered_writer;
+pub mod tracing_buffer;
 /// Cross-platform abstraction layer providing unified APIs for platform-specific operations.
 pub trait CommonPlatform {
     /// Platform-specific sleep function (required due to Emscripten's non-standard sleep requirements).

src/platform/tracing_buffer.rs

@@ -0,0 +1,91 @@
+//! Buffered tracing setup for handling logs before console attachment.
+
+use crate::platform::buffered_writer::BufferedWriter;
+use std::io;
+use tracing::Level;
+use tracing_error::ErrorLayer;
+use tracing_subscriber::fmt::MakeWriter;
+use tracing_subscriber::layer::SubscriberExt;
+
+/// A writer that can switch between buffering and direct output.
+#[derive(Clone, Default)]
+pub struct SwitchableWriter {
+    buffered_writer: BufferedWriter,
+    direct_mode: std::sync::Arc<parking_lot::Mutex<bool>>,
+}
+
+impl SwitchableWriter {
+    pub fn switch_to_direct_mode(&self) -> io::Result<()> {
+        // Get buffer size before flushing for debug logging
+        let buffer_size = self.buffered_writer.buffer_size();
+
+        // First flush any buffered content
+        self.buffered_writer.flush_to(io::stdout())?;
+
+        // Switch to direct mode
+        *self.direct_mode.lock() = true;
+
+        // Log how much was buffered (this will now go directly to stdout)
+        tracing::debug!("Flushed {} bytes of buffered logs to console", buffer_size);
+
+        Ok(())
+    }
+}
+
+impl io::Write for SwitchableWriter {
+    fn write(&mut self, buf: &[u8]) -> io::Result<usize> {
+        if *self.direct_mode.lock() {
+            io::stdout().write(buf)
+        } else {
+            self.buffered_writer.clone().write(buf)
+        }
+    }
+
+    fn flush(&mut self) -> io::Result<()> {
+        if *self.direct_mode.lock() {
+            io::stdout().flush()
+        } else {
+            // For buffered mode, flush is a no-op
+            Ok(())
+        }
+    }
+}
+
+/// A make writer that uses the switchable writer.
+#[derive(Clone)]
+pub struct SwitchableMakeWriter {
+    writer: SwitchableWriter,
+}
+
+impl SwitchableMakeWriter {
+    pub fn new(writer: SwitchableWriter) -> Self {
+        Self { writer }
+    }
+}
+
+impl<'a> MakeWriter<'a> for SwitchableMakeWriter {
+    type Writer = SwitchableWriter;
+
+    fn make_writer(&'a self) -> Self::Writer {
+        self.writer.clone()
+    }
+}
+
+/// Sets up a switchable tracing subscriber that can transition from buffered to direct output.
+///
+/// Returns the switchable writer that can be used to control the behavior.
+pub fn setup_switchable_subscriber() -> SwitchableWriter {
+    let switchable_writer = SwitchableWriter::default();
+    let make_writer = SwitchableMakeWriter::new(switchable_writer.clone());
+
+    let _subscriber = tracing_subscriber::fmt()
+        .with_ansi(cfg!(not(target_os = "emscripten")))
+        .with_max_level(Level::DEBUG)
+        .with_writer(make_writer)
+        .finish()
+        .with(ErrorLayer::default());
+
+    tracing::subscriber::set_global_default(_subscriber).expect("Could not set global default switchable subscriber");
+
+    switchable_writer
+}

src/systems/item.rs

@@ -60,9 +60,11 @@ pub fn item_system(
                         // Convert seconds to frames (assumes 60 FPS)
                         let total_ticks = 60 * 5; // 5 seconds total
 
-                        // Set all ghosts to frightened state
+                        // Set all ghosts to frightened state, except those in Eyes state
                         for mut ghost_state in ghost_query.iter_mut() {
-                            *ghost_state = GhostState::new_frightened(total_ticks, FRIGHTENED_FLASH_START_TICKS);
+                            if !matches!(*ghost_state, GhostState::Eyes) {
+                                *ghost_state = GhostState::new_frightened(total_ticks, FRIGHTENED_FLASH_START_TICKS);
+                            }
                         }
                     }
                 }

tests/item.rs

@@ -4,8 +4,8 @@ use pacman::{
     events::GameEvent,
     map::builder::Map,
     systems::{
-        is_valid_item_collision, item_system, AudioEvent, AudioState, EntityType, ItemCollider, PacmanCollider, Position,
-        ScoreResource,
+        is_valid_item_collision, item_system, AudioEvent, AudioState, EntityType, Ghost, GhostCollider, GhostState, ItemCollider,
+        PacmanCollider, Position, ScoreResource,
     },
 };
 
@@ -75,6 +75,18 @@ fn spawn_test_item(world: &mut World, item_type: EntityType) -> Entity {
     world.spawn((Position::Stopped { node: 1 }, item_type, ItemCollider)).id()
 }
 
+fn spawn_test_ghost(world: &mut World, ghost_state: GhostState) -> Entity {
+    world
+        .spawn((
+            Position::Stopped { node: 2 },
+            Ghost::Blinky,
+            EntityType::Ghost,
+            GhostCollider,
+            ghost_state,
+        ))
+        .id()
+}
+
 fn send_collision_event(world: &mut World, entity1: Entity, entity2: Entity) {
     let mut events = world.resource_mut::<Events<GameEvent>>();
     events.send(GameEvent::Collision(entity1, entity2));
@@ -251,3 +263,40 @@ fn test_item_system_preserves_existing_score() {
     let score = world.resource::<ScoreResource>();
     assert_eq!(score.0, 110);
 }
+
+#[test]
+fn test_power_pellet_does_not_affect_ghosts_in_eyes_state() {
+    let mut world = create_test_world();
+    let pacman = spawn_test_pacman(&mut world);
+    let power_pellet = spawn_test_item(&mut world, EntityType::PowerPellet);
+
+    // Spawn a ghost in Eyes state (returning to ghost house)
+    let eyes_ghost = spawn_test_ghost(&mut world, GhostState::Eyes);
+
+    // Spawn a ghost in Normal state
+    let normal_ghost = spawn_test_ghost(&mut world, GhostState::Normal);
+
+    send_collision_event(&mut world, pacman, power_pellet);
+
+    world.run_system_once(item_system).expect("System should run successfully");
+
+    // Check that the power pellet was collected and score updated
+    let score = world.resource::<ScoreResource>();
+    assert_eq!(score.0, 50);
+
+    // Check that the power pellet was despawned
+    let power_pellet_count = world
+        .query::<&EntityType>()
+        .iter(&world)
+        .filter(|&entity_type| matches!(entity_type, EntityType::PowerPellet))
+        .count();
+    assert_eq!(power_pellet_count, 0);
+
+    // Check that the Eyes ghost state was not changed
+    let eyes_ghost_state = world.entity(eyes_ghost).get::<GhostState>().unwrap();
+    assert!(matches!(*eyes_ghost_state, GhostState::Eyes));
+
+    // Check that the Normal ghost state was changed to Frightened
+    let normal_ghost_state = world.entity(normal_ghost).get::<GhostState>().unwrap();
+    assert!(matches!(*normal_ghost_state, GhostState::Frightened { .. }));
+}

tests/tracing_buffer.rs

@@ -0,0 +1,19 @@
+use pacman::platform::tracing_buffer::SwitchableWriter;
+use std::io::Write;
+
+#[test]
+fn test_switchable_writer_buffering() {
+    let mut writer = SwitchableWriter::default();
+
+    // Write some data while in buffered mode
+    writer.write_all(b"Hello, ").unwrap();
+    writer.write_all(b"world!").unwrap();
+    writer.write_all(b"This is buffered content.\n").unwrap();
+
+    // Switch to direct mode (this should flush to stdout and show buffer size)
+    // In a real test we can't easily capture stdout, so we'll just verify it doesn't panic
+    writer.switch_to_direct_mode().unwrap();
+
+    // Write more data in direct mode
+    writer.write_all(b"Direct output after flush\n").unwrap();
+}