v0.4.2

Author: jet-logic

runce/__init__.py

@@ -5,4 +5,4 @@
 Ensures each command runs exactly once per unique ID.
 """
 
-__version__ = "0.4.1"
+__version__ = "0.4.2"

runce/cli.py

@@ -202,6 +202,7 @@ class Run(Main):
     overwrite: bool = flag("overwrite", "Overwrite existing entry", default=False)
     cmd_after: str = flag("run-after", "Run command after", metavar="command")
     split: bool = flag("split", "Dont merge stdout and stderr", default=False)
+    input: str = flag("i", "input", "pass FILE to stdin", metavar="FILE", default="")
 
     def start(self) -> None:
         args = self.args
@@ -213,8 +214,9 @@ def start(self) -> None:
         if e:
             s = ["🚨", r"Found: PID={pid} ({pid_status}) {name}"]
         else:
+            
             # Start new process
-            e = sp.spawn(args, name, overwrite=self.overwrite, cwd=self.cwd, split=self.split)
+            e = sp.spawn(args, name, overwrite=self.overwrite, cwd=self.cwd, split=self.split, in_file=self.input)
             s = ["🚀", r"Started: PID={pid} ({pid_status}) {name}"]
         assert e
         try:
@@ -254,8 +256,8 @@ def start(self) -> None:
             pass
         else:
             f = "{pid_status} {elapsed} {pid}\t{name}, {command}"
-            print("Status  Elapsed  PID\tName, Command")
-            print("------- -------- ------ ------------")
+            print("Stat Elapsed  PID\tName, Command")
+            print("---- -------- ------ ------------")
         fp = format_prep(f)
         for d in Manager().all():
             print(fp(d))

runce/spawn.py

@@ -57,7 +57,12 @@ def spawn(
         mode = "w" if overwrite else "x"
 
         if in_file:
-            po_kwa["stdin"] = Path(in_file).open("rb")
+            if in_file == "-":
+                from sys import stdin
+
+                po_kwa["stdin"] = stdin.buffer
+            else:
+                po_kwa["stdin"] = Path(in_file).open("rb")
 
         if not cmd:
             cmd = ["sh"]
@@ -75,15 +80,6 @@ def spawn(
             so = se = Path(out_file) if out_file else data_dir / f"{base_name}.log"
             po_kwa["stdout"] = so.open(f"{mode}b")
             po_kwa["stderr"] = STDOUT
-        if po_kwa.get("stdin") is None:
-            from sys import stdin
-
-            try:
-                no = stdin.buffer.fileno()
-            except Exception as ex:
-                pass
-            else:
-                po_kwa["stdin"] = stdin.buffer
 
         po_kwa.setdefault("start_new_session", True)
         po_kwa.setdefault("close_fds", True)

runce/utils.py

@@ -37,18 +37,14 @@ def check_pid(pid: int) -> bool:
         finally:
             kernel32.CloseHandle(handle)
 
-    def kill_pid(
-        pid: int, sig: Optional[int] = None, process_group: Optional[bool] = None
-    ) -> bool:
+    def kill_pid(pid: int, sig: Optional[int] = None, process_group: Optional[bool] = None) -> bool:
         try:
             os.kill(pid, signal.SIGTERM if sig is None else sig)
         except PermissionError as e:
             if check_pid(pid) is False:
                 return False
         except OSError as e:
-            if 87 == getattr(
-                e, "winerror", 0
-            ):  # ERROR_INVALID_PARAMETER (no such process)
+            if 87 == getattr(e, "winerror", 0):  # ERROR_INVALID_PARAMETER (no such process)
                 return False
             raise
         return True
@@ -183,7 +179,7 @@ def tail_file(filename="", n=10):
 
 def filesizepu(s: str) -> tuple[int, str]:
     u = ""
-    if s[0].isnumeric():
+    if s[0].isnumeric() or s[0].startswith("."):
         q = s.lower()
         if q.endswith("b"):
             q, u = q[0:-1], q[-1]