diff --git a/e2e/parse/partition/store.go b/e2e/parse/partition/store.go index 9db972575bb04a7349c113cb348173ab4bdce0eb..a8ba36bd985a3497cc9dd467f1c448304f1b7cd4 100644 --- a/e2e/parse/partition/store.go +++ b/e2e/parse/partition/store.go @@ -8,6 +8,7 @@ package partition import ( + "bytes" "encoding/binary" "encoding/json" jww "github.com/spf13/jwalterweatherman" @@ -58,6 +59,12 @@ func (s *Store) AddFirst(partner *id.ID, mt catalog.MessageType, mpm := s.load(partner, messageID) mpm.AddFirst(mt, partNum, numParts, senderTimestamp, storageTimestamp, part) + if bytes.Equal(residue.Marshal(), []byte{}) { + // fixme: should this error or crash? + jww.WARN.Printf("Key reside from first message " + + "is empty, continuing...") + } + mpm.KeyResidue = residue msg, ok := mpm.IsComplete(relationshipFingerprint)