fix(win): stabilize non-interactive execution and prevent CLI hangs

- Replace blocking stdin read in worker with timeout-bounded threaded read (5s safety limit)
- Harden safe_input() to avoid indefinite blocking on daemon/worker IO
- Add socket timeouts for dispatcher daemon connections to prevent hang on CLI routing
- Detect daemon logs follow mode (-f/--follow) to correctly mark interactive sessions on Windows and Linux
- Improve dispatcher interactivity detection logic for info/config/log-follow commands

This improves CLI reliability under non-interactive and daemon-routed execution paths,
preventing deadlocks during long-running or headless invocations.

Modified:
  • src/omnipkg/common_utils.py (+19/-3 lines)
  • src/omnipkg/dispatcher.c (+10/-1 lines)
  • src/omnipkg/dispatcher.py (+17/-1 lines)

[gitship-generated]

Author: 1minds3t

src/omnipkg/common_utils.py

@@ -747,10 +747,26 @@ def _worker_read_reply() -> dict:
     The daemon writes to worker.process.stdin (also text mode) after
     receiving the stdin_line from the C dispatcher.
     """
-    line = sys.stdin.readline()
-    if not line:
+    import threading
+    result = [None]
+    exc = [None]
+
+    def _read():
+        try:
+            result[0] = sys.stdin.readline()
+        except Exception as e:
+            exc[0] = e
+
+    t = threading.Thread(target=_read, daemon=True)
+    t.start()
+    t.join(5.0)
+    if t.is_alive():
+        raise TimeoutError("no stdin reply within 5s")
+    if exc[0]:
+        raise exc[0]
+    if not result[0]:
         raise EOFError("daemon closed stdin")
-    return json.loads(line.strip())
+    return json.loads(result[0].strip())
 
 
 def safe_input(prompt: str, default: str = "", auto_value: str = None) -> str:

src/omnipkg/dispatcher.c

@@ -2055,7 +2055,16 @@ int main(int argc, char **argv) {
          * that contain the word python (e.g. "info python-dotenv"). */
         int info_python = (is_info && argc >= 3 &&
                            strcmp(argv[2], "python") == 0);
-        is_interactive_command = ((is_info && !info_python) || is_config);
+        int is_logs_follow = 0;
+        if (argc >= 3 && strcmp(argv[1], "daemon") == 0 && strcmp(argv[2], "logs") == 0) {
+            for (int _i = 3; _i < argc; _i++) {
+                if (strcmp(argv[_i], "-f") == 0 || strcmp(argv[_i], "--follow") == 0) {
+                    is_logs_follow = 1;
+                    break;
+                }
+            }
+        }
+        is_interactive_command = ((is_info && !info_python) || is_config || is_logs_follow);
     }
     if (!is_swap_python && !is_interactive_command) {
         try_daemon_cli(target_python, argc, argv, version_injected, forced_version);

src/omnipkg/dispatcher.py

@@ -225,7 +225,21 @@ def main():
         and argv_commands[1] in ("start", "stop", "restart")
     )
 
-    if not is_swap_command and not is_daemon_lifecycle:
+    is_info_command = (
+        len(argv_commands) >= 1
+        and argv_commands[0] == "info"
+        and not (len(argv_commands) >= 2 and argv_commands[1] == "python")
+    )
+    is_config_command = len(argv_commands) >= 1 and argv_commands[0] == "config"
+    is_logs_follow = (
+        len(argv_commands) >= 2
+        and argv_commands[0] == "daemon"
+        and argv_commands[1] == "logs"
+        and "-f" in sys.argv
+    )
+    is_interactive_command = is_info_command or is_config_command or is_logs_follow
+
+    if not is_swap_command and not is_daemon_lifecycle and not is_interactive_command:
         try:
             import socket
             import tempfile
@@ -240,6 +254,7 @@ def main():
                         host, port = conn_str[6:].split(":")
                         sock = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
                         sock.connect((host, int(port)))
+                        sock.settimeout(300)
                     else:
                         raise ValueError()
                 else:
@@ -248,6 +263,7 @@ def main():
                 if os.path.exists(sock_path):
                     sock = socket.socket(socket.AF_UNIX, socket.SOCK_STREAM)
                     sock.connect(sock_path)
+                    sock.settimeout(300)
                 else:
                     raise ValueError()