feat(loggin): bring back portal + mulog

Author: goshatch

deps.edn

@@ -25,9 +25,11 @@
 
   ring/ring-mock {:mvn/version "0.4.0"}
 
-  ;; Logging
+  ;; Logging and observability
   org.slf4j/slf4j-simple {:mvn/version "2.0.16"}
   com.brunobonacci/mulog {:mvn/version "0.9.0"}
+  djblue/portal {:mvn/version "0.58.5"}
+
   ;;
   ;; A small library for explicit, intentful configuration.
   ;; https://github.com/juxt/aero

src/dev/mulog_events.clj

@@ -0,0 +1,43 @@
+(ns mulog-events
+  (:require
+   [com.brunobonacci.mulog :as mulog]
+   [com.brunobonacci.mulog.buffer :as mulog-buffer]))
+
+;; ---------------------------------------------------------
+;; Set event global context
+;; - information added to every event for REPL workflow
+;; (mulog/set-global-context! {:app-name "parts"
+;;                             :version "0.1.0-SNAPSHOT", :env "dev"})
+;; ---------------------------------------------------------
+
+;; ---------------------------------------------------------
+;; Mulog event publishing
+
+(deftype TapPublisher
+         [buffer transform]
+  com.brunobonacci.mulog.publisher.PPublisher
+  (agent-buffer [_] buffer)
+  (publish-delay [_] 200)
+  (publish [_ buffer]
+    (doseq [item (transform (map second (mulog-buffer/items buffer)))]
+      (tap> item))
+    (mulog-buffer/clear buffer)))
+
+#_{:clj-kondo/ignore [:unused-private-var]}
+(defn ^:private tap-events
+  [{:keys [transform] :as _config}]
+  (TapPublisher. (mulog-buffer/agent-buffer 10000) (or transform identity)))
+
+(def tap-publisher
+  "Start mulog custom tap publisher to send all events to Portal
+  and other tap sources
+  `mulog-tap-publisher` to stop publisher"
+  (mulog/start-publisher!
+   {:type :custom, :fqn-function "mulog-events/tap-events"}))
+
+#_{:clj-kondo/ignore [:unused-public-var]}
+(defn stop
+  "Stop mulog tap publisher to ensure multiple publishers are not started
+ Recommended before using `(restart)` or evaluating the `user` namespace"
+  []
+  tap-publisher)

src/dev/repl.clj

@@ -3,6 +3,8 @@
    [kaocha.repl :as k]
    [kaocha.watch :as watch]
    [migratus.core :as migratus]
+   [portal.api :as portal]
+   [mulog-events]
    [parts.config :as conf]
    [parts.db :as db]
    [parts.server :as server]
@@ -12,10 +14,20 @@
 (defn cljs-repl []
   (shadow.cljs.devtools.api/repl :frontend))
 
+(def portal-instance
+  "Open portal window if no portal sessions have been created.
+   A portal session is created when opening a portal window.
+
+   Opens in the default system browser."
+  (or (seq (portal/sessions))
+      (portal/open {:app false})))
+
+(add-tap #'portal.api/submit)
+
 ;; App server management
 
 (defonce server-ref (atom nil))
-;; TODO: Do we also want to open Inspector automatically?
+
 (defn start []
   (shadow-server/start!)
   (shadow/watch :frontend)

src/main/parts/server.clj

@@ -6,11 +6,13 @@
   (:require
    [clojure.core.async :as async]
    [com.brunobonacci.mulog :as mulog]
+   [muuntaja.core :as muuntaja]
    [org.httpkit.server :as server]
    [parts.api.account :as api.account]
    [parts.api.auth :as api.auth]
    [parts.api.systems :as api.systems]
    [parts.auth :as auth]
+   [parts.config :as conf]
    [parts.db :as db]
    [parts.handlers.pages :as pages]
    [parts.handlers.waitlist :as waitlist]
@@ -19,7 +21,6 @@
    [reitit.ring :as ring]
    [reitit.ring.coercion :as rrc]
    [reitit.ring.middleware.muuntaja :as muuntaja-middleware]
-   [muuntaja.core :as muuntaja]
    [ring.middleware.params :refer [wrap-params]])
   (:gen-class))
 
@@ -193,7 +194,7 @@
   (let [port (or (some-> (first args) Integer/parseInt) 3000)]
     ;; Set up global logging context
     (mulog/set-global-context!
-     {:app-name "Parts" :version "0.1.0-SNAPSHOT"})
+     {:app-name "Parts" :version "0.1.0-SNAPSHOT", :env (conf/get-environment)})
     (mulog/log ::application-startup :arguments args :port port)
 
     ;; Initialize database