Rearrange classes for request and response processing

RequestContext object is the only one passed from SocketManager
to Request execute() method.
Response object is passed to Protocol through
RequestContext::returnResponse().
Response queue is managed automaticaly in RequestContext class.
Request derivatives don't need to handle queues.
ResponseTaker::appendResponseToBuffer() methods need to take
additional queue object as parameter as it is no longer
part of response object.

Change-Id: I15af84c315a55284d4dccff670537e47c60c6b70

diff --git a/src/service/logic/Logic.cpp b/src/service/logic/Logic.cpp
index 3b7f54d61eedf18c23dfba9baa24ea8777824e96..df52e9fc53cc1351ef7ec0c543e9808aeae4193f 100644 (file)
--- a/src/service/logic/Logic.cpp
+++ b/src/service/logic/Logic.cpp
@@ -31,7 +31,7 @@ Logic::Logic() {
 Logic::~Logic() {
 }
 
-PolicyResult Logic::check(int sourceDesc UNUSED, const PolicyKey &key UNUSED) {
+PolicyResult Logic::check(const RequestContext &context UNUSED, const PolicyKey &key UNUSED) {
 //todo this is only a stub
     return PolicyResult(PredefinedPolicyType::ALLOW);
 }

diff --git a/src/service/logic/Logic.h b/src/service/logic/Logic.h
index a487ac751ffc86dce867ec1725b6727f928cf00b..3f8626f3ae51301c4917f89848f2e589f111a9d2 100644 (file)
--- a/src/service/logic/Logic.h
+++ b/src/service/logic/Logic.h
@@ -26,6 +26,8 @@
 #include <types/PolicyKey.h>
 #include <types/PolicyResult.h>
 
+#include <request/RequestContext.h>
+
 namespace Cynara {
 
 class Logic {
@@ -33,7 +35,7 @@ public:
     Logic();
     ~Logic();
 
-    PolicyResult check(int sourceDesc, const PolicyKey &key);
+    PolicyResult check(const RequestContext &context, const PolicyKey &key);
 };
 
 } // namespace Cynara

diff --git a/src/service/protocol/ResponseTaker.cpp b/src/service/protocol/ResponseTaker.cpp
index b5fb6ac3d66c6f236a3918694b63cddf0cf73949..9ce248a1d683181a87dba945434aa0018a85cae3 100644 (file)
--- a/src/service/protocol/ResponseTaker.cpp
+++ b/src/service/protocol/ResponseTaker.cpp
@@ -28,7 +28,8 @@
 
 namespace Cynara {
 
-void ResponseTaker::appendResponseToBuffer(CheckResponse &&response UNUSED) {
+void ResponseTaker::appendResponseToBuffer(BinaryQueue &queue UNUSED,
+                                           CheckResponse &&response UNUSED) {
     throw NotImplementedException();
 }
 

diff --git a/src/service/protocol/ResponseTaker.h b/src/service/protocol/ResponseTaker.h
index d8a39c570030f17ff0ae860891fe1abef90765ba..a4305d9af7d4251e5b1028f54af96eff13f1bfdd 100644 (file)
--- a/src/service/protocol/ResponseTaker.h
+++ b/src/service/protocol/ResponseTaker.h
@@ -23,6 +23,8 @@
 #ifndef SRC_SERVICE_PROTOCOL_RESPONSETAKER_H_
 #define SRC_SERVICE_PROTOCOL_RESPONSETAKER_H_
 
+#include <common.h>
+
 #include <response/CheckResponse.h>
 
 namespace Cynara {
@@ -32,7 +34,7 @@ public:
     ResponseTaker() = default;
     virtual ~ResponseTaker() = default;
 
-    virtual void appendResponseToBuffer(CheckResponse &&response);
+    virtual void appendResponseToBuffer(BinaryQueue &queue, CheckResponse &&response);
 };
 
 } // namespace Cynara

diff --git a/src/service/request/CheckRequest.cpp b/src/service/request/CheckRequest.cpp
index e5d229565a37d97cec0806636516df38ee319136..a7edfef7e84d2eb6f3261cd99fa0f50946a544ff 100644 (file)
--- a/src/service/request/CheckRequest.cpp
+++ b/src/service/request/CheckRequest.cpp
@@ -23,7 +23,8 @@
 #include <common.h>
 #include <types/PolicyResult.h>
 
-#include <protocol/Protocol.h>
+#include <logic/Logic.h>
+#include <main/Cynara.h>
 #include <request/RequestContext.h>
 
 #include "CheckRequest.h"
@@ -33,10 +34,9 @@ namespace Cynara {
 CheckRequest::CheckRequest(const PolicyKey &key) : m_key(key) {
 }
 
-void CheckRequest::execute(Logic *logic, int sourceDesc) {
-    PolicyResult result = logic->check(sourceDesc, m_key);
-    BinaryQueue &queue = RequestContext::resultQueue(sourceDesc);
-    RequestContext::protocol(sourceDesc)->appendResponseToBuffer(CheckResponse(queue, result));
+void CheckRequest::execute(const RequestContext &context) {
+    PolicyResult result = Cynara::getLogic()->check(context, m_key);
+    context.returnResponse(CheckResponse(result));
 }
 
 } // namespace Cynara

diff --git a/src/service/request/CheckRequest.h b/src/service/request/CheckRequest.h
index d7b28abbe4a813b493adf70efe5ed01c1fcdbaee..4e1b62c54364811f2198ed0d5c1ac629720eaaa9 100644 (file)
--- a/src/service/request/CheckRequest.h
+++ b/src/service/request/CheckRequest.h
@@ -25,7 +25,8 @@
 
 #include <types/PolicyKey.h>
 
-#include "Request.h"
+#include <request/Request.h>
+#include <request/RequestContext.h>
 
 namespace Cynara {
 
@@ -37,7 +38,7 @@ public:
     CheckRequest(const PolicyKey &key);
     virtual ~CheckRequest() = default;
 
-    virtual void execute(Logic *logic, int sourceDesc);
+    virtual void execute(const RequestContext &context);
 };
 
 } // namespace Cynara

diff --git a/src/service/request/Request.h b/src/service/request/Request.h
index 7ab5112919c738332fee333ad2dd7f3a65e0a3cc..96715106159529fef87d39b6bbffb57272e8e918 100644 (file)
--- a/src/service/request/Request.h
+++ b/src/service/request/Request.h
@@ -25,7 +25,7 @@
 
 #include <memory>
 
-#include <logic/Logic.h>
+#include "RequestContext.h"
 
 namespace Cynara {
 
@@ -34,7 +34,7 @@ public:
     Request();
     virtual ~Request();
 
-    virtual void execute(Logic *logic, int sourceDesc) = 0;
+    virtual void execute(const RequestContext &context) = 0;
 };
 
 typedef std::shared_ptr<Request> RequestPtr;

diff --git a/src/service/request/RequestContext.cpp b/src/service/request/RequestContext.cpp
index fdadea4976fe37e2813e0626410d579f2a43dcf3..9318227a2522d895202fd70e7c207444e0d38e6d 100644 (file)
--- a/src/service/request/RequestContext.cpp
+++ b/src/service/request/RequestContext.cpp
@@ -21,18 +21,22 @@
  */
 
 #include <main/Cynara.h>
+#include <sockets/Descriptor.h>
 #include <sockets/SocketManager.h>
 
 #include "RequestContext.h"
 
 namespace Cynara {
 
-BinaryQueue &RequestContext::resultQueue(int fd) {
-    return Cynara::getSocketManager()->descriptor(fd).writeQueue();
+RequestContext::RequestContext(int desc) : m_desc(desc) {
 }
 
-ProtocolPtr RequestContext::protocol(int fd) {
-    return Cynara::getSocketManager()->descriptor(fd).protocol();
+ResponseTaker &RequestContext::responseTaker(void) const {
+        return Cynara::getSocketManager()->descriptor(m_desc).responseTaker();
+}
+
+BinaryQueue &RequestContext::responseQueue(void) const {
+    return Cynara::getSocketManager()->descriptor(m_desc).writeQueue();
 }
 
 } // namespace Cynara

diff --git a/src/service/request/RequestContext.h b/src/service/request/RequestContext.h
index d026e48b6ace0b5fa4622a1a34f4500ce1ad503d..441bf7c3bf976c54add117b4db84076fa38243b6 100644 (file)
--- a/src/service/request/RequestContext.h
+++ b/src/service/request/RequestContext.h
@@ -25,15 +25,24 @@
 
 #include <common.h>
 
-#include <protocol/Protocol.h>
+#include <protocol/ResponseTaker.h>
 
 namespace Cynara {
 
 class RequestContext {
+private:
+    int m_desc;
+
+    ResponseTaker &responseTaker(void) const;
+    BinaryQueue &responseQueue(void) const;
 
 public:
-    static BinaryQueue &resultQueue(int fd);
-    static ProtocolPtr protocol(int fd);
+    RequestContext(int desc);
+
+    template <class T>
+    void returnResponse(T &&response) const {
+        responseTaker().appendResponseToBuffer(responseQueue(), std::move(response));
+    }
 };
 
 } // namespace Cynara

diff --git a/src/service/response/CheckResponse.h b/src/service/response/CheckResponse.h
index fdef1a757bc394c6c2fd38986475a61cac32972b..69ae983f266024f355f28627f366585e6945c111 100644 (file)
--- a/src/service/response/CheckResponse.h
+++ b/src/service/response/CheckResponse.h
@@ -29,11 +29,10 @@
 namespace Cynara {
 
 struct CheckResponse {
-    BinaryQueue &m_queueRef;
     const PolicyResult &m_resultRef;
 
-    CheckResponse(BinaryQueue &queue, const PolicyResult &result)
-        : m_queueRef(queue), m_resultRef(result) {}
+    CheckResponse(const PolicyResult &result) : m_resultRef(result) {
+    }
 };
 
 } // namespace Cynara

diff --git a/src/service/sockets/SocketManager.cpp b/src/service/sockets/SocketManager.cpp
index 7ce4f088494aa3d67345bacbdc0b5acb5071b595..4d9e425a19ccb93fd87e3b68f5b452ad9c7a6f8e 100644 (file)
--- a/src/service/sockets/SocketManager.cpp
+++ b/src/service/sockets/SocketManager.cpp
@@ -224,7 +224,7 @@ bool SocketManager::handleRead(int fd, const RawBuffer &readbuffer) {
 
             LOGD("request extracted");
             try {
-                req->execute(Cynara::getLogic(), fd);
+                req->execute(fd);
 
                 if (desc.hasDataToWrite())
                     addWriteSocket(fd);