|
@@ -7,6 +7,7 @@ import (
|
|
|
"net/http"
|
|
"net/http"
|
|
|
"os"
|
|
"os"
|
|
|
"os/signal"
|
|
"os/signal"
|
|
|
|
|
+ "time"
|
|
|
|
|
|
|
|
"golang.org/x/crypto/blake2b"
|
|
"golang.org/x/crypto/blake2b"
|
|
|
|
|
|
|
@@ -23,6 +24,8 @@ func sender(queue chan []byte, secret string) {
|
|
|
h.Set("X-Secret", secret)
|
|
h.Set("X-Secret", secret)
|
|
|
|
|
|
|
|
for {
|
|
for {
|
|
|
|
|
+ time.Sleep(3 * time.Second)
|
|
|
|
|
+
|
|
|
ws, _, err := websocket.DefaultDialer.Dial("wss://yebi.su/ws", h)
|
|
ws, _, err := websocket.DefaultDialer.Dial("wss://yebi.su/ws", h)
|
|
|
if err != nil {
|
|
if err != nil {
|
|
|
log.Println("dial error")
|
|
log.Println("dial error")
|
