yves/meowlib
1
0
Fork 0
Code Issues Pull Requests Projects Releases 1 Wiki Activity

double ratchet key persitence bugfix
Some checks failed
continuous-integration/drone/push Build is failing
Details

Browse Source
This commit is contained in:
ycc
2026-03-05 09:06:16 +01:00
parent f4fb42d72e
commit 32cc9ff848
2 changed files with 12 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
client/helpers/messageHelper.go
View File

@@ -105,6 +105,10 @@ func BuildReceivedMessage(messageUid string, peer_uid string, received int64) (*
if err != nil { if err != nil {
return nil, "BuildReceivedMessage : ProcessOutboundUserMessage", err return nil, "BuildReceivedMessage : ProcessOutboundUserMessage", err
} }
// Persist peer to save updated DR state (DrStateJson)
if peer.DrRootKey != "" {
client.GetConfig().GetIdentity().Peers.StorePeer(peer)
}
return packedMsg, "", nil return packedMsg, "", nil
} }
@@ -122,6 +126,10 @@ func BuildProcessedMessage(messageUid string, peer_uid string, processed int64)
if err != nil { if err != nil {
return nil, "BuildProcessedMessage : ProcessOutboundUserMessage", err return nil, "BuildProcessedMessage : ProcessOutboundUserMessage", err
} }
// Persist peer to save updated DR state (DrStateJson)
if peer.DrRootKey != "" {
client.GetConfig().GetIdentity().Peers.StorePeer(peer)
}
return packedMsg, "", nil return packedMsg, "", nil
} }

4
client/internalusermessage.go
View File

@@ -44,6 +44,10 @@ func ProcessOutboundTextMessage(peer *Peer, text string, srv *Server) ([]byte, e
if err != nil { if err != nil {
return nil, err return nil, err
} }
// Persist peer to save updated DR state (DrStateJson)
if peer.DrRootKey != "" {
GetConfig().GetIdentity().Peers.StorePeer(peer)
}
// Creating Server message for transporting the user message // Creating Server message for transporting the user message
toServerMessage := srv.BuildToServerMessageFromUserMessage(packedMsg) toServerMessage := srv.BuildToServerMessageFromUserMessage(packedMsg)
return srv.ProcessOutboundMessage(toServerMessage) return srv.ProcessOutboundMessage(toServerMessage)