summaryrefslogtreecommitdiff
path: root/internal/api/client/streaming/stream.go
diff options
context:
space:
mode:
authorLibravatar Tobi Smethurst <31960611+tsmethurst@users.noreply.github.com>2021-07-11 16:22:21 +0200
committerLibravatar GitHub <noreply@github.com>2021-07-11 16:22:21 +0200
commit846057f0d696fded87d105dec1245e9ba32763ce (patch)
tree9a4914c07bcf189a3eea0a2c091567c56cdf4963 /internal/api/client/streaming/stream.go
parentfavourites GET implementation (#95) (diff)
downloadgotosocial-846057f0d696fded87d105dec1245e9ba32763ce.tar.xz
Block/unblock (#96)
* remote + local block logic, incl. federation * improve blocking stuff * fiddle with display of blocked profiles * go fmt
Diffstat (limited to 'internal/api/client/streaming/stream.go')
-rw-r--r--internal/api/client/streaming/stream.go14
1 files changed, 7 insertions, 7 deletions
diff --git a/internal/api/client/streaming/stream.go b/internal/api/client/streaming/stream.go
index a5b8a2d99..20a12fefe 100644
--- a/internal/api/client/streaming/stream.go
+++ b/internal/api/client/streaming/stream.go
@@ -67,23 +67,23 @@ sendLoop:
select {
case m := <-stream.Messages:
// we've got a streaming message!!
- l.Debug("received message from stream")
+ l.Trace("received message from stream")
if err := conn.WriteJSON(m); err != nil {
- l.Infof("error writing json to websocket connection: %s", err)
+ l.Debugf("error writing json to websocket connection: %s", err)
// if something is wrong we want to bail and drop the connection -- the client will create a new one
break sendLoop
}
- l.Debug("wrote message into websocket connection")
+ l.Trace("wrote message into websocket connection")
case <-t.C:
- l.Debug("received TICK from ticker")
+ l.Trace("received TICK from ticker")
if err := conn.WriteMessage(websocket.PingMessage, []byte(": ping")); err != nil {
- l.Infof("error writing ping to websocket connection: %s", err)
+ l.Debugf("error writing ping to websocket connection: %s", err)
// if something is wrong we want to bail and drop the connection -- the client will create a new one
break sendLoop
}
- l.Debug("wrote ping message into websocket connection")
+ l.Trace("wrote ping message into websocket connection")
}
}
- l.Debug("leaving StreamGETHandler")
+ l.Trace("leaving StreamGETHandler")
}