events.clj

(ns monolith.logic.events
  (:require [monolith.db :as db]
            [monolith.utils :as utils]
            [monolith.http :refer [ok]]
            [yesql.core :as yesql]
            [compojure.core :refer [defroutes POST]]))

(yesql/defqueries "sql/stripe/events.sql" (db/yesql-conn))

(defn req->params [{:keys [id] :as body}]
  (assoc body :stripe_id id :id (utils/uuid)))

(defn get-event [id]
  (-> {:stripe_id id}
      get-stripe-events-by-id
      first))

(defn exists? [stripe_id]
  (not (nil? (get-event stripe_id))))

(defn create! [{:keys [body]}]
  (if (exists? (:id body))
   (ok {})
   (-> body
       req->params
       insert-stripe-event<!
       ok)))

(defroutes routes
  (POST "/events" [] create!))