diff --git a/network/message/handler.go b/network/message/handler.go index ecced449eb9f1077311dd26aac3c90851b32c4ac..b7574f4cf8636b67aaa37ef7330058dd037de2f6 100644 --- a/network/message/handler.go +++ b/network/message/handler.go @@ -126,17 +126,19 @@ func (m *Manager) handleMessage(ecrMsg format.Message, bundle Bundle, edge *edge return } - im := fmt.Sprintf("Received message of type %s from %s in round %d,"+ - " msgDigest: %s, keyFP: %v", encTy, sender, bundle.Round, - msgDigest, msg.GetKeyFP()) - jww.INFO.Print(im) - m.Internal.Events.Report(2, "MessageReception", "MessagePart", im) + // Process the decrypted/unencrypted message partition, to see if // we get a full message xxMsg, ok := m.partitioner.HandlePartition(sender, encTy, msg.GetContents(), relationshipFingerprint) + im := fmt.Sprintf("Received message of ecr type %s and msg type " + + "%d from %s in round %d,msgDigest: %s, keyFP: %v", encTy, + xxMsg.MessageType, sender, bundle.Round, msgDigest, msg.GetKeyFP()) + jww.INFO.Print(im) + m.Internal.Events.Report(2, "MessageReception", "MessagePart", im) + // If the reception completed a message, hear it on the switchboard if ok { //Set the identities diff --git a/storage/utility/meteredCmixMessageBuffer.go b/storage/utility/meteredCmixMessageBuffer.go index dd5ade5a31a51469587c4dd8a32d67f07b9c515e..8060b4781fc25af49b97251abcb87981e9929cff 100644 --- a/storage/utility/meteredCmixMessageBuffer.go +++ b/storage/utility/meteredCmixMessageBuffer.go @@ -56,7 +56,7 @@ func (*meteredCmixMessageHandler) LoadMessage(kv *versioned.KV, key string) (int // Load the versioned object vo, err := kv.Get(key, currentMeteredCmixMessageVersion) if err != nil { - return format.Message{}, err + return nil, err } msg := meteredCmixMessage{}