bugfix in serialization of incoming messages in redis

This commit is contained in:
ycc 2022-12-17 21:37:48 +01:00
parent 1031529964
commit 7d6d8dd913
2 changed files with 1 additions and 2 deletions

View File

@ -76,7 +76,6 @@ message ContactCard {
// structure for sending a message to be forwarded to another user in protobuf format // structure for sending a message to be forwarded to another user in protobuf format
message PackedUserMessage { message PackedUserMessage {
//string from = 1; // the client identity public key as known by the destination peer // remove, limit server tracking
string destination=1; // the peer's current conversation lookup public key string destination=1; // the peer's current conversation lookup public key
bytes payload=2; // the message UserMessage encrypted with the destination peer's public key bytes payload=2; // the message UserMessage encrypted with the destination peer's public key
bytes signature=3; // the payload signature with the client identity private key bytes signature=3; // the payload signature with the client identity private key

View File

@ -34,7 +34,7 @@ func (r *RedisRouter) Route(msg *meowlib.ToServerMessage) (*meowlib.FromServerMe
if len(msg.Messages) > 0 { // user message if len(msg.Messages) > 0 { // user message
for _, usrmsg := range msg.Messages { for _, usrmsg := range msg.Messages {
// serialize the message to store it as byte array into redis // serialize the message to store it as byte array into redis
out, err := proto.Marshal(msg) out, err := proto.Marshal(usrmsg)
if err != nil { if err != nil {
return nil, err return nil, err
} }