distraction action

server/src/crypto/cipher.hpp

@@ -8,6 +8,7 @@ namespace sosc {
 namespace cgc {
 class Cipher {
 public:
+    Cipher() {};
     Cipher(const KeyExchange& key);
     
     void Parse(std::string* data);

server/src/hosts/master.hpp

@@ -5,6 +5,9 @@
 #include "../sock/scapesock.hpp"
 #include "../sock/pool.hpp"
 
+#include "../crypto/keyex.hpp"
+#include "../crypto/cipher.hpp"
+
 namespace sosc {
 /** MASTER -> CLIENT **/
     
@@ -12,12 +15,15 @@ class MasterClient {
 public:
     
 private:
-    ScapeConnection client;
+    ScapeConnection sock;
+    
+    cgc::KeyExchange key;
+    cgc::Cipher cipher;
 };
 
 class MasterClientPool : public Pool<MasterClient> {
 protected:
-    bool ProcessClient(MasterClient client) override;
+    bool ProcessClient(MasterClient& client) override;
 };
 
 /** MASTER -> SLAVE **/
@@ -25,15 +31,20 @@ protected:
 class MasterIntra {
 public:
     MasterIntra(IntraClient client);
-    
+    bool Process();
     void Close();
 private:
-    IntraClient client;
+    IntraClient sock;
+    
+    cgc::KeyExchange key;
+    cgc::Cipher cipher;
 };
 
 class MasterIntraPool : public Pool<MasterIntra> {
 protected:
-    bool ProcessClient(MasterIntra client) override;
+    bool ProcessClient(MasterIntra& client) override {
+        return client.Process();
+    }
 };
 }
 

server/src/hosts/master_intra.cpp

@@ -1,9 +1,9 @@
 #include "master.hpp"
 
 sosc::MasterIntra::MasterIntra(IntraClient client) {
-    this->client = client;
+    this->sock = client;
 }
 
-bool sosc::MasterIntraPool::ProcessClient(MasterIntra client) {
-    
+bool sosc::MasterIntra::Process() {
+    return true;
 }

server/src/hosts/slave.cpp

@@ -1,5 +1,2 @@
 #include "slave.hpp"
 
-bool sosc::SlavePool::ProcessClient(SlaveClient* client) {
-    return true;
-}

server/src/hosts/slave.hpp

@@ -7,12 +7,12 @@
 namespace sosc {
 class SlaveClient {
 public:
-    
+    SlaveClient(ScapeConnection client);
 private:
-    ScapeConnection client;
+    ScapeConnection sock;
 };
 
-class SlavePool : public Pool<SlaveClient*> {
+class SlaveClientPool : Pool<SlaveClient*> {
 protected:
     bool ProcessClient(SlaveClient* client) override;
 };

server/src/sock/pool.hpp

@@ -42,7 +42,7 @@ public:
     
     void Stop();
 protected:
-    virtual bool ProcessClient(T client) = 0;
+    virtual bool ProcessClient(T& client) = 0;
 private:
     bool IsStackFull(int stackCount) const;
     bool CanAddStack() const;
@@ -239,7 +239,7 @@ void Pool<T>::Stack::Stop() {
         return;
     
     this->is_running = false;
-    this->thread.join();
+    this->thread->join();
     
     delete this->thread;
     this->is_open = false;