jobs: add further job options

novem/cli/__init__.py

@@ -21,12 +21,11 @@
 from ..api_ref import NovemAPI
 from ..utils import cl, colors, get_config_path, get_current_config
 from ..version import __version__
-from .common import grid, mail, plot
+from .common import grid, job, mail, plot
 from .config import check_if_profile_exists, update_config
 from .group import group
 from .invite import invite
 from .setup import setup
-from .vis import list_jobs
 
 sys.tracebacklimit = 0
 
@@ -416,9 +415,7 @@ def run_cli_wrapped() -> None:
     elif args and args["grid"] != "":
         grid(args)
     elif args and args["job"] != "":
-        # Job listing only (no individual job operations yet)
-        if args["job"] is None:
-            list_jobs(args)
+        job(args)
     elif args and args["invite"] != "":
         invite(args)
     elif args and ("group" in args or "org" in args):

novem/cli/common.py

@@ -2,11 +2,11 @@
 import sys
 from typing import Any, Dict, Literal, Optional
 
-from novem import Grid, Mail, Plot
+from novem import Grid, Job, Mail, Plot
 from novem.api_ref import Novem404, NovemAPI
 from novem.cli.editor import edit
 from novem.cli.setup import Share
-from novem.cli.vis import list_vis, list_vis_shares
+from novem.cli.vis import list_job_shares, list_jobs, list_vis, list_vis_shares
 from novem.utils import data_on_stdin
 from novem.vis import NovemVisAPI
 
@@ -260,3 +260,136 @@ def grid(args: Dict[str, Any]) -> None:
 def plot(args: Dict[str, Any]) -> None:
     plot = VisBase("plot")
     plot(args)
+
+
+def job(args: Dict[str, Any]) -> None:
+    name = args["job"]
+
+    # List all jobs
+    if name is None:
+        list_jobs(args)
+        return
+
+    # Delete job
+    if args["delete"]:
+        novem = NovemAPI(**args, is_cli=True)
+        try:
+            novem.delete(f"jobs/{name}")
+            return
+        except Novem404:
+            print(f"Job {name} did not exist")
+            sys.exit(1)
+
+    # Create Job object
+    ignore_ssl = False
+    if "ignore_ssl" in args:
+        ignore_ssl = args["ignore_ssl"]
+
+    create = args["create"]
+
+    j = Job(
+        name,
+        ignore_ssl=ignore_ssl,
+        create=create,
+        config_path=args["config_path"],
+        qpr=args.get("qpr"),
+        debug=args.get("debug"),
+        config_profile=args["profile"],
+        is_cli=True,
+    )
+
+    # -R (run): trigger job execution
+    if args.get("run_job"):
+        j.run()
+        return
+
+    # --dump: dump entire API tree to file
+    if "dump" in args and args["dump"]:
+        path = args["dump"]
+        print(f'Dumping api tree structure to "{path}"')
+        j.api_dump(outpath=path)
+        return
+
+    # --tree: print API tree structure
+    if "tree" in args and args["tree"] != -1:
+        path = args["tree"]
+        if not path:
+            path = "/"
+        ts = j.api_tree(colors=True, relpath=path)
+        print(ts)
+        return
+
+    # -e (edit): edit a path in the editor
+    if "edit" in args and args["edit"]:
+        path = args["edit"]
+
+        # fetch target
+        ctnt = j.api_read(f"/{path}")
+
+        # get new content
+        nctnt = edit(contents=ctnt, use_tty=True)
+
+        if ctnt != nctnt:
+            # update content
+            j.api_write(f"/{path}", nctnt)
+
+    else:
+        # --type
+        ptype = args["type"]
+        if ptype:
+            j.type = ptype
+
+        found_stdin = False
+        stdin_data = data_on_stdin()
+        stdin_has_data = bool(stdin_data)
+
+        # check if we have any explicit inputs [-w's]
+        if args["input"] and len(args["input"]):
+            for i in args["input"]:
+                path = f"/{i[0]}"
+
+                if len(i) == 1:
+                    if stdin_has_data and not found_stdin:
+                        assert stdin_data
+                        ctnt = stdin_data
+
+                        j.api_write(path, ctnt)
+                        found_stdin = True
+                    elif found_stdin:
+                        print("stdin can only be sent to a single destination per invocation")
+                        sys.exit(1)
+                    else:
+                        print(f'No data found on stdin, "-w {path}" requires data to be supplied on stdin')
+                        sys.exit(1)
+
+                elif len(i) == 2 and i[1][0] == "@":
+                    fn = os.path.expanduser(i[1][1:])
+                    try:
+                        with open(fn, "r") as f:
+                            ctnt = f.read()
+                            j.api_write(path, ctnt)
+                    except FileNotFoundError:
+                        print(f'The supplied input file "{fn}" does not exist. Please review your options')
+                        sys.exit(1)
+
+                else:
+                    ctnt = i[1]
+                    j.api_write(path, ctnt)
+
+    # -s (share): manage shares
+    share_op, share_target = args["share"]
+    if share_op is Share.CREATE:
+        j.shared += share_target  # type: ignore
+
+    if share_op is Share.DELETE:
+        j.shared -= share_target  # type: ignore
+
+    if share_op is Share.LIST:
+        list_job_shares(name, args)
+        return
+
+    # -r (read output)
+    out = args["out"]
+    if out:
+        outp = j.api_read(f"/{out}")
+        print(outp, end="")

novem/cli/setup.py

@@ -422,6 +422,13 @@ def setup(raw_args: Any = None) -> Tuple[Any, Dict[str, str]]:
         help="select job to operate on, no parameter will list all your jobs",
     )
 
+    job.add_argument(
+        "-R",
+        dest="run_job",
+        action="store_true",
+        help="run the job",
+    )
+
     invite = parser.add_argument_group("invite")
 
     invite.add_argument(

novem/cli/vis.py

@@ -275,6 +275,30 @@ def list_vis_shares(vis_name: str, args: Dict[str, str], type: str) -> None:
     return
 
 
+def list_job_shares(job_name: str, args: Dict[str, str]) -> None:
+
+    novem = NovemAPI(**args, is_cli=True)
+
+    (config_status, config) = get_current_config(**args)
+
+    plist = []
+
+    try:
+        plist = json.loads(novem.read(f"jobs/{job_name}/shared"))
+    except Novem404:
+        plist = []
+
+    if args["list"]:
+        # print to terminal
+        for p in plist:
+            print(p["name"])
+    else:
+        striped: bool = config.get("cli_striped", False)
+        share_pretty_print(plist, striped=striped)
+
+    return
+
+
 def list_jobs(args: Dict[str, Any]) -> None:
     """List jobs with custom formatting."""
     colors()
@@ -397,6 +421,12 @@ def fav_fmt(markers: str, cl: cl) -> str:
             "clr": cl.OKCYAN,
             "overflow": "keep",
         },
+        {
+            "key": "name",
+            "header": "Name",
+            "type": "text",
+            "overflow": "truncate",
+        },
         {
             "key": "last_run_status",
             "header": "Status",
@@ -439,6 +469,12 @@ def fav_fmt(markers: str, cl: cl) -> str:
             "overflow": "keep",
             "align": "right",
         },
+        {
+            "key": "summary",
+            "header": "Summary",
+            "type": "text",
+            "overflow": "truncate",
+        },
     ]
 
     # Pre-process columns that need string conversion