add events

Author: tamizhvendan

clojure/wheel/src/wheel/infra/cron/job/core.clj

@@ -4,7 +4,9 @@
             [clojurewerkz.quartzite.scheduler :as qs]
             [clojurewerkz.quartzite.schedule.cron :as qsc]
             [clojurewerkz.quartzite.triggers :as qt]
-            [wheel.infra.config :as config]))
+            [wheel.infra.config :as config]
+            [wheel.middleware.event :as event]
+            [wheel.infra.log :as log]))
 
 (defmulti jobtype :type)
 
@@ -26,11 +28,19 @@
                       (qsc/cron-schedule expression)))))
 
 (defn handle [channel-fn ctx]
-  (let [{:strs [channel-config cron-job-config]} (qc/from-job-data ctx)]
-    (try
-      (channel-fn (:channel-id cron-job-config) channel-config)
-      (catch Throwable ex
-        (prn "==>" ex)))))
+  (try
+    (let [{:strs [channel-config cron-job-config]} (qc/from-job-data ctx)
+          {:keys [channel-id type]}                cron-job-config
+          {:keys [channel-name]}                   channel-config
+          cron-started-event                       (event/cron type channel-id channel-name)]
+      (try
+        (channel-fn channel-id channel-config)
+        (log/write! cron-started-event)
+        (catch Throwable ex
+          (log/write-all! [cron-started-event
+                           (event/cron type channel-id channel-name ex)]))))
+    (catch Throwable t
+      (prn "~~>" t))))
 
 (defn schedule [scheduler {:keys [channel-id]
                            :as   cron-job-config}]

clojure/wheel/src/wheel/marketplace/tata_cliq/core.clj

@@ -26,9 +26,6 @@
       (event/processing-failed ex id :ranging channel-id channel-name))))
 
 (defmethod channel/allocate-order :tata-cliq [channel-id channel-config]
-  (try
-    (->> (tata-cliq/new-orders channel-config channel-id)
-         (map tata-cliq-order/to-oms-order)
-         (run! oms/allocate-order))
-    (catch Throwable e
-      (prn e))))
+  (->> (tata-cliq/new-orders channel-config channel-id)
+       (map tata-cliq-order/to-oms-order)
+       (run! oms/allocate-order)))

clojure/wheel/src/wheel/middleware/event.clj

@@ -14,7 +14,11 @@
 (s/def ::domain-event-name #{:ranging/succeeded})
 (s/def ::system-event-name #{:system/parsing-failed
                              :system/channel-not-found
-                             :system/processing-failed})
+                             :system/processing-failed
+                             :system.cron/started
+                             :system.cron/failed})
+
+(s/def ::job-type #{:allocate-order})
 
 (s/def ::name (s/or :oms ::oms-event-name 
                     :domain ::domain-event-name
@@ -57,14 +61,20 @@
 (defmethod payload-type :ranging/succeeded [_]
   (s/keys :req-un [::ranged-items]))
 
+(defmethod payload-type :system.cron/started [_]
+  (s/keys :req-un [::job-type]))
+
+(defmethod payload-type :system.cron/failed [_]
+  (s/keys :req-un [::job-type ::error-message ::stacktrace]))
+
 (defmethod payload-type :default [_]
   (s/keys :req-un [::type]))
 (s/def ::payload (s/multi-spec payload-type :type))
 
 (defmulti event-type :type)
 (defmethod event-type :system [_]
   (s/keys :req-un [::id ::name ::type ::level ::timestamp ::payload]
-          :opt-un [::parent-id]))
+          :opt-un [::parent-id ::channel-id ::channel-name]))
 (defmethod event-type :domain [_]
   (s/keys :req-un [::id ::name ::type ::level ::timestamp 
                    ::channel-id ::channel-name ::payload]
@@ -122,6 +132,21 @@
           :channel-name channel-name
           :level :error)))
 
+(defn cron 
+  ([job-type channel-id channel-name]
+   (event :system.cron/started {:job-type job-type}
+          :channel-id channel-id
+          :channel-name channel-name
+          :type :system
+          :level :info))
+  ([job-type channel-id channel-name ex]
+   (event :system.cron/failed
+          (assoc (ex->map ex) :job-type job-type)
+          :channel-id channel-id
+          :channel-name channel-name
+          :type :system
+          :level :error)))
+
 (defn parsing-failed [parent-id message-type error-message]
   {:pre [(s/assert uuid? parent-id)
          (s/assert ::oms-message/type message-type)