adding transaction rules.

2019-05-07 07:10:21 -07:00
parent 918f2e5be1
commit a1abb4b05e
15 changed files with 266 additions and 15 deletions
--- a/src/clj/auto_ap/datomic/transaction_rules.clj
+++ b/src/clj/auto_ap/datomic/transaction_rules.clj
@@ -0,0 +1,71 @@
+(ns auto-ap.datomic.transaction-rules
+  (:require [datomic.api :as d]
+            [auto-ap.datomic :refer [uri merge-query apply-sort-2 apply-pagination add-sorter-field]]
+            [auto-ap.graphql.utils :refer [limited-clients]]
+            [clojure.set :refer [rename-keys]]
+            [clj-time.coerce :as c]))
+
+(defn <-datomic [result]
+  result)
+
+(def default-read '[*
+                    {:transaction-rule/client [:client/name :db/id :client/code]}
+                    {:transaction-rule/bank-account [*]}
+                    {:transaction-rule/yodlee-merchant [*]}])
+
+(defn raw-graphql-ids [db args]
+  (let [query (cond-> {:query {:find []
+                               :in ['$]
+                               :where []}
+                       :args [db]}
+                (:sort-by args) (add-sorter-field {"client" ['[?e :transaction-rule/client ?c]
+                                                             '[?c :client/name ?sorter]]
+                                                   "yodlee-merchant" ['[?e :transaction-rule/yodlee-merchant ?c]
+                                                                      '[?c :yodlee-merchant/name ?sorter]]
+                                                   "bank-account" ['[?e :transaction-rule/bank-account ?c]
+                                                                   '[?c :bank-account/name ?sorter]]
+                                                   "amount_lte" ['[?e :transaction-rule/amount-lte ?sorter]]
+                                                   "amount_gte" ['[?e :transaction-rule/amount-gte ?sorter]]
+                                                   }
+                                                  args)
+
+                (limited-clients (:id args))
+                (merge-query {:query {:in ['[?xx ...]]
+                                      :where ['[?e :transaction-rule/client ?xx]]}
+                              :args [(set (map :db/id (limited-clients (:id args))))]})
+
+                (:client-id args)
+                (merge-query {:query {:in ['?client-id]
+                                      :where ['[?e :transaction-rule/client ?client-id]]}
+                              :args [(:client-id args)]})
+
+                true
+                (merge-query {:query {:find ['?e]
+                                      :where ['[?e :transaction-rule/description]]}}))]
+
+    
+    (cond->> query
+      true (d/query)
+      true (apply-sort-2 args [:asc])
+      true (apply-pagination args))))
+
+(defn graphql-results [ids db args]
+  (let [results (->> (d/pull-many db default-read ids)
+                     (group-by :db/id))
+        transaction-rules (->> ids
+                               (map results)
+                               (map first)
+                               (mapv <-datomic))]
+    transaction-rules))
+
+(defn get-graphql [args]
+  (let [db (d/db (d/connect uri))
+        {ids-to-retrieve :ids matching-count :count} (raw-graphql-ids db args)]
+
+    [(->> (graphql-results ids-to-retrieve db args))
+     matching-count]))
+
+(defn get-by-id [id]
+  (->> 
+   (d/pull (d/db (d/connect uri)) default-read id)
+   (<-datomic)))