goat_monitor/goat_monitor.py

@@ -34,13 +34,7 @@ from goat_monitor._version import __version__  # type: ignore
     default=False,
     help="Print version and exit",
 )
-@click.option(
+def wrap(command: List[str], config: Path, retries: int, version):
-    "--dry-run",
-    is_flag=True,
-    default=False,
-    help="Run command without sending any notifications",
-)
-def wrap(command: List[str], config: Path, retries: int, version: bool, dry_run: bool):
     """Wrap an arbitrary command with gotify notifications"""
 
     if version:
@@ -52,14 +46,13 @@ def wrap(command: List[str], config: Path, retries: int, version: bool, dry_run:
         settings = toml.load(f)
 
     # gotify configuration
-    if not dry_run:
+    url = settings["server"]
-        url = settings["server"]
+    app_token = settings["app_token"]
-        app_token = settings["app_token"]
+    with gotify.Gotify(base_url=url, app_token=app_token) as gotify_connection:
-        with gotify.Gotify(base_url=url, app_token=app_token) as gotify_connection:
+        # this is just to test configuration.
-            # this is just to test configuration.
+        # I don't know how long a gotify connection will stay up so rather than thinking about it
-            # I don't know how long a gotify connection will stay up so rather than thinking about it
+        # I'm just creating a new one whenever I need to send a message
-            # I'm just creating a new one whenever I need to send a message
+        pass
-            pass
 
     if retries == -1:
         retries = np.inf
@@ -69,25 +62,20 @@ def wrap(command: List[str], config: Path, retries: int, version: bool, dry_run:
     attempt = 0
     while attempt <= retries:
         # run the command
-        with subprocess.Popen(
+        result = subprocess.run(
             " ".join(command),
             shell=True,
             stderr=subprocess.STDOUT,
             stdout=subprocess.PIPE,
-        ) as proc:
+            encoding="utf-8",
-            stdout = ""
+        )
-            while True:
-                c = proc.stdout.read(1)
-                if c == b"":
-                    break
-                s = c.decode("utf-8")
-                stdout += s
-                print(s, end="", flush=True)
-            return_code = proc.wait()
 
-        if return_code:
+        # TODO: print lines real time as the subprocess runs
+        print(result.stdout, end="")
+
+        if result.returncode:
             # failed
-            title = f"Command failed with exit code {return_code}"
+            title = f"Command failed with exit code {result.returncode}"
             if attempt < retries:
                 title += f" - Retrying (attempt {attempt+1}/{retries})"
             else:
@@ -97,7 +85,7 @@ def wrap(command: List[str], config: Path, retries: int, version: bool, dry_run:
             title = "Command succeeded"
 
         MAX_LINES = 20
-        lines = stdout.splitlines()
+        lines = result.stdout.splitlines()
         if len(lines) > MAX_LINES:
             lines = lines[-MAX_LINES:]
         message = (
@@ -107,17 +95,16 @@ def wrap(command: List[str], config: Path, retries: int, version: bool, dry_run:
             + "\n".join(lines)
         )
 
-        if not dry_run:
+        with gotify.Gotify(base_url=url, app_token=app_token) as gotify_connection:
-            with gotify.Gotify(base_url=url, app_token=app_token) as gotify_connection:
+            gotify_connection.create_message(message=message, title=title)
-                gotify_connection.create_message(message=message, title=title)
 
-        if not return_code:
+        if not result.returncode:
             # only retry on failure
             break
 
         attempt += 1
 
-    sys.exit(return_code)
+    sys.exit(result.returncode)
 
 
 # %% main