diff --git a/services/backup/docker-server/contents/server/src/DatabaseManager.h b/services/backup/docker-server/contents/server/src/DatabaseManager.h --- a/services/backup/docker-server/contents/server/src/DatabaseManager.h +++ b/services/backup/docker-server/contents/server/src/DatabaseManager.h @@ -36,6 +36,10 @@ public: static DatabaseManager &getInstance(); + + void putBackupItem(const BackupItem &item); + std::shared_ptr findLastBackupItem(const std::string &userID); + void removeBackupItem(std::shared_ptr item); }; template diff --git a/services/backup/docker-server/contents/server/src/DatabaseManager.cpp b/services/backup/docker-server/contents/server/src/DatabaseManager.cpp --- a/services/backup/docker-server/contents/server/src/DatabaseManager.cpp +++ b/services/backup/docker-server/contents/server/src/DatabaseManager.cpp @@ -1,5 +1,6 @@ #include "DatabaseManager.h" #include "Constants.h" +#include "Tools.h" #include #include @@ -42,6 +43,78 @@ } } +void DatabaseManager::putBackupItem(const BackupItem &item) { + Aws::DynamoDB::Model::PutItemRequest request; + request.SetTableName(BackupItem::tableName); + request.AddItem( + BackupItem::FIELD_USER_ID, + Aws::DynamoDB::Model::AttributeValue(item.getUserID())); + request.AddItem( + BackupItem::FIELD_CREATED, + Aws::DynamoDB::Model::AttributeValue( + std::to_string(getCurrentTimestamp()))); + request.AddItem( + BackupItem::FIELD_BACKUP_ID, + Aws::DynamoDB::Model::AttributeValue(item.getBackupID())); + request.AddItem( + BackupItem::FIELD_RECOVERY_DATA, + Aws::DynamoDB::Model::AttributeValue(item.getRecoveryData())); + request.AddItem( + BackupItem::FIELD_COMPACTION_HOLDER, + Aws::DynamoDB::Model::AttributeValue(item.getCompactionHolder())); + request.AddItem( + BackupItem::FIELD_ATTACHMENT_HOLDERS, + Aws::DynamoDB::Model::AttributeValue(item.getAttachmentHolders())); + + this->innerPutItem(std::make_shared(item), request); +} + +std::shared_ptr +DatabaseManager::findLastBackupItem(const std::string &userID) { + std::shared_ptr item = createItemByType(); + + Aws::DynamoDB::Model::QueryRequest req; + req.SetTableName(BackupItem::tableName); + req.SetKeyConditionExpression(item->getPrimaryKey() + " = :valueToMatch"); + + AttributeValues attributeValues; + attributeValues.emplace(":valueToMatch", userID); + + req.SetExpressionAttributeValues(attributeValues); + req.SetIndexName("userID-created-index"); + + req.SetLimit(1); + req.SetScanIndexForward(false); + + const Aws::DynamoDB::Model::QueryOutcome &outcome = + getDynamoDBClient()->Query(req); + if (!outcome.IsSuccess()) { + throw std::runtime_error(outcome.GetError().GetMessage()); + } + const Aws::Vector &items = outcome.GetResult().GetItems(); + if (items.empty()) { + return nullptr; + } + return std::make_shared(items[0]); +} + +void DatabaseManager::removeBackupItem(std::shared_ptr item) { + Aws::DynamoDB::Model::DeleteItemRequest request; + request.SetTableName(item->getTableName()); + request.AddKey( + BackupItem::FIELD_USER_ID, + Aws::DynamoDB::Model::AttributeValue(item->getUserID())); + request.AddKey( + BackupItem::FIELD_BACKUP_ID, + Aws::DynamoDB::Model::AttributeValue(item->getBackupID())); + + const Aws::DynamoDB::Model::DeleteItemOutcome &outcome = + comm::network::getDynamoDBClient()->DeleteItem(request); + if (!outcome.IsSuccess()) { + throw std::runtime_error(outcome.GetError().GetMessage()); + } +} + } // namespace database } // namespace network } // namespace comm