Page MenuHomePhabricator
Differential D3647

[services] Backup - Send log - add backup id and log hash states
ClosedPublic
Actions

Authored by • karol on Apr 7 2022, 7:21 AM.
Tags
None
Referenced Files
Unknown Object (File)
Tue, Apr 1, 2:48 PM
Unknown Object (File)
Tue, Apr 1, 6:35 AM
Unknown Object (File)
Mon, Mar 31, 9:03 PM
Unknown Object (File)
Sat, Mar 29, 7:16 PM
Unknown Object (File)
Sat, Mar 29, 12:40 PM
Unknown Object (File)
Sat, Mar 15, 5:53 AM
Unknown Object (File)
Mar 3 2025, 6:59 PM
Unknown Object (File)
Feb 23 2025, 2:41 PM
View All Files
Subscribers
• abosh
• adrian
ashoat
atul
• benschac
tomek

Details

Reviewers
tomek
• max
Commits
rCOMM430640213fac: [services] Backup - Send log - add backup id and log hash states
Summary

Depends on D3646

Adding two missing states for the reactor: BACKUP_ID and LOG_HASH. along with the cases in the reading request method's body.

Test Plan
cd services
yarn run-backup-service

Diff Detail

Repository
rCOMM Comm
Lint
No Lint Coverage
Unit
No Test Coverage

Event Timeline

• karol created this revision.Apr 7 2022, 7:21 AM
Herald added subscribers: • abosh, • benschac, atul and 3 others. · View Herald TranscriptApr 7 2022, 7:21 AM
• karol edited the summary of this revision. (Show Details)Apr 7 2022, 7:27 AM
• karol edited the test plan for this revision. (Show Details)
• karol added reviewers: tomek, • max.
• karol added a parent revision: D3646: [services] Backup - Send log - initialize put reactor method.
• karol added a child revision: D3648: [services] Backup - Send log - add reactor state mutex.Apr 7 2022, 7:29 AM
Harbormaster completed remote builds in B7967: Diff 11171.Apr 7 2022, 8:32 AM
• karol requested review of this revision.Apr 7 2022, 8:32 AM
tomek accepted this revision.Apr 8 2022, 1:23 AM
tomek added inline comments.
services/backup/docker-server/contents/server/src/Reactors/server/SendLogReactor.h
94–104

It is ok to introduce new, unimplemented states, but it would be better if we added them one-by-one, with the implementation.

Also, this->state = State::LOG_CHUNK; is deleted... shouldn't we replace it with this->state = State::BACKUP_ID;?

This revision is now accepted and ready to land.Apr 8 2022, 1:23 AM
• karol added inline comments.Apr 13 2022, 4:19 AM
services/backup/docker-server/contents/server/src/Reactors/server/SendLogReactor.h
94–104

It is ok to introduce new, unimplemented states, but it would be better if we added them one-by-one, with the implementation.

I understand. I'm going to try to remember about this next time.

Also, this->state = State::LOG_CHUNK; is deleted... shouldn't we replace it with this->state = State::BACKUP_ID;?

t is added in D3651. Here we return unimplemented anyway so there's no point in caring about the correctness of the logic as it's not gonna work here yet anyway.

Closed by commit rCOMM430640213fac: [services] Backup - Send log - add backup id and log hash states (authored by • karol). · Explain WhyApr 13 2022, 4:20 AM
This revision was automatically updated to reflect the committed changes.
• karol added a commit: rCOMM430640213fac: [services] Backup - Send log - add backup id and log hash states.

Revision Contents
Changeset List

PathSize
services/
backup/
docker-server/
contents/
server/
src/
Reactors/
server/
13 lines

Diff 11171

View Options

services/backup/docker-server/contents/server/src/Reactors/server/SendLogReactor.h

Show All 16 Lines virtual void SetUp() {
config::ConfigManager::getInstance().load(); config::ConfigManager::getInstance().load();
Aws::InitAPI({}); Aws::InitAPI({});
} }
virtual void TearDown() { virtual void TearDown() {
Aws::ShutdownAPI({}); Aws::ShutdownAPI({});
} }
}; };
TEST_F(DatabaseManagerTest, TestOperationsOnMessageItem) {
const database::MessageItem item(
tools::generateUUID(),
"mobile:" + tools::generateRandomString(DEVICEID_CHAR_LENGTH),
"mobile:" + tools::generateRandomString(DEVICEID_CHAR_LENGTH),
tools::generateRandomString(256),
tools::generateRandomString(256),
static_cast<uint64_t>(std::time(0)) + 600);
EXPECT_EQ(
database::DatabaseManager::getInstance().isTableAvailable(
item.getTableName()),
true);
database::DatabaseManager::getInstance().putMessageItem(item);
std::shared_ptr<database::MessageItem> foundItem =
database::DatabaseManager::getInstance().findMessageItem(
item.getMessageID());
EXPECT_NE(foundItem, nullptr);
EXPECT_EQ(
memcmp(
item.getFromDeviceID().data(),
foundItem->getFromDeviceID().data(),
item.getFromDeviceID().size()),
0);
tomekUnsubmitted
Done
Inline Actions
EXPECT_NE(foundItem, nullptr);
- EXPECT_EQ(
- memcmp(
- item.getFromDeviceID().data(),
- foundItem->getFromDeviceID().data(),
- item.getFromDeviceID().size()),
- 0);
+ EXPECT_EQ(item.getFromDeviceID(), foundItem->getFromDeviceID());
EXPECT_EQ(
tomek:
EXPECT_EQ(
memcmp(
item.getToDeviceID().data(),
foundItem->getToDeviceID().data(),
item.getToDeviceID().size()),
0);
EXPECT_EQ(
memcmp(
item.getPayload().data(),
foundItem->getPayload().data(),
item.getPayload().size()),
0);
EXPECT_EQ(
memcmp(
item.getBlobHashes().data(),
foundItem->getBlobHashes().data(),
item.getBlobHashes().size()),
0);
EXPECT_EQ(item.getExpire() == foundItem->getExpire(), true);
database::DatabaseManager::getInstance().removeMessageItem(
item.getMessageID());
}