29 lines
1.6 KiB
Clojure
29 lines
1.6 KiB
Clojure
(ns auto-ap.import.common
|
|
(:require
|
|
[auto-ap.datomic :refer [conn]]
|
|
[clojure.tools.logging :as log]
|
|
[datomic.api :as d]))
|
|
|
|
(defn bank-account->integration-id [bank-account]
|
|
(or (->> bank-account
|
|
(d/pull (d/db conn) [:bank-account/integration-status])
|
|
:bank-account/integration-status
|
|
:db/id)
|
|
#db/id[:db.part/user]))
|
|
|
|
(defn wrap-integration [f bank-account]
|
|
(try
|
|
(let [result (f)]
|
|
@(d/transact conn [{:db/id bank-account :bank-account/integration-status {:db/id (bank-account->integration-id bank-account)
|
|
:integration-status/state :integration-state/success
|
|
:integration-status/last-attempt (java.util.Date.)
|
|
:integration-status/last-updated (java.util.Date.)}}])
|
|
result)
|
|
(catch Exception e
|
|
@(d/transact conn [{:db/id bank-account :bank-account/integration-status {:db/id (bank-account->integration-id bank-account)
|
|
:integration-status/state :integration-state/failed
|
|
:integration-status/last-attempt (java.util.Date.)
|
|
:integration-status/message (.getMessage e)}}])
|
|
(log/warn e)
|
|
nil)))
|