|
|
@@ -24,12 +24,12 @@ func sender(queue chan []byte, secret string) {
|
|
|
h.Set("X-Secret", secret)
|
|
|
|
|
|
for {
|
|
|
- time.Sleep(3 * time.Second)
|
|
|
-
|
|
|
ws, _, err := websocket.DefaultDialer.Dial("wss://yebi.su/ws", h)
|
|
|
if err != nil {
|
|
|
log.Println("dial error")
|
|
|
|
|
|
+ time.Sleep(3 * time.Second)
|
|
|
+
|
|
|
continue
|
|
|
}
|
|
|
|
|
|
@@ -41,12 +41,16 @@ func sender(queue chan []byte, secret string) {
|
|
|
if err := ws.WriteMessage(websocket.BinaryMessage, data); err != nil {
|
|
|
log.Println("connection lost")
|
|
|
|
|
|
+ time.Sleep(1 * time.Second)
|
|
|
+
|
|
|
break
|
|
|
}
|
|
|
|
|
|
if _, _, err := ws.ReadMessage(); err != nil {
|
|
|
log.Println("connection lost")
|
|
|
|
|
|
+ time.Sleep(1 * time.Second)
|
|
|
+
|
|
|
break
|
|
|
}
|
|
|
}
|
