nostr/more-speech
1
0
Fork 0
mirror of https://github.com/unclebob/more-speech.git synced 2024-09-30 02:21:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Extracted connect-to-relay

Browse Source
This commit is contained in:
Robert C. Martin 2023-02-10 14:24:49 -06:00
parent fe4cde702b
commit 55af920b52
1 changed files with 17 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

26
src/more_speech/nostr/protocol.clj
View File

@ -60,17 +60,25 @@
(swap! config/websocket-backlog inc)
(send-off events/event-agent handlers/handle-event message url)))
(defn connect-to-relay [relay]
(let [url (::ws-relay/url relay)
relay-config (get @relays url)
read-type (:read relay-config)
readable? (or (= read-type :read-all)
(= read-type :read-trusted)
(= read-type :read-web-of-trust))
writeable? (:write relay-config)
should-connect? (or readable? writeable?)
open-relay (if should-connect?
(relay/open relay)
nil)]
(when (some? open-relay)
(swap! relays assoc-in [url :connection] open-relay))))
(defn connect-to-relays []
(doseq [url (keys @relays)]
(let [relay (ws-relay/make url handle-relay-message)
relay-config (get @relays url)
should-connect? (or (:read relay-config)
(:write relay-config))
open-relay (if should-connect?
(relay/open relay)
nil)]
(when (some? open-relay)
(swap! relays assoc-in [url :connection] open-relay))))
(let [relay (ws-relay/make url handle-relay-message)]
(connect-to-relay relay)))
(prn 'relay-connection-attempts-complete))
(defn request-contact-lists-from-relays [id]