diff options
author | 2021-07-11 16:22:21 +0200 | |
---|---|---|
committer | 2021-07-11 16:22:21 +0200 | |
commit | 846057f0d696fded87d105dec1245e9ba32763ce (patch) | |
tree | 9a4914c07bcf189a3eea0a2c091567c56cdf4963 /internal/api/client/streaming/stream.go | |
parent | favourites GET implementation (#95) (diff) | |
download | gotosocial-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.go | 14 |
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") } |