fix scaffolding

Author: tamizhvendan

clojure/wheel/resources/config.edn

@@ -20,4 +20,4 @@
                               :bearer-token "top-secret!"}}
             :cron-jobs [{:type       :allocate-order
                          :channel-id "UA"
-                         :expression "4 0 * ? * * *"}]}}
+                         :expression "0 0/1 * 1/1 * ? *"}]}}

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

@@ -11,4 +11,4 @@
 
 (defn init []
   (for [cron-job-config (config/get-all-cron-jobs)]
-    (job/schedule scheduler cron-job-config)))
+    (job/schedule scheduler cron-job-config)))

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

@@ -9,7 +9,7 @@
 (defmulti jobtype :type)
 
 (defn- identifier [{:keys [channel-id type]}]
-  (keyword channel-id (name type)))
+  (str channel-id "/" (name type)))
 
 (defn- create-job [channel-config cron-job-config]
   (qj/build
@@ -22,22 +22,20 @@
                         :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))
+  (let [{:strs [channel-config cron-job-config]} (qc/from-job-data ctx)]
+    (channel-fn (:channel-id cron-job-config) channel-config)))
 
-(defn schedule [scheduler cron-job-config]
-  (when-let [job (create cron-job-config)]
-    (qs/schedule scheduler job (create-trigger cron-job-config))))
+(defn schedule [scheduler {:keys [channel-id]
+                           :as   cron-job-config}]
+  (when-let [channel-config (config/get-channel-config channel-id)]
+    (let [job     (create-job channel-config cron-job-config)
+          trigger (create-trigger cron-job-config)]
+      (qs/schedule scheduler job trigger))))
 
 (comment
-  (key {:channel-id "UA"
-        :type       :allocate-order}))
+  (identifier {:channel-id "UA"
+               :type       :allocate-order}))

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

@@ -5,4 +5,4 @@
 (s/def ::name #{:tata-cliq :amazon :flipkart})
 
 (defmulti allocate-order (fn [channel-id channel-config]
-                           (:name channel-config)))
+                           (:channel-name channel-config)))

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

@@ -23,5 +23,5 @@
     (catch Throwable ex
       (event/processing-failed ex id :ranging channel-id channel-name))))
 
-(defmethod channel/allocate-order :tata-cliq [x _]
-  (prn "~~>" x))
+(defmethod channel/allocate-order :tata-cliq [channel-id channel-config]
+  (prn channel-id "~~>" channel-config))