Always on top feature

komorebi/src/core/mod.rs

@@ -60,6 +60,8 @@ pub enum SocketMessage {
     FocusStackWindow(usize),
     StackAll,
     UnstackAll,
+    FocusExe(Option<String>, Option<isize>),
+    DisplayMonitorWorkspaceNumber(usize, usize),
     ResizeWindowEdge(OperationDirection, Sizing),
     ResizeWindowAxis(Axis, Sizing),
     MoveContainerToMonitorNumber(usize),
@@ -87,6 +89,7 @@ pub enum SocketMessage {
     ToggleFloat,
     ToggleMonocle,
     ToggleMaximize,
+    ToggleAlwaysOnTop,
     ToggleWindowContainerBehaviour,
     ToggleFloatOverride,
     WindowHidingBehaviour(HidingBehaviour),

komorebi/src/process_command.rs

@@ -230,6 +230,14 @@ impl WindowManager {
                 self.focus_container_in_direction(direction)?;
                 self.promote_container_to_front()?
             }
+            SocketMessage::DisplayMonitorWorkspaceNumber(monitor_idx, workspace_idx) => {
+                self.send_always_on_top(
+                    Option::from(monitor_idx),
+                    Option::from(workspace_idx),
+                    None,
+                )?;
+                self.display_monitor_workspace(monitor_idx, workspace_idx)?;
+            }
             SocketMessage::EagerFocus(ref exe) => {
                 let focused_monitor_idx = self.focused_monitor_idx();
                 let focused_workspace_idx = self.focused_workspace_idx()?;
@@ -300,6 +308,9 @@ impl WindowManager {
                     }
                 }
             }
+            SocketMessage::FocusExe(ref exe, hwnd) => {
+                self.focus_window_from_exe(exe, hwnd)?;
+            }
             SocketMessage::MoveWindow(direction) => {
                 let focused_workspace = self.focused_workspace()?;
                 match focused_workspace.layer() {
@@ -360,6 +371,7 @@ impl WindowManager {
             SocketMessage::ToggleFloat => self.toggle_float()?,
             SocketMessage::ToggleMonocle => self.toggle_monocle()?,
             SocketMessage::ToggleMaximize => self.toggle_maximize()?,
+            SocketMessage::ToggleAlwaysOnTop => self.toggle_always_on_top()?,
             SocketMessage::ContainerPadding(monitor_idx, workspace_idx, size) => {
                 self.set_container_padding(monitor_idx, workspace_idx, size)?;
             }
@@ -604,6 +616,7 @@ impl WindowManager {
             }
             SocketMessage::MoveContainerToWorkspaceNumber(workspace_idx) => {
                 self.move_container_to_workspace(workspace_idx, true, None)?;
+                self.send_always_on_top(None, Some(workspace_idx), Some(true))?;
             }
             SocketMessage::CycleMoveContainerToWorkspace(direction) => {
                 let focused_monitor = self
@@ -620,8 +633,10 @@ impl WindowManager {
                 );
 
                 self.move_container_to_workspace(workspace_idx, true, None)?;
+                self.send_always_on_top(None, Some(workspace_idx), Some(true))?;
             }
             SocketMessage::MoveContainerToMonitorNumber(monitor_idx) => {
+                self.send_always_on_top(Some(monitor_idx), None, Some(true))?;
                 let direction = self.direction_from_monitor_idx(monitor_idx);
                 self.move_container_to_monitor(monitor_idx, None, true, direction)?;
             }
@@ -635,11 +650,14 @@ impl WindowManager {
                         .ok_or_else(|| anyhow!("there must be at least one monitor"))?,
                 );
 
+                self.send_always_on_top(Some(monitor_idx), None, Some(true))?;
+
                 let direction = self.direction_from_monitor_idx(monitor_idx);
                 self.move_container_to_monitor(monitor_idx, None, true, direction)?;
             }
             SocketMessage::SendContainerToWorkspaceNumber(workspace_idx) => {
                 self.move_container_to_workspace(workspace_idx, false, None)?;
+                self.send_always_on_top(None, Some(workspace_idx), Some(false))?;
             }
             SocketMessage::CycleSendContainerToWorkspace(direction) => {
                 let focused_monitor = self
@@ -656,8 +674,10 @@ impl WindowManager {
                 );
 
                 self.move_container_to_workspace(workspace_idx, false, None)?;
+                self.send_always_on_top(None, Some(workspace_idx), Some(false))?;
             }
             SocketMessage::SendContainerToMonitorNumber(monitor_idx) => {
+                self.send_always_on_top(Some(monitor_idx), None, Some(false))?;
                 let direction = self.direction_from_monitor_idx(monitor_idx);
                 self.move_container_to_monitor(monitor_idx, None, false, direction)?;
             }
@@ -668,10 +688,13 @@ impl WindowManager {
                         .ok_or_else(|| anyhow!("there must be at least one monitor"))?,
                 );
 
+                self.send_always_on_top(Some(monitor_idx), None, Some(false))?;
+
                 let direction = self.direction_from_monitor_idx(monitor_idx);
                 self.move_container_to_monitor(monitor_idx, None, false, direction)?;
             }
             SocketMessage::SendContainerToMonitorWorkspaceNumber(monitor_idx, workspace_idx) => {
+                self.send_always_on_top(Some(monitor_idx), Some(workspace_idx), Some(false))?;
                 let direction = self.direction_from_monitor_idx(monitor_idx);
                 self.move_container_to_monitor(
                     monitor_idx,
@@ -681,6 +704,7 @@ impl WindowManager {
                 )?;
             }
             SocketMessage::MoveContainerToMonitorWorkspaceNumber(monitor_idx, workspace_idx) => {
+                self.send_always_on_top(Some(monitor_idx), Some(workspace_idx), Some(true))?;
                 let direction = self.direction_from_monitor_idx(monitor_idx);
                 self.move_container_to_monitor(
                     monitor_idx,
@@ -693,6 +717,7 @@ impl WindowManager {
                 if let Some((monitor_idx, workspace_idx)) =
                     self.monitor_workspace_index_by_name(workspace)
                 {
+                    self.send_always_on_top(Some(monitor_idx), Some(workspace_idx), Some(false))?;
                     let direction = self.direction_from_monitor_idx(monitor_idx);
                     self.move_container_to_monitor(
                         monitor_idx,
@@ -706,6 +731,7 @@ impl WindowManager {
                 if let Some((monitor_idx, workspace_idx)) =
                     self.monitor_workspace_index_by_name(workspace)
                 {
+                    self.send_always_on_top(Some(monitor_idx), Some(workspace_idx), Some(true))?;
                     let direction = self.direction_from_monitor_idx(monitor_idx);
                     self.move_container_to_monitor(
                         monitor_idx,
@@ -897,6 +923,8 @@ impl WindowManager {
                         .ok_or_else(|| anyhow!("there must be at least one workspace"))?,
                 );
 
+                self.send_always_on_top(None, Option::from(workspace_idx), None)?;
+
                 self.focus_workspace(workspace_idx)?;
             }
             SocketMessage::CycleFocusEmptyWorkspace(direction) => {
@@ -1015,6 +1043,7 @@ impl WindowManager {
 
                 if let Some(monitor) = self.focused_monitor_mut() {
                     if let Some(last_focused_workspace) = monitor.last_focused_workspace() {
+                        self.send_always_on_top(None, Option::from(last_focused_workspace), None)?;
                         self.focus_workspace(last_focused_workspace)?;
                     }
                 }
@@ -1040,6 +1069,7 @@ impl WindowManager {
                 }
 
                 if self.focused_workspace_idx().unwrap_or_default() != workspace_idx {
+                    self.send_always_on_top(None, Option::from(workspace_idx), None)?;
                     self.focus_workspace(workspace_idx)?;
                 }
             }
@@ -1061,13 +1091,28 @@ impl WindowManager {
 
                 let focused_monitor_idx = self.focused_monitor_idx();
 
+                for i in 0..self.monitors.elements().len() {
+                    if i != focused_monitor_idx {
+                        self.send_always_on_top(
+                            Option::from(i),
+                            Option::from(workspace_idx),
+                            None,
+                        )?;
+                    }
+                }
+
                 for (i, monitor) in self.monitors_mut().iter_mut().enumerate() {
                     if i != focused_monitor_idx {
                         monitor.focus_workspace(workspace_idx)?;
                         monitor.load_focused_workspace(false)?;
                     }
                 }
 
+                self.send_always_on_top(
+                    Option::from(focused_monitor_idx),
+                    Some(workspace_idx),
+                    None,
+                )?;
                 self.focus_workspace(workspace_idx)?;
             }
             SocketMessage::FocusMonitorWorkspaceNumber(monitor_idx, workspace_idx) => {
@@ -1077,6 +1122,7 @@ impl WindowManager {
                 let focused_pair = (focused_monitor_idx, focused_workspace_idx);
 
                 if focused_pair != (monitor_idx, workspace_idx) {
+                    self.send_always_on_top(Option::from(monitor_idx), Some(workspace_idx), None)?;
                     self.focus_monitor(monitor_idx)?;
                     self.focus_workspace(workspace_idx)?;
                 }
@@ -1085,6 +1131,7 @@ impl WindowManager {
                 if let Some((monitor_idx, workspace_idx)) =
                     self.monitor_workspace_index_by_name(name)
                 {
+                    self.send_always_on_top(Option::from(monitor_idx), Some(workspace_idx), None)?;
                     self.focus_monitor(monitor_idx)?;
                     self.focus_workspace(workspace_idx)?;
                 }

komorebi/src/process_event.rs

@@ -191,6 +191,13 @@ impl WindowManager {
 
                     already_moved_window_handles.remove(&window.hwnd);
                 }
+
+                if let Some(aot) = self.always_on_top.as_mut() {
+                    if aot.contains(&window.hwnd) {
+                        let idx = aot.iter().position(|x| *x == window.hwnd).unwrap();
+                        aot.remove(idx);
+                    }
+                }
             }
             WindowManagerEvent::Minimize(_, window) => {
                 let mut hide = false;
@@ -707,6 +714,7 @@ impl WindowManager {
             }
             WindowManagerEvent::MouseCapture(..)
             | WindowManagerEvent::Cloak(..)
+            | WindowManagerEvent::LocationChange(..)
             | WindowManagerEvent::TitleUpdate(..) => {}
         };
 
@@ -734,6 +742,7 @@ impl WindowManager {
         if !matches!(
             event,
             WindowManagerEvent::Show(WinEvent::ObjectNameChange, _)
+                | WindowManagerEvent::LocationChange(_, _)
         ) {
             tracing::info!("processed: {}", event.window().to_string());
         } else {

komorebi/src/static_config.rs

@@ -1156,6 +1156,7 @@ impl StaticConfig {
             already_moved_window_handles: Arc::new(Mutex::new(HashSet::new())),
             uncloack_to_ignore: 0,
             known_hwnds: HashMap::new(),
+            always_on_top: None,
         };
 
         match value.focus_follows_mouse {