void Logic::execute(RequestContextPtr context, InsertOrUpdateBucketRequestPtr request) {
m_storage->addOrUpdateBucket(request->bucketId(), request->result());
-//todo add saving to database
+ m_storage->save();
+
context->returnResponse(context, std::make_shared<CodeResponse>(CodeResponse::Code::OK,
request->sequenceNumber()));
}
auto code = CodeResponse::Code::OK;
try {
m_storage->deleteBucket(request->bucketId());
-//todo add saving to database
+ m_storage->save();
} catch (const BucketNotExistsException &ex) {
code = CodeResponse::Code::NO_BUCKET;
} catch (const DefaultBucketDeletionException &ex) {
try {
m_storage->insertPolicies(request->policiesToBeInsertedOrUpdated());
m_storage->deletePolicies(request->policiesToBeRemoved());
-//todo add saving to database
+ m_storage->save();
} catch (const BucketNotExistsException &ex) {
code = CodeResponse::Code::NO_BUCKET;
}