Added better logging for packets and payloads and now the writer is

responsible for packaging into a packet the payload (instead of everyone
who sends to the writer)

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))
-}