Page MenuHomePhabricator
Files F3380275

D3805.id11722.diff
No OneTemporary
Actions

D3805.id11722.diff
View Options

diff --git a/services/tunnelbroker/src/Database/DatabaseManager.cpp b/services/tunnelbroker/src/Database/DatabaseManager.cpp
--- a/services/tunnelbroker/src/Database/DatabaseManager.cpp
+++ b/services/tunnelbroker/src/Database/DatabaseManager.cpp
@@ -185,6 +185,10 @@
request.AddItem(
MessageItem::FIELD_EXPIRE,
Aws::DynamoDB::Model::AttributeValue(std::to_string(item.getExpire())));
+ request.AddItem(
+ MessageItem::FIELD_CREATED_AT,
+ Aws::DynamoDB::Model::AttributeValue(
+ std::to_string(static_cast<size_t>(std::time(0)))));
this->innerPutItem(std::make_shared<MessageItem>(item), request);
}
diff --git a/services/tunnelbroker/src/Database/MessageItem.h b/services/tunnelbroker/src/Database/MessageItem.h
--- a/services/tunnelbroker/src/Database/MessageItem.h
+++ b/services/tunnelbroker/src/Database/MessageItem.h
@@ -15,6 +15,7 @@
std::string payload;
std::string blobHashes;
uint64_t expire;
+ uint64_t createdAt;
void validate() const override;
@@ -25,6 +26,7 @@
static const std::string FIELD_PAYLOAD;
static const std::string FIELD_BLOB_HASHES;
static const std::string FIELD_EXPIRE;
+ static const std::string FIELD_CREATED_AT;
std::string getPrimaryKey() const override;
std::string getTableName() const override;
@@ -34,6 +36,7 @@
std::string getPayload() const;
std::string getBlobHashes() const;
uint64_t getExpire() const;
+ uint64_t getCreatedAt() const;
MessageItem() {
}
diff --git a/services/tunnelbroker/src/Database/MessageItem.cpp b/services/tunnelbroker/src/Database/MessageItem.cpp
--- a/services/tunnelbroker/src/Database/MessageItem.cpp
+++ b/services/tunnelbroker/src/Database/MessageItem.cpp
@@ -14,6 +14,7 @@
const std::string MessageItem::FIELD_PAYLOAD = "Payload";
const std::string MessageItem::FIELD_BLOB_HASHES = "BlobHashes";
const std::string MessageItem::FIELD_EXPIRE = "Expire";
+const std::string MessageItem::FIELD_CREATED_AT = "CreatedAt";
MessageItem::MessageItem(
const std::string messageID,
@@ -55,6 +56,8 @@
this->payload = itemFromDB.at(MessageItem::FIELD_PAYLOAD).GetS();
this->blobHashes = itemFromDB.at(MessageItem::FIELD_BLOB_HASHES).GetS();
this->expire = std::stoull(itemFromDB.at(MessageItem::FIELD_EXPIRE).GetS());
+ this->createdAt =
+ std::stoull(itemFromDB.at(MessageItem::FIELD_CREATED_AT).GetS());
} catch (const std::exception &e) {
throw std::runtime_error(
"Got an exception at MessageItem: " + std::string(e.what()));
@@ -95,6 +98,10 @@
return this->expire;
}
+uint64_t MessageItem::getCreatedAt() const {
+ return this->createdAt;
+}
+
} // namespace database
} // namespace network
} // namespace comm

File Metadata

Mime Type
text/plain
Expires
Thu, Nov 28, 10:37 PM (22 h, 7 m)
Storage Engine
blob
Storage Format
Raw Data
Storage Handle
2594871
Default Alt Text
D3805.id11722.diff (2 KB)

Event Timeline