feat: add mq component in itself

Author: J0sueTM

src/com/moclojer/components/mq.clj

@@ -50,22 +50,22 @@
   component/Lifecycle
   (start [this]
     (logs/log :info "starting mq")
-    (let [components {:config config
+    (let [client (rq/create-client (get-in config [:config :mq :uri]))
+          base-this (assoc this :client client)
+          components {:config config
                       :database database
                       :storage storage
                       :http http
-                      :sentry sentry}
-          client (rq/create-client (get-in config [:config :mq :uri]))
+                      :sentry sentry
+                      :mq base-this}
           wrapped-workers (map #(wrap-worker % components sentry) workers)
           subs (rq-pubsub/subscribe! client wrapped-workers :blocking? blocking?)]
 
       (doseq [job jobs]
-        (start-job! (assoc this :client client) job))
+        (start-job! base-this job))
 
-      (merge this {:client client
-                   :subs subs
-                   :jobs jobs
-                   :components components})))
+      (merge this (assoc base-this :components components)
+             {:subs subs :jobs jobs})))
   (stop [this]
     (logs/log :info "stopping mq")
     (when-let [?client (:client this)]

test/com/moclojer/components/mq_test.clj

@@ -47,15 +47,23 @@
   {:init (utils/start-system! create-and-start-system)
    :cleanup utils/stop-system!
    :fail-fast? true}
-  #_(flow
-      "should publish and consume a message"
-      (publish-message {:event "test"} "test")
-      (flow "sleeping and check the state"
-        (match? {:event "test"}
-                (state/return
-                 (utils/exec-with-timeout
-                  #(deref state)
-                  10000 500)))))
+
+  (flow
+    "should have itself in the components"
+    [mq (state-flow.api/get-state :mq)]
+    (match?
+     (get-in mq [:components :mq :client])
+     (:client mq)))
+
+  (flow
+    "should publish and consume a message"
+    (publish-message {:event "test"} "test")
+    (flow "sleeping and check the state"
+      (match? {:event "test"}
+              (state/return
+               (utils/exec-with-timeout
+                #(deref state)
+                10000 500)))))
   (flow
     "should trigger a job 2 times within 5.5 seconds"
     [:let [job {:channel "test-job"