Skip to content
This repository was archived by the owner on Mar 28, 2023. It is now read-only.

Commit 5340cc8

Browse files
committed
Refactor broadcast message
1 parent a805f45 commit 5340cc8

File tree

1 file changed

+3
-5
lines changed

1 file changed

+3
-5
lines changed

net/web_relay_manager.go

Lines changed: 3 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -192,13 +192,11 @@ func (wrm *WebRelayManager) SendRelayMessage(ciphertext string, recipient string
192192
outgoing, _ := json.Marshal(typedmessage)
193193
log.Debugf("Sending encrypted relay message: %s", string(outgoing))
194194

195-
// Transmit the encrypted message to each configured web relay
196-
for _, relay := range wrm.webrelays {
197-
wrm.authToWebRelay(relay, outgoing)
198-
}
195+
// Transmit the encrypted message to each web relay socket connection
196+
wrm.broadcastMessage(outgoing)
199197
}
200198

201-
func (wrm *WebRelayManager) authToWebRelay(server string, msg []byte) {
199+
func (wrm *WebRelayManager) broadcastMessage(msg []byte) {
202200
for _, conn := range wrm.connections {
203201
if conn != nil {
204202
err := conn.WriteMessage(websocket.TextMessage, msg)

0 commit comments

Comments
 (0)