Add processing EraseRequest on serviceLogic layer

Process EraseRequest, pass data to Storage layer.
Save database in case of successful erase.
Return CodeResponse to sender of EraseRequest.

Change-Id: I9bddfff64bf8b8e11f36ccac85ab5bb715f69c4f

diff --git a/src/service/logic/Logic.cpp b/src/service/logic/Logic.cpp
index 3445984..75c94ca 100644 (file)
--- a/src/service/logic/Logic.cpp
+++ b/src/service/logic/Logic.cpp
@@ -42,6 +42,7 @@
 #include <request/AgentRegisterRequest.h>
 #include <request/CancelRequest.h>
 #include <request/CheckRequest.h>
+#include <request/EraseRequest.h>
 #include <request/InsertOrUpdateBucketRequest.h>
 #include <request/ListRequest.h>
 #include <request/RemoveBucketRequest.h>
@@ -270,6 +271,22 @@ bool Logic::update(const PolicyKey &key, ProtocolFrameSequenceNumber checkId,
     return false;
 }
 
+void Logic::execute(RequestContextPtr context, EraseRequestPtr request) {
+    auto code = CodeResponse::Code::OK;
+
+    try {
+        m_storage->erasePolicies(request->startBucket(), request->recursive(), request->filter());
+        onPoliciesChanged();
+    } catch (const DatabaseException &ex) {
+        code = CodeResponse::Code::FAILED;
+    } catch (const BucketNotExistsException &ex) {
+        code = CodeResponse::Code::NO_BUCKET;
+    }
+
+    context->returnResponse(context, std::make_shared<CodeResponse>(code,
+                            request->sequenceNumber()));
+}
+
 void Logic::execute(RequestContextPtr context, InsertOrUpdateBucketRequestPtr request) {
     auto code = CodeResponse::Code::OK;
 

diff --git a/src/service/logic/Logic.h b/src/service/logic/Logic.h
index d347071..71c5d01 100644 (file)
--- a/src/service/logic/Logic.h
+++ b/src/service/logic/Logic.h
@@ -69,6 +69,7 @@ public:
     virtual void execute(RequestContextPtr context, AgentRegisterRequestPtr request);
     virtual void execute(RequestContextPtr context, CancelRequestPtr request);
     virtual void execute(RequestContextPtr context, CheckRequestPtr request);
+    virtual void execute(RequestContextPtr context, EraseRequestPtr request);
     virtual void execute(RequestContextPtr context, InsertOrUpdateBucketRequestPtr request);
     virtual void execute(RequestContextPtr context, ListRequestPtr request);
     virtual void execute(RequestContextPtr context, RemoveBucketRequestPtr request);