diff options
| author | Kyren223 <Kyren223@proton.me> | 2025-02-05 19:41:34 +0200 |
|---|---|---|
| committer | Kyren223 <Kyren223@proton.me> | 2025-02-05 19:41:34 +0200 |
| commit | 0bf5515629f1cfe1557dba4f8d588ac64b77d408 (patch) | |
| tree | 2bfc56b990c6edd6bab6ddf7b10964b0efb1dbcb /internal/server/server.go | |
| parent | 8a8c4e9abc1006da92969e0234bb2d42f587c149 (diff) | |
When a user sends a message "signal" and the receiving user doesn't have
the signal already open, it will be added as the first signal
Diffstat (limited to 'internal/server/server.go')
| -rw-r--r-- | internal/server/server.go | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/internal/server/server.go b/internal/server/server.go index 153f612..1477e7f 100644 --- a/internal/server/server.go +++ b/internal/server/server.go @@ -414,6 +414,7 @@ func (server *server) sendInitialPackets(ctx context.Context, sess *session.Sess if payload == &api.ErrInternalError { return false } + log.Println(sess.Addr(), "sending", payload.Type(), "payload:", payload) pkt := packet.NewPacket(packet.NewMsgPackEncoder(payload)) sess.Write(ctx, pkt) @@ -421,6 +422,7 @@ func (server *server) sendInitialPackets(ctx context.Context, sess *session.Sess if payload == &api.ErrInternalError { return false } + log.Println(sess.Addr(), "sending", payload.Type(), "payload:", payload) pkt = packet.NewPacket(packet.NewMsgPackEncoder(payload)) sess.Write(ctx, pkt) @@ -428,6 +430,7 @@ func (server *server) sendInitialPackets(ctx context.Context, sess *session.Sess if err != nil { return false } + log.Println(sess.Addr(), "sending", payload.Type(), "payload:", payload) pkt = packet.NewPacket(packet.NewMsgPackEncoder(payload)) sess.Write(ctx, pkt) @@ -435,6 +438,7 @@ func (server *server) sendInitialPackets(ctx context.Context, sess *session.Sess if payload == &api.ErrInternalError { return false } + log.Println(sess.Addr(), "sending", payload.Type(), "payload:", payload) pkt = packet.NewPacket(packet.NewMsgPackEncoder(payload)) sess.Write(ctx, pkt) |