diff --git a/src/clj/auto_ap/square/core3.clj b/src/clj/auto_ap/square/core3.clj index 4e8cf5bd..198c4e4c 100644 --- a/src/clj/auto_ap/square/core3.clj +++ b/src/clj/auto_ap/square/core3.clj @@ -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]