add cron scaffolding

Author: tamizhvendan

clojure/wheel/.joker

@@ -1,2 +1,3 @@
 {:known-macros [mount.core/defstate
-                toucan.models/defmodel]}
+                toucan.models/defmodel
+                clojurewerkz.quartzite.jobs/defjob]}

clojure/wheel/project.clj

@@ -13,7 +13,8 @@
                  [cheshire "5.9.0"]
                  [toucan "1.14.0"]
                  [clj-http "3.10.0"]
-                 [com.ibm.mq/com.ibm.mq.allclient "9.1.0.0"]]
+                 [com.ibm.mq/com.ibm.mq.allclient "9.1.0.0"]
+                 [clojurewerkz/quartzite "2.1.0"]]
   :main ^:skip-aot wheel.core
   :target-path "target/%s"
   :profiles {:uberjar {:aot :all}

clojure/wheel/resources/config.edn

@@ -11,10 +11,13 @@
                        :qmgr     #or [#env "WHEEL_APP_MQ_QMGR" "QM1"]
                        :user-id  #or [#env "WHEEL_APP_MQ_USER_ID" "app"]
                        :password #or [#env "WHEEL_APP_MQ_PASSWORD" "test123"]}}
- :settings {:oms      {:ranging-queue-name "DEV.QUEUE.1"}
-            :channels {"UA" {:channel-name :tata-cliq
-                             :base-url     "http://localhost:3000"
-                             :bearer-token "top-secret!"}
-                       "UB" {:channel-name :tata-cliq
-                             :base-url     "http://localhost:3000"
-                             :bearer-token "top-secret!"}}}}
+ :settings {:oms       {:ranging-queue-name "DEV.QUEUE.1"}
+            :channels  {"UA" {:channel-name :tata-cliq
+                              :base-url     "http://localhost:3000"
+                              :bearer-token "top-secret!"}
+                        "UB" {:channel-name :tata-cliq
+                              :base-url     "http://localhost:3000"
+                              :bearer-token "top-secret!"}}
+            :cron-jobs [{:type       :allocate-order
+                         :channel-id "UA"
+                         :expression "4 0 * ? * * *"}]}}

clojure/wheel/src/wheel/infra/config.clj

@@ -21,10 +21,12 @@
 (defn oms-settings []
   (get-in root [:settings :oms]))
 
-(defn get-channel-cofig [channel-id]
+(defn get-channel-config [channel-id]
   (get-in root [:settings :channels channel-id]))
 
+(defn get-all-cron-jobs []
+  (get-in root [:settings :cron-jobs]))
+
 (comment
   (mount/start)
-  (get-channel-cofig "UA")
   (mount/stop))

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

@@ -4,6 +4,7 @@
             [clojure.spec.alpha :as s]
             [wheel.infra.config :as config]
             [wheel.infra.database :as db]
+            [wheel.infra.cron.core :as cron]
             [wheel.infra.ibmmq :as ibmmq]
             [wheel.infra.oms :as oms]
             [wheel.middleware.ranging :as ranging]
@@ -15,7 +16,8 @@
   ([check-asserts]
    (log/init)
    (s/check-asserts check-asserts)
-   (mount/start)))
+   (mount/start)
+   (cron/init)))
 
 (defn stop-app []
   (mount/stop))

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

@@ -0,0 +1,14 @@
+(ns wheel.infra.cron.core
+  (:require [clojurewerkz.quartzite.scheduler :as qs]
+            [wheel.infra.cron.job.allocate-order]
+            [wheel.infra.cron.job.core :as job]
+            [wheel.infra.config :as config]
+            [mount.core :as mount]))
+
+(mount/defstate scheduler
+  :start (qs/start (qs/initialize))
+  :stop (qs/shutdown scheduler))
+
+(defn init []
+  (for [cron-job-config (config/get-all-cron-jobs)]
+    (job/schedule scheduler cron-job-config)))

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

@@ -0,0 +1,10 @@
+(ns wheel.infra.cron.job.allocate-order
+  (:require [wheel.infra.cron.job.core :as job]
+            [clojurewerkz.quartzite.jobs :as qj]
+            [wheel.marketplace.channel :as channel]))
+
+(qj/defjob AllocateOrderJob [ctx]
+  (job/handle channel/allocate-order ctx))
+
+(defmethod job/jobtype :allocate-order [_]
+  AllocateOrderJob)

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

@@ -0,0 +1,43 @@
+(ns wheel.infra.cron.job.core
+  (:require [clojurewerkz.quartzite.jobs :as qj]
+            [clojurewerkz.quartzite.conversion :as qc]
+            [clojurewerkz.quartzite.scheduler :as qs]
+            [clojurewerkz.quartzite.schedule.cron :as qsc]
+            [clojurewerkz.quartzite.triggers :as qt]
+            [wheel.infra.config :as config]))
+
+(defmulti jobtype :type)
+
+(defn- identifier [{:keys [channel-id type]}]
+  (keyword channel-id (name type)))
+
+(defn- create-job [channel-config cron-job-config]
+  (qj/build
+   (qj/of-type (jobtype cron-job-config))
+   (qj/using-job-data {:channel-config  channel-config
+                       :cron-job-config cron-job-config})
+   (qj/with-identity (qj/key (identifier cron-job-config)))))
+
+(defn- create-trigger [{:keys [expression]
+                        :as   cron-job-config}]
+  (qt/build
+   (qt/with-identity (qt/key (identifier cron-job-config)))
+   (qt/start-now)
+   (qt/with-schedule (qsc/schedule
+                      (qsc/cron-schedule expression)))))
+
+(defn create [{:keys [channel-id]
+               :as   cron-job-config}]
+  (when-let [channel-config (config/get-channel-config channel-id)]
+    (create-job channel-config cron-job-config)))
+
+(defn handle [channel-fn ctx]
+  (channel-fn (qc/from-job-data ctx) nil))
+
+(defn schedule [scheduler cron-job-config]
+  (when-let [job (create cron-job-config)]
+    (qs/schedule scheduler job (create-trigger cron-job-config))))
+
+(comment
+  (key {:channel-id "UA"
+        :type       :allocate-order}))

clojure/wheel/src/wheel/marketplace/channel.clj

@@ -2,4 +2,7 @@
   (:require [clojure.spec.alpha :as s]))
 
 (s/def ::id (complement clojure.string/blank?))
-(s/def ::name #{:tata-cliq :amazon :flipkart})
+(s/def ::name #{:tata-cliq :amazon :flipkart})
+
+(defmulti allocate-order (fn [channel-id channel-config]
+                           (:name channel-config)))

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

@@ -1,5 +1,6 @@
 (ns wheel.marketplace.tata-cliq.core
   (:require [wheel.marketplace.tata-cliq.api :as tata-cliq]
+            [wheel.marketplace.channel :as channel]
             [wheel.middleware.ranging :as ranging]
             [wheel.oms.message :as oms-message]
             [wheel.middleware.event :as event]
@@ -20,4 +21,7 @@
                        (map #(set/rename-keys % {:id :sku}) items))
     (event/ranging-succeeded id channel-id channel-name items)
     (catch Throwable ex
-      (event/processing-failed ex id :ranging channel-id channel-name))))
+      (event/processing-failed ex id :ranging channel-id channel-name))))
+
+(defmethod channel/allocate-order :tata-cliq [x _]
+  (prn "~~>" x))