making tests work again.

This commit is contained in:
2023-05-01 09:42:06 -07:00
parent 93ba8ca3b5
commit 611af7f9bb
9 changed files with 29 additions and 32 deletions

View File

@@ -28,7 +28,7 @@
:stop nil)
(mount/defstate conn
:start (dc/connect "datomic:ddb://us-east-1/iol-dev/dev")
:start (dc/connect uri)
:stop nil)
#_(def uri "datomic:mem://datomic-transactor:4334/invoice")

View File

@@ -188,7 +188,6 @@
{:index :avet
:selector [:db/id :journal-entry-line/location :journal-entry-line/account :journal-entry-line/running-balance :journal-entry-line/client+account+location+date {:journal-entry/_line-items [:journal-entry/date :journal-entry/client]}]
:start [:journal-entry-line/client+account+location+date [client bank-account "A" #inst "2030-01-01"]]
:limit 1
:reverse true
})
(filter (fn [{[c b] :journal-entry-line/client+account+location+date}]

View File

@@ -346,8 +346,7 @@
@(->> (dc/qseq {:query '[:find (pull ?je [:journal-entry/date :journal-entry/client {:journal-entry/line-items [:journal-entry-line/account :journal-entry-line/location :db/id]}])
:in $ ?c
:where [?je :journal-entry/client ?c]]
:args [(dc/db conn)]}
client)
:args [(dc/db conn) client]})
(map first)
(mapcat (fn [je]
(map (fn [jel]
@@ -442,8 +441,7 @@
{:index :avet
:selector [:db/id :journal-entry-line/running-balance :journal-entry-line/client+account+location+date]
:start [:journal-entry-line/client+account+location+date [client account location starting-at]]
:reverse true
:limit 500})
:reverse true})
(take-while (fn [result]
(= [client
account
@@ -461,17 +459,6 @@
account (pull-id db account)]
(into []
(comp
(map (fn [i]
(dc/index-pull db
{:index :avet
:selector [:db/id :journal-entry-line/debit :journal-entry-line/credit :journal-entry-line/client+account+location+date]
:start [:journal-entry-line/client+account+location+date
[client account location starting-at]]
:offset (* i 1000)
:limit 1000}
)))
(take-while identity)
(mapcat identity)
(take-while (fn [{[result-client result-account result-location] :journal-entry-line/client+account+location+date}]
(and
(= client result-client)
@@ -479,7 +466,13 @@
(= location result-location))))
(map (fn [result]
[(:db/id result) (:journal-entry-line/debit result 0.0) (:journal-entry-line/credit result 0.0) ])))
(range 100))))
(dc/index-pull db
{:index :avet
:selector [:db/id :journal-entry-line/debit :journal-entry-line/credit :journal-entry-line/client+account+location+date]
:start [:journal-entry-line/client+account+location+date
[client account location starting-at]]
}))))
(defn compute-running-balance [account-needing-refresh]
(mu/trace ::compute