diff options
Diffstat (limited to 'internal/server/api/helpers.go')
| -rw-r--r-- | internal/server/api/helpers.go | 8 |
1 files changed, 2 insertions, 6 deletions
diff --git a/internal/server/api/helpers.go b/internal/server/api/helpers.go index 2ed0694..7895a59 100644 --- a/internal/server/api/helpers.go +++ b/internal/server/api/helpers.go @@ -79,7 +79,7 @@ func NetworkPropagateWithFilter( context, cancel := context.WithTimeout(context.Background(), timeout) go func() { defer cancel() - if ok := session.Write(context, WrapPayload(payload)); !ok { + if ok := session.Write(context, payload); !ok { log.Println(sess.Addr(), "propagation to", session.Addr(), "failed") } }() @@ -121,7 +121,7 @@ func UserPropagate( context, cancel := context.WithTimeout(context.Background(), timeout) go func() { defer cancel() - if ok := session.Write(context, WrapPayload(payload)); !ok { + if ok := session.Write(context, payload); !ok { log.Println(sess.Addr(), "propagation to", session.Addr(), "failed") } }() @@ -189,7 +189,3 @@ func getNotifications(ctx context.Context, userId snowflake.ID) (packet.Notifica } return items, nil } - -func WrapPayload(payload packet.Payload) packet.Packet { - return packet.NewPacket(packet.NewMsgPackEncoder(payload)) -} |