instrumention is done by testrunner

deps.edn

@@ -9,9 +9,12 @@
  ;; ---------------------------------------------------------
  :deps
  {;; Application
-  org.clojure/clojure {:mvn/version "1.11.4"}
+  ;;org.clojure/clojure {:mvn/version "1.11.4"}
   org.clojure/spec.alpha {:mvn/version "0.5.238"}
-  orchestra/orchestra {:mvn/version "2021.01.01-1"}}
+;;   org.babashka/spec.alpha {:git/url "https://github.com/babashka/spec.alpha"
+;;                            :git/sha "644a7fc216e43d5da87b07471b0f87d874107d1a"}
+  orchestra/orchestra {:mvn/version "2021.01.01-1"}
+  babashka/babashka.curl {:mvn/version "0.1.2"}}
  ;; ---------------------------------------------------------
 
  ;; ---------------------------------------------------------
@@ -26,7 +29,8 @@
   ;; call with :watch? true to start file watcher and re-run tests on saved changes
   :test/run
   {:extra-paths ["test"]
-   :extra-deps {lambdaisland/kaocha {:mvn/version "1.91.1392"}}
+   :extra-deps {lambdaisland/kaocha {:mvn/version "1.91.1392"}
+                expound/expound {:mvn/version "0.9.0"}}
    :main-opts   ["-m" "kaocha.runner"]
    :exec-fn kaocha.runner/exec-fn
    :exec-args {:randomize? false

src/dda/backup/core/domain.clj

@@ -3,6 +3,7 @@
    [clojure.spec.alpha :as s]))
 
 (s/def ::command (s/cat
+                  :opts (s/? map?)
                   :app string?
                   :params (s/* string?)))
 (s/def ::commands (s/coll-of ::command))

src/dda/backup/monitoring.clj

@@ -0,0 +1,11 @@
+(ns dda.backup.monitoring
+  (:require
+   [dda.backup.monitoring.domain :as d]
+   [orchestra.core :refer [defn-spec]]))
+
+(defn-spec send-monitoring any?
+  [config ::d/monitoring-config]
+  (curl/post 
+   "http://pushgateway:9091/metrics/job/backup" 
+   {:headers {"Content-Type" "application/json; schema=\"prometheus/telemetry\"; version=\"0.0.2\""}
+    :body (d/monitoring-data config)}))

src/dda/backup/monitoring/domain.clj

@@ -0,0 +1,43 @@
+(ns dda.backup.monitoring.domain
+  (:require
+   [dda.backup.restic.domain :as rd]
+   [dda.backup.monitoring.element :as e]
+   [orchestra.core :refer [defn-spec]]
+   [clojure.spec.alpha :as s]))
+
+(s/def ::type #{"gauge"})
+(s/def ::value (s/+ ::e/metric-element))
+(s/def ::metric (s/keys :req-un [::type
+                                 ::value]))
+(s/def ::backup-size (s/spec ::e/value))
+
+(s/def ::docstring string?)
+(s/def ::__name__ string?)
+(s/def ::baseLabels (s/keys :req-un [::__name__]))
+
+(s/def ::monitoring-data (s/keys :req-un [::baseLabels
+                                          ::docstring
+                                          ::metric]))
+
+(s/def ::monitoring-data-seq (s/+ ::monitoring-data))
+
+(s/def ::fqdn string?)
+
+
+(s/def ::monitoring-config
+  (s/keys :req-un [::fqdn
+                   ::backup-size
+                   ::rd/restic-repository
+                   ::rd/backup-path]))
+
+(defn-spec monitoring-data ::monitoring-data-seq
+  [config ::monitoring-config]
+  (let [{:keys [fqdn backup-size restic-repository backup-path]} config]
+    [{:baseLabels {:__name__ "backup_size"},
+      :docstring "Backup size in MB",
+      :metric {:type "gauge",
+               :value [{:labels
+                        {:app_name "c4k-forgejo"
+                         :fqdn fqdn
+                         :restic_repo (str restic-repository "/" backup-path)},
+                        :value backup-size}]}}]))

src/dda/backup/monitoring/element.clj

@@ -0,0 +1,7 @@
+(ns dda.backup.monitoring.element
+  (:require
+   [clojure.spec.alpha :as s]))
+
+(s/def ::labels map?)
+(s/def ::value pos?)
+(s/def ::metric-element (s/keys :req-un [::labels ::value]))

src/dda/backup/postgresql/domain.clj

@@ -30,9 +30,11 @@
   (s/merge ::pg-config
            ::rd/restic-config))
 
+(s/def ::pg-command (s/* string?))
+
 (defn-spec psql-command ::cd/command
   [config ::pg-config
-   command ::cd/command]
+   command ::pg-command]
   (let [{:keys [pg-host pg-port pg-db pg-user]} config]
     (into
      ["psql" "-d" pg-db "-h" pg-host "-p" (str pg-port) "-U" pg-user
@@ -41,7 +43,7 @@
 
 (defn-spec pgdumpall-command ::cd/command
   [config ::pg-role-dump-config
-   command ::cd/command]
+   command ::pg-command]
   (let [{:keys [pg-host pg-port pg-user pg-role-prefix]} config]
     (into
      []
@@ -54,7 +56,7 @@
 
 (defn-spec pgdump-command ::cd/command
   [config ::pg-db-dump-config
-   command ::cd/command]
+   command ::pg-command]
   (let [{:keys [pg-host pg-port pg-db pg-user]} config]
     (into
      []

test/dda/backup/backup/domain_test.clj

@@ -1,13 +1,8 @@
 (ns dda.backup.backup.domain-test
   (:require
    [clojure.test :refer [deftest is are testing run-tests]]
-   [clojure.spec.test.alpha :as st]
    [dda.backup.backup.domain :as cut]))
 
-(st/instrument `cut/backup-files-command)
-(st/instrument `cut/backup-role-command)
-(st/instrument `cut/backup-db-command)
-
 (deftest should-calculate-backup-files-command
   (is (= [[{:dir "dir-to-backup"}
            "restic"

test/dda/backup/core/domain_test.clj

@@ -6,7 +6,13 @@
 
 (deftest should-verify-command
   (is (= {:app "restic", :params ["-r" "repo/dir" "-v" "init" "--cacert" "ca"]}
-         (s/conform ::cut/command ["restic" "-r" "repo/dir" "-v" "init" "--cacert" "ca"]))))
+         (s/conform ::cut/command ["restic" "-r" "repo/dir" "-v" "init" "--cacert" "ca"])))
+  (is (= {:app "restic"}
+         (s/conform ::cut/command ["restic"])))
+  (is (= {:opts {:dir "dir"} :app "restic", :params ["-r" "repo/dir" "-v" "init" "--cacert" "ca"]}
+         (s/conform ::cut/command [{:dir "dir"} "restic" "-r" "repo/dir" "-v" "init" "--cacert" "ca"])))
+  (is (= {:opts {:dir "dir"} :app "restic"}
+         (s/conform ::cut/command [{:dir "dir"} "restic"]))))
 
 (deftest should-verify-commands
   (is (= [{:app "ls"}

test/dda/backup/monitoring/domain_test.clj

@@ -0,0 +1,19 @@
+(ns dda.backup.monitoring.domain-test
+  (:require
+   [clojure.test :refer [deftest is are testing run-tests]]
+   [dda.backup.monitoring.domain :as cut]))
+
+(deftest should-generate-monitoring-data
+  (is (= [{:baseLabels {:__name__ "backup_size"},
+           :docstring "Backup size in MB",
+           :metric {:type "gauge",
+                    :value [{:labels
+                             {:app_name "c4k-forgejo"
+                              :fqdn "repo.prod.meissa.de"
+                              :restic_repo "repo/dir-at-repo"},
+                             :value 123}]}}]
+         (cut/monitoring-data {:fqdn "repo.prod.meissa.de"
+                               :restic-repository "repo"
+                               :backup-path "dir-at-repo"
+                               :backup-size 123}))))
+

test/dda/backup/postgresql/domain_test.clj

@@ -1,13 +1,8 @@
 (ns dda.backup.postgresql.domain-test
   (:require
    [clojure.test :refer [deftest is are testing run-tests]]
-   [clojure.spec.test.alpha :as st]
    [dda.backup.postgresql.domain :as cut]))
 
-(st/instrument `cut/pgpass)
-(st/instrument `cut/db-drop-command)
-(st/instrument `cut/db-create-command)
-
 (deftest should-calculate-pgpass
   (is (= "localhost:5432:mydb:user:password\nlocalhost:5432:template1:user:password\n"
          (cut/pgpass {:restic-repository "repo"

test/dda/backup/restic/domain_test.clj

@@ -1,14 +1,8 @@
 (ns dda.backup.restic.domain-test
   (:require
    [clojure.test :refer [deftest is are testing run-tests]]
-   [clojure.spec.test.alpha :as st]
    [dda.backup.restic.domain :as cut]))
 
-(st/instrument `cut/repo-command)
-(st/instrument `cut/init-repo-command)
-(st/instrument `cut/unlock-repo-command)
-(st/instrument `cut/forget-command)
-
 (deftest should-calculate-repo-command
   (is (=  [{:dir "dir"}
            "restic"

test/dda/backup/restore/domain_test.clj

@@ -1,12 +1,8 @@
 (ns dda.backup.restore.domain-test
   (:require
    [clojure.test :refer [deftest is are testing run-tests]]
-   [clojure.spec.test.alpha :as st]
    [dda.backup.restore.domain :as cut]))
 
-(st/instrument `cut/restore-dir-command)
-(st/instrument `cut/restore-db-command)
-
 (deftest should-calculate-restore-dir
   (is (= [["rm" "-rf" "dir-to-backup"]
           ["restic"

tests.edn

@@ -10,4 +10,6 @@
 
 ;; ---------------------------------------------------------
 
-#kaocha/v1 {}
+#kaocha/v1 {:plugins [:orchestra]
+            :reporter kaocha.report/documentation}
+