chicken-master/frontend/src/chicken_master/events.cljs

(ns chicken-master.events
  (:require
   [re-frame.core :as re-frame]
   [chicken-master.db :as db]
   [chicken-master.time :as time]
   [chicken-master.config :as config]
   [day8.re-frame.http-fx]
   [ajax.edn :as edn]
   [goog.crypt.base64 :as b64]))

(defn get-token [] (str "Basic " (some-> js/window (.-localStorage) (.getItem :bearer-token))))
(defn http-request [method endpoint & {:keys [params body on-success on-failure]
                                       :or {on-success ::process-fetched-days
                                            on-failure ::failed-request}}]
  {:method method
   :uri (str (config/settings :backend-url) endpoint)
   :headers {"Content-Type" "application/edn"
             "authorization" (get-token)}
   :format (edn/edn-request-format)
   :body (some-> body pr-str)
   :params params
   :response-format (edn/edn-response-format)
   :on-success  [on-success]
   :on-failure     [on-failure]})


(defn http-get [endpoint params on-success]
  (http-request :get endpoint :params params :on-success on-success))

(defn http-post [endpoint body]
  (http-request :post endpoint :body body))

(re-frame/reg-event-fx
 ::initialize-db
 (fn [_ _]
   (time/update-settings config/default-settings)
   (let [user (some-> js/window (.-localStorage) (.getItem :bearer-token))
         user (when-not (= user "null") user)
         result {:db (assoc db/default-db
                            :settings config/default-settings
                            :current-user user)}]
     (if user
       (assoc result :dispatch [::load-db])
       result))))

(re-frame/reg-event-fx
 ::load-db
 (fn [_ _]
   (time/update-settings config/default-settings)
   {:fx [[:dispatch [::show-from-date (time/iso-date (time/today))]]
         [:dispatch [::start-loading]]
         [:dispatch [::fetch-stock]]
         [:dispatch [::fetch-orders]]]}))

