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

Cleaning up core3 file.

Browse Source
This commit is contained in:
Bryce Covert
2023-01-20 09:31:37 -08:00
parent 2f9b7cc7a3
commit 447ee308b1
1 changed files with 10 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,25 +1,23 @@
(ns auto-ap.square.core3
(:require
[auto-ap.datomic :refer [conn remove-nils]]
[auto-ap.logging :as log :refer [capture-context->lc with-context-as]]
[auto-ap.time :as atime]
[cemerick.url :as url]
[clj-http.client :as client]
[clj-time.coerce :as coerce]
[clj-time.core :as time]
[clj-time.format :as f]
[clj-time.periodic :as periodic]
[clojure.core.async :as async]
[clojure.data.json :as json]
[clojure.set :as set]
[clojure.string :as str]
[cemerick.url :as url]
[datomic.api :as d]
[slingshot.slingshot :refer [try+]]
[manifold.executor :as ex]
[manifold.deferred :as de]
[manifold.time :as mt]
[manifold.stream :as s]
[com.brunobonacci.mulog :as mu]
[auto-ap.logging :refer [with-context-as capture-context->lc] :as log]))
[datomic.api :as d]
[manifold.deferred :as de]
[manifold.executor :as ex]
[manifold.stream :as s]
[manifold.time :as mt]))
(defn client-base-headers [client]
{"Square-Version" "2021-08-18"
@@ -63,7 +61,7 @@
(throw e)
(de/chain
(mt/in 1000 (fn [] 1))
(fn [x] (de/recur (inc attempt)))))))
(fn [_] (de/recur (inc attempt)))))))
(de/chain identity)))
(fn [result]
(de/success! response-deferred result)))
@@ -72,7 +70,7 @@
(s/buffer 50)
(s/realize-each)
(s/consume (fn [result]
(s/consume (fn [_]
(log/info ::request-completed
:source "Square 3"
:background-job "Square 3"))))
@@ -81,7 +79,7 @@
(defn manifold-api-call
([request] (manifold-api-call request 0))
([request attempt]
(manifold-api-call request 0 (de/deferred)))
(manifold-api-call request attempt (de/deferred)))
([request attempt response-deferred]
(de/chain (s/put! manifold-api-stream [request attempt response-deferred])
(fn [r]