From d5411ecd2bb606f6b6a14017ba26df908ebf39f6 Mon Sep 17 00:00:00 2001
From: josh <josh@elixxir.io>
Date: Fri, 4 Jun 2021 12:46:44 -0700
Subject: [PATCH] Add partition clear thread to client runner
---
api/client.go | 2 ++
network/message/parse/partition.go | 5 +++--
2 files changed, 5 insertions(+), 2 deletions(-)
diff --git a/api/client.go b/api/client.go
index 5512d33f6..7880fa697 100644
--- a/api/client.go
+++ b/api/client.go
@@ -186,6 +186,8 @@ func OpenClient(storageDir string, password []byte, parameters params.Network) (
parameters: parameters,
}
+ c.runner.Add(c.storage.Partition().ClearMessages())
+
return c, nil
}
diff --git a/network/message/parse/partition.go b/network/message/parse/partition.go
index e7fbbfd31..ad66ba2f3 100644
--- a/network/message/parse/partition.go
+++ b/network/message/parse/partition.go
@@ -12,6 +12,7 @@ import (
"gitlab.com/elixxir/client/interfaces/message"
"gitlab.com/elixxir/client/storage"
"gitlab.com/xx_network/primitives/id"
+ "gitlab.com/xx_network/primitives/netTime"
"time"
)
@@ -80,9 +81,9 @@ func (p Partitioner) HandlePartition(sender *id.ID, _ message.EncryptionType,
// Handle the message ID
messageID := p.session.Conversations().Get(sender).
ProcessReceivedMessageID(fm.GetID())
-
+ storeageTimestamp := netTime.Now()
return p.session.Partition().AddFirst(sender, fm.GetType(),
- messageID, fm.GetPart(), fm.GetNumParts(), fm.GetTimestamp(),
+ messageID, fm.GetPart(), fm.GetNumParts(), fm.GetTimestamp(), storeageTimestamp,
fm.GetSizedContents(), relationshipFingerprint)
} else {
// If it is a subsequent message part, handle it as so
--
GitLab