(re-frame/reg-event-db ::hide-modal (fn [db [_ modal]] (assoc-in db [modal :show] nil)))
(re-frame/reg-event-db ::start-loading (fn [db _] (update db :loading? inc)))
(re-frame/reg-event-db ::stop-loading (fn [db _] (update db :loading? #(-> % dec (max 0)))))
(re-frame/reg-event-fx
 ::confirm-action
 (fn [_ [_ msg on-confirm-event & params]]
   (when (js/confirm msg)
     {:fx [[:dispatch (into [on-confirm-event] params)]]})))

(re-frame/reg-event-fx
 ::log-error
 (fn [_ [_ error]]
   (.error js/console error)
   (js/alert "Wystąpił błąd")
   ))

(re-frame/reg-event-fx
 ::failed-request
 (fn [{db :db} [_ response]]
   {:fx [(when (= (:status response) 401) [:dispatch [::log-out]])
         [:dispatch [::log-error (str response)]]
         [:dispatch [::stop-loading]]]}))

(re-frame/reg-event-fx
 ::change-order-type
 (fn [{db :db} [_ id event]]
   (prn "changing" (-> db :orders (get id)))
   (prn event)
   (if (-> db :orders (get id) :recurrence)
     {:db (assoc db :order-type-edit {:show true :order (-> db :orders (get id)) :event event})}
     {:db db :dispatch event})))

(re-frame/reg-event-fx
 ::remove-order
 (fn [_ [_ id day action-type]]
   (if (or day action-type)
     {:http-xhrio (http-request :post (str "orders/" id "/remove")
                                :body {:day day :action-type action-type})}
     {:http-xhrio (http-request :delete (str "orders/" id))})))

(re-frame/reg-event-fx
 ::move-order
 (fn [{{orders :orders} :db} [_ id from to]]
   {:http-xhrio
    (http-request :put (str "orders/" id)
                  :body (-> id orders (assoc :order-date from :day to)))}))

(re-frame/reg-event-db
 ::edit-order
 (fn [{orders :orders :as db} [_ day id]]
   (assoc db :order-edit
          (-> orders
              (get id {:state :waiting})
              (merge {:show true :day day :order-date day})))))

(re-frame/reg-event-fx
 ::fulfill-order
 (fn [{db :db} [_ id day]]
   {:db (assoc-in db [:orders id :state] :pending)
    :http-xhrio (http-request :post (str "orders/" id "/fulfilled")
                              :body {:day day})}))

(re-frame/reg-event-fx
 ::reset-order
 (fn [{db :db} [_ id day]]
   {:db (assoc-in db [:orders id :state] :waiting)
    :http-xhrio (http-request :post (str "orders/" id "/waiting")
                              :body {:day day})}))

(re-frame/reg-event-fx
 ::save-order
 (fn [{{order :order-edit} :db} [_ form]]
   {:dispatch [::hide-modal :order-edit]
    :http-xhrio (http-post "orders"
                           (merge
                            (select-keys order [:id :day :hour :state :order-date])
                            (select-keys form [:id :day :hour :state :who :notes :products :recurrence])))}))

(re-frame/reg-event-fx
 ::process-fetched-days
 (fn [{db :db} [_ days]]
   {:db (-> db
            (update :current-days (fn [current-days]
                                    (for [[day orders] current-days]
                                      [day (if (contains? days day) (days day) orders)])))
            (update :orders (fn [orders] (->> days
                                             (mapcat second)
                                             (group-by :id)
                                             vals
                                             (map (fn [items] (->> items
                                                                  (reduce #(assoc %1 (:day %2) (:state %2)) {})
                                                                  (assoc (first items) :days))))
                                             (reduce #(assoc %1 (:id %2) %2) orders)))))
    :dispatch [::stop-loading]}))

(re-frame/reg-event-fx
 ::scroll-weeks
 (fn [{db :db} [_ offset]]
   {:fx [[:dispatch [::start-loading]]
         [:dispatch [::show-from-date (-> db
                                          :start-date
                                          time/parse-date
                                          (time/date-offset (* 7 offset))
                                          time/iso-date)]]]}))

(re-frame/reg-event-fx
 ::show-from-date
 (fn [{{:keys [start-date orders] :as db} :db} [_ day]]
   (let [day (or day start-date)
         days (into #{} (time/get-weeks day 2))
         filtered-orders (->> orders vals
                              (mapcat (fn [order]
                                        (map #(assoc order :day (first %) :state (second %))
                                             (:days order))))
                              (filter (comp days :day)) (group-by :day))]
     {:db (assoc db
                 :start-date day
                 :current-days (map #(vector % (get filtered-orders %)) (sort days)))
      :dispatch [::stop-loading]})))

(re-frame/reg-event-fx
 ::fetch-orders
 (fn [_ [_ from to]]
   {:dispatch [::start-loading]
    :http-xhrio (http-request :get "orders")}))

;; Customers events
(re-frame/reg-event-fx
 ::show-customers
 (fn [{db :db} _]
   {:db (assoc-in db [:clients :show] true)
    :dispatch [::fetch-stock]}))

(re-frame/reg-event-fx
 ::add-customer
 (fn [_ [_ customer-name]]
   {:http-xhrio (http-request :post "customers"
                                            :body {:name customer-name}
                                            :on-success ::process-stock)}))
(re-frame/reg-event-fx
 ::remove-customer
 (fn [_ [_ id]]
   {:dispatch [::start-loading]
     :http-xhrio (http-request :delete (str "customers/" id)
                                             :on-success ::process-stock)}))

(re-frame/reg-event-fx
 ::save-product-group
 (fn [_ [_ id group]]
   {:dispatch [::start-loading]
    :http-xhrio (http-request :post (str "customers/" id "/product-group")
                              :body group
                              :on-success ::process-stock)}))

(re-frame/reg-event-fx
 ::save-customer-prices
 (fn [_ [_ id products]]
   {:dispatch [::start-loading]
    :http-xhrio (http-request :post (str "customers/" id "/prices")
                              :body products
                              :on-success ::process-stock)}))

;;; Storage events

(re-frame/reg-event-fx
 ::show-stock
 (fn [{db :db} _]
   {:db (assoc-in db [:stock :show] true)
    :dispatch [::fetch-stock]}))

(re-frame/reg-event-fx
 ::fetch-stock
 (fn [_ [_ ]]
   {:dispatch [::start-loading]
    :http-xhrio (http-get "stock" {} ::process-stock)}))

(defn assoc-if [coll key source]
  (if (contains? source key)
    (assoc coll key (source key))
    coll))
(re-frame/reg-event-fx
 ::process-stock
 (fn [{db :db} [_ stock]]
   {:db (-> db
            (assoc-if :products stock)
            (assoc-if :customers stock))
    :dispatch [::stop-loading]
    }))

(re-frame/reg-event-fx
 ::save-stock
 (fn [_ [_ products]]
   {:fx [[:dispatch [::hide-modal :stock]]
         [:dispatch [::start-loading]]]
    :http-xhrio (http-request :post "products" :body products :on-success ::process-stock)}))

;; Settings
(re-frame/reg-event-db
 ::show-settings
 (fn [db _]
   (assoc-in db [:settings :show] true)))


(re-frame/reg-event-fx
 ::set-user
 (fn [{db :db} [_ user]]
   (config/set-item! :bearer-token (b64/encodeString (str (user "name") ":" (user "password"))))
   {:db (assoc db :current-user (b64/encodeString (str (user "name") ":" (user "password"))))
    :dispatch [::load-db]}))

(re-frame/reg-event-db
 ::log-out
 (fn [db _]
   (config/set-item! :bearer-token nil)
   (dissoc db :current-user)))

(comment
  (re-frame/dispatch-sync [::show-stock])
  (re-frame/dispatch-sync [::update-product-stock :eggs 2])
  )