wier-up channel multi-method

Author: tamizhvendan

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

@@ -1,5 +1,7 @@
 (ns wheel.marketplace.tata-cliq.core
   (:require [wheel.marketplace.tata-cliq.api :as tata-cliq]
+            [wheel.marketplace.tata-cliq.order :as tata-cliq-order]
+            [wheel.oms.client :as oms]
             [wheel.marketplace.channel :as channel]
             [wheel.middleware.ranging :as ranging]
             [wheel.oms.message :as oms-message]
@@ -24,4 +26,9 @@
       (event/processing-failed ex id :ranging channel-id channel-name))))
 
 (defmethod channel/allocate-order :tata-cliq [channel-id channel-config]
-  (prn 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))))

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

@@ -41,15 +41,15 @@
   (let [{:keys [address-info order-no order-lines payment-info]} tata-cliq-order
         {:keys [shipping billing]}                               address-info
         {:keys [payment-cost payment-id]}                        payment-info]
-    {:billing     (to-oms-address billing)
-     :shipping    (to-oms-address shipping)
-     :order-no    order-no
-     :payments    [{:amount       payment-cost
-                    :reference-id payment-id}]
-     :order-lines (map (fn [{:keys [article-number price]}]
-                         {:id         article-number
-                          :sale-price price})
-                       order-lines)}))
+    {:billing-address  (to-oms-address billing)
+     :shipping-address (to-oms-address shipping)
+     :order-no         order-no
+     :payments         [{:amount       payment-cost
+                         :reference-id payment-id}]
+     :order-lines      (map (fn [{:keys [article-number price]}]
+                              {:id         article-number
+                               :sale-price price})
+                            order-lines)}))
 
 (comment
   (s/check-asserts true)

clojure/wheel/src/wheel/oms/client.clj

@@ -0,0 +1,7 @@
+(ns wheel.oms.client
+  (:require [wheel.oms.order :as oms-order]
+            [clojure.spec.alpha :as s]))
+
+(defn allocate-order [order]
+  {:pre [(s/assert ::oms-order/order order)]}
+  (prn (oms-order/to-xml order)))