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

Commit f0fc4e8

Browse files
committed
Listening to websocket for incomings
1 parent 8e7e738 commit f0fc4e8

File tree

1 file changed

+19
-0
lines changed

1 file changed

+19
-0
lines changed

net/web_relay_manager.go

Lines changed: 19 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,25 @@ func connectToServer(relay string, sender string) (*websocket.Conn, error) {
103103

104104
fmt.Printf("Successfully connected and subscribed to: %s\n", relay)
105105

106+
go func() {
107+
for {
108+
// read in a message
109+
messageType, p, err := c.ReadMessage()
110+
if err != nil {
111+
fmt.Println(err)
112+
//return nil, err
113+
}
114+
// print out that message for clarity
115+
fmt.Printf("Received incoming message from relay: %s\n", string(p))
116+
117+
if err := c.WriteMessage(messageType, p); err != nil {
118+
fmt.Println(err)
119+
//return nil, err
120+
}
121+
122+
}
123+
}()
124+
106125
return c, nil
107126
}
108127

0 commit comments

Comments
 (0)