diff --git a/src/clj/auto_ap/graphql/transactions.clj b/src/clj/auto_ap/graphql/transactions.clj index 4b603c7f..06a92846 100644 --- a/src/clj/auto_ap/graphql/transactions.clj +++ b/src/clj/auto_ap/graphql/transactions.clj @@ -138,23 +138,22 @@ (when (:transaction/payment transaction) - (throw (ex-info "Transaction already associated with a payment" {:validation-error "Transaction already associated with a payment"}))) - + (throw (ex-info "Transaction already associated with a payment" {:validation-error "Transaction already associated with a payment"})))) + @(d/transact (d/connect uri) + (transduce + (map #(into + [(remove-nils (rm/apply-rule {:db/id (:db/id %) + :transaction/amount (:transaction/amount %)} + transaction-rule - @(d/transact (d/connect uri) - (transduce - (map #(into - [(remove-nils (rm/apply-rule {:db/id (:db/id %) - :transaction/amount (:transaction/amount %)} - transaction-rule - - (or (-> % :transaction/bank-account :bank-account/locations) - (-> % :transaction/client :client/locations))))] - (map (fn [x] [:db/retractEntity (:db/id x)] ) - (:transaction/accounts %)))) - into - [] - transactions)))) + (or (-> % :transaction/bank-account :bank-account/locations) + (-> % :transaction/client :client/locations))))] + (map (fn [x] [:db/retractEntity (:db/id x)] ) + (:transaction/accounts %)))) + into + [] + transactions)) + ) (transduce (comp (map d-transactions/get-by-id)