version 0.2.9

Author: melezhik

Changes

@@ -2,6 +2,13 @@ Revision history for Sparky
 
 {{$NEXT}}
 
+0.2.9 2025-02-20T14:50:00Z
+
+  - Make sparman part of
+    Sparky distribution
+
+  - Comment some noisy logs
+
 0.2.8 2024-07-14T12:30:00Z
 
   - Migrate ci pipeline to Sparky

META6.json

@@ -42,5 +42,5 @@
   },
   "tags" : [ ],
   "test-depends" : [ ],
-  "version" : "0.2.8"
+  "version" : "0.2.9"
 }

bin/sparman.raku

@@ -0,0 +1,134 @@
+sub MAIN(
+  Str   $comp,
+  Str   $action,
+  Bool  :$verbose? = False,
+  Str   :$base?,
+  Str   :$env?,
+) {
+
+    say "Execute $action on $comp ...";
+
+    die "unknown component" unless $comp  ~~ /^^ (worker|worker_ui) $$/;
+
+    my $c = _get_conf();
+    my $vars = $env ?? $env.split(/","/).map({"export $_"}).join("\n") !! "";
+
+    if $comp eq "worker_ui" {
+      if ! $c<worker><base> and $action eq "start" {
+        say "worker ui base dir not found, tell me where to look it up:";
+        say "sparman.raku --base /path/to/basedir worker_ui conf";
+        exit(1)
+      }
+      if $action eq "start" {
+        my $cmd = q[
+          set -e
+          pid=$(ps uax|grep "raku bin/sparky-web.raku"|grep -v grep | awk '{ print $2 }')
+          if test -z $pid; then ] ~
+            qq[\ncd {$c<worker><base>}\n] ~
+            q[mkdir -p ~/.sparky ] ~
+            qq[\n$vars\n] ~
+            q[nohup raku bin/sparky-web.raku 1>~/.sparky/sparky-web.log 2>&1 < /dev/null &
+            echo "run [OK]"
+          else
+            echo "already running pid=$pid ..."
+          fi
+        ];          
+        say $cmd if $verbose;
+        shell $cmd;
+      } elsif $action eq "stop" {
+        my $cmd = q[
+          set -e
+          pid=$(ps uax|grep "raku bin/sparky-web.raku"|grep -v grep | awk '{ print $2 }')
+          if test -z $pid; then
+            echo "already stopped"
+          else
+            echo "kill $pid ..."
+            kill $pid
+            echo "stop [OK] | pid=$pid"
+          fi
+        ];
+        say $cmd if $verbose;
+        shell $cmd;
+      } elsif $action eq "conf" {
+        if $base {
+          $c<worker><base> = $base;
+          _update_conf($c);
+        }
+      } elsif $action eq "status" {
+        my $cmd = q[
+          set -e
+          pid=$(ps uax|grep "raku bin/sparky-web.raku"|grep -v grep | awk '{ print $2 }')
+          if test -z $pid; then
+            echo "stop [OK]"
+          else
+            echo "run [OK] | pid=$pid"
+          fi
+        ];
+        say $cmd if $verbose;
+        shell $cmd;
+      } else {
+        die "unknown action"
+      }
+    } 
+    if $comp eq "worker" {
+      if $action eq "start" {
+        my $cmd = q[
+          set -e
+          pid=$(ps uax|grep bin/sparkyd|grep rakudo|grep -v grep | awk '{ print $2 }')
+          if test -z $pid; then
+            mkdir -p ~/.sparky/] ~
+            qq[\n$vars\n] ~
+            q[nohup sparkyd 1>~/.sparky/sparkyd.log 2>&1 < /dev/null &
+            echo "run [OK]"
+          else
+            echo "already running pid=$pid ..."
+          fi
+        ];          
+        say $cmd if $verbose;
+        shell $cmd;
+      } elsif $action eq "stop" {
+        my $cmd = q[
+          set -e
+          pid=$(ps uax|grep bin/sparkyd|grep rakudo|grep -v grep | awk '{ print $2 }')
+          if test -z $pid; then
+            echo "already stopped"
+          else
+            echo "kill $pid ..."
+            kill $pid
+            echo "stop [OK] | pid=$pid"
+          fi
+        ];
+        say $cmd if $verbose;
+        shell $cmd;
+      } elsif $action eq "status" {
+        my $cmd = q[
+          set -e
+          pid=$(ps uax|grep bin/sparkyd|grep rakudo|grep -v grep | awk '{ print $2 }')
+          if test -z $pid; then
+            echo "stop [OK]"
+          else
+            echo "run [OK] | pid=$pid"
+          fi
+        ];
+        say $cmd if $verbose;
+        shell $cmd;
+      } else {
+        die "unknown action"
+      }
+    }
+
+}
+
+sub _get_conf {
+  if "{%*ENV<HOME>}/.sparky/conf.raku".IO ~~ :e {
+    EVALFILE "{%*ENV<HOME>}/.sparky/conf.raku"
+  } else {
+    return {}
+  }
+}
+
+sub _update_conf (%c) {
+  mkdir "{%*ENV<HOME>}/.sparky/";
+  say "update {%*ENV<HOME>}/.sparky/conf.raku ...";
+  "{%*ENV<HOME>}/.sparky/conf.raku".IO.spurt(%c.perl)
+}

docs/sparman.md

@@ -0,0 +1,49 @@
+# Sparman
+
+Sparman is a cli to run and configure Sparky components:
+
+- sparkyd (aka sparky worker)
+
+- web UI (aka sparky worker UI)
+
+# API
+
+## Sparky Worker
+
+Sparky worker is a background process performing all SparrowCI tasks execution
+
+```bash
+sparman.raku worker start
+sparman.raku worker stop
+sparman.raku worker status
+```
+
+## Sparky Worker UI
+
+Sparky worker UI allows to read worker reports and manage worker jobs. This
+is intended for SparrowCI operations people
+
+```bash
+sparman.raku worker_ui start
+sparman.raku worker_ui stop
+sparman.raku worker_ui status
+```
+
+## Pass environment variables
+
+To pass environmental variables to services, use `--env var=val,var2=val ...` notation.
+
+For example, to set worker polling timeout to 10 seconds and set SPARROWCI_HOST:
+
+```bash
+sparman.raku --env SPARKY_TIMEOUT=10,SPARROWCI_HOST=http://127.0.0.1:2222 worker start
+```
+
+## Logs
+
+Logs are available at the following locations:
+
+Sparky Woker UI - `~/.sparky/sparky-web.log`
+
+Sparky Woker - `~/.sparky/sparkyd.log `
+

lib/Sparky.rakumod

@@ -1,6 +1,6 @@
 use v6;
 
-unit module Sparky:ver<0.2.8>;
+unit module Sparky:ver<0.2.9>;
 use YAMLish;
 use DBIish;
 use Time::Crontab;