notid/integreat
1
0
Fork 0
Code Issues Pull Requests 2 Actions Packages Projects Releases Wiki Activity

Fixes rate limiting, adds more logs

Browse Source
This commit is contained in:
Bryce
2024-07-03 08:54:58 -07:00
parent 49aec3ccf5
commit 0bb6ed2c6d
1 changed files with 5 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/clj/auto_ap/square/core3.clj
View File

@@ -35,7 +35,7 @@
(def manifold-api-stream (def manifold-api-stream
(let [stream (s/stream 100)] (let [stream (s/stream 100)]
(->> stream (->> stream
(s/throttle 50) (s/throttle 25)
(s/map (fn [[request attempt response-deferred]] (s/map (fn [[request attempt response-deferred]]
(de/catch (de/catch
(de/chain (de/chain
@@ -70,7 +70,7 @@
(fn [error] (fn [error]
(de/error! response-deferred error))))) (de/error! response-deferred error)))))
(s/buffer 50) (s/buffer 25)
(s/realize-each) (s/realize-each)
(s/consume (fn [_] (s/consume (fn [_]
#_(log/info ::request-completed #_(log/info ::request-completed
@@ -402,7 +402,9 @@
(s/reduce into [])))) (s/reduce into []))))
(de/catch (fn [e] (de/catch (fn [e]
(log/error ::cant-create-results (log/error ::cant-create-results
:exception e))))))) :exception e
:client client
:location location)))))))
(defn get-payment [client p] (defn get-payment [client p]