Add AgentRegisterRequest handling

Simple mockup of registering agent in cynara service.

Change-Id: I8368c6ad1af946c86e44d196f073d1bf209e97c3

diff --git a/src/service/logic/Logic.cpp b/src/service/logic/Logic.cpp
index d4cc634..55f9f63 100644 (file)
--- a/src/service/logic/Logic.cpp
+++ b/src/service/logic/Logic.cpp
@@ -20,10 +20,11 @@
  * @brief       This file implements main class of logic layer in cynara service
  */
 
-#include <signal.h>
+#include <csignal>
+#include <memory>
 
-#include <log/log.h>
 #include <common.h>
+#include <log/log.h>
 #include <exceptions/BucketNotExistsException.h>
 #include <exceptions/DatabaseException.h>
 #include <exceptions/DefaultBucketDeletionException.h>
@@ -32,11 +33,8 @@
 #include <exceptions/PluginErrorException.h>
 #include <exceptions/PluginNotFoundException.h>
 #include <exceptions/UnexpectedErrorException.h>
-
-#include <cynara-plugin.h>
-
-#include <main/Cynara.h>
 #include <request/AdminCheckRequest.h>
+#include <request/AgentRegisterRequest.h>
 #include <request/CancelRequest.h>
 #include <request/CheckRequest.h>
 #include <request/InsertOrUpdateBucketRequest.h>
@@ -44,12 +42,17 @@
 #include <request/RequestContext.h>
 #include <request/SetPoliciesRequest.h>
 #include <request/SignalRequest.h>
+#include <response/AgentRegisterResponse.h>
 #include <response/CancelResponse.h>
 #include <response/CheckResponse.h>
 #include <response/CodeResponse.h>
+
+#include <main/Cynara.h>
 #include <sockets/SocketManager.h>
 #include <storage/Storage.h>
 
+#include <cynara-plugin.h>
+
 #include "Logic.h"
 
 namespace Cynara {
@@ -78,6 +81,12 @@ void Logic::execute(RequestContextPtr context, AdminCheckRequestPtr request) {
                             request->sequenceNumber()));
 }
 
+void Logic::execute(RequestContextPtr context, AgentRegisterRequestPtr request) {
+    // MOCKUP
+    context->returnResponse(context, std::make_shared<AgentRegisterResponse>(
+                            AgentRegisterResponse::DONE, request->sequenceNumber()));
+}
+
 void Logic::execute(RequestContextPtr context, CancelRequestPtr request) {
     // MOCKUP
     context->returnResponse(context, std::make_shared<CancelResponse>(request->sequenceNumber()));

diff --git a/src/service/logic/Logic.h b/src/service/logic/Logic.h
index e74cffe..18d8abb 100644 (file)
--- a/src/service/logic/Logic.h
+++ b/src/service/logic/Logic.h
@@ -57,6 +57,7 @@ public:
     }
 
     virtual void execute(RequestContextPtr context, AdminCheckRequestPtr request);
+    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, InsertOrUpdateBucketRequestPtr request);