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

In websocket-relay check if socket has closed before sending or closing.

Browse Source
This commit is contained in:
Robert C. Martin 2023-01-17 15:32:27 -06:00
parent d3f3cb7324
commit cb605a909f
1 changed files with 13 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
src/more_speech/websocket_relay.clj
View File

@ -80,20 +80,22 @@
(defmethod relay/close ::websocket [relay]
(let [{::keys [socket timer]} relay]
(try
(.get (.sendClose socket WebSocket/NORMAL_CLOSURE "done"))
(catch Exception e
(prn 'on-send-close-error (:reason e))))
(when (and socket (not (.isOutputClosed socket)))
(try
(.get (.sendClose socket WebSocket/NORMAL_CLOSURE "done"))
(catch Exception e
(prn 'on-send-close-error (:reason e)))))
(when timer (.cancel timer))
(assoc relay ::open? false ::socket nil)))
(defmethod relay/send ::websocket [relay message]
(let [{::keys [socket url]} relay]
(try
(let [json (to-json message)]
(println "sending to:" url " " json)
(.sendText socket json true)
(.request socket 1))
(catch Exception e
(prn 'send-to (.getMessage e))))))
(when (and socket (not (.isOutputClosed socket)))
(try
(let [json (to-json message)]
(println "sending to:" url " " json)
(.sendText socket json true)
(.request socket 1))
(catch Exception e
(prn 'send-to (.getMessage e)))))))