This commit is contained in:
parent
92a8ecffd6
commit
e82c1ab94e
2 changed files with 6 additions and 6 deletions
|
@ -5,18 +5,18 @@
|
|||
(import app.httpsig [auth])
|
||||
|
||||
|
||||
(defn/a fetch
|
||||
(defn :async fetch
|
||||
[url]
|
||||
(.info logger url)
|
||||
(return (.json
|
||||
(with/a [client (.AsyncClient httpx)]
|
||||
(with [:async client (.AsyncClient httpx)]
|
||||
(let [headers {"User-Agent" config.USER_AGENT
|
||||
"Accept" config.AP_CONTENT_TYPE}]
|
||||
(await (.get client url :headers headers :timeout 15)))))))
|
||||
|
||||
(defn/a post
|
||||
(defn :async post
|
||||
[url payload]
|
||||
(with/a [client (.AsyncClient httpx)]
|
||||
(with [:async client (.AsyncClient httpx)]
|
||||
(let [headers {"User-Agent" config.USER_AGENT
|
||||
"Content-Type" config.AP_CONTENT_TYPE}]
|
||||
(setv resp
|
||||
|
|
|
@ -6,14 +6,14 @@
|
|||
(import pprint [pprint])
|
||||
|
||||
|
||||
(defn/a selete_object
|
||||
(defn :async selete_object
|
||||
[db ap_type]
|
||||
(.all (await (.scalars db
|
||||
(.where (select models.InboxObject)
|
||||
(= models.InboxObject.ap_type ap_type))))))
|
||||
|
||||
|
||||
(defn/a get_index_status
|
||||
(defn :async get_index_status
|
||||
[db]
|
||||
(.all (await
|
||||
(.scalars db
|
||||
|
|
Loading…
Reference in a new issue