diff --git a/src/server/db/database.hpp b/src/server/db/database.hpp index 6008431..47057b6 100644 --- a/src/server/db/database.hpp +++ b/src/server/db/database.hpp @@ -14,6 +14,7 @@ namespace sosc { namespace db { class Query; +typedef std::vector Queries; class ResultSet { public: diff --git a/src/server/hosts/master.hpp b/src/server/hosts/master.hpp index 7b83302..3acc43b 100644 --- a/src/server/hosts/master.hpp +++ b/src/server/hosts/master.hpp @@ -18,7 +18,7 @@ namespace sosc { class MasterClient { public: explicit MasterClient(const ScapeConnection& client); - bool Process(const Queries* queries); + bool Process(const db::Queries* queries); bool Close(); bool Close(const Packet& message); @@ -40,11 +40,11 @@ private: class MasterClientPool : public Pool { protected: - void SetupQueries(Queries* queries) override; + void SetupQueries(db::Queries* queries) override; bool ProcessClient( MasterClient& client, ctx::MasterClientContext* context, - const Queries* queries) override + const db::Queries* queries) override { return client.Process(queries); } @@ -55,7 +55,7 @@ protected: class MasterIntra { public: explicit MasterIntra(const IntraClient& client); - bool Process(const Queries* queries); + bool Process(const db::Queries* queries); bool Close(); bool Close(const Packet& message); @@ -87,16 +87,16 @@ private: int32_t server_id; std::string license; - const Queries* queries; + const db::Queries* queries; }; class MasterIntraPool : public Pool { protected: - void SetupQueries(Queries* queries) override; + void SetupQueries(db::Queries* queries) override; bool ProcessClient (MasterIntra& client, ctx::MasterIntraContext* context, - const Queries* queries) override + const db::Queries* queries) override { return client.Process(queries); } diff --git a/src/server/hosts/master_client.cpp b/src/server/hosts/master_client.cpp index 503ef47..0c6ef12 100644 --- a/src/server/hosts/master_client.cpp +++ b/src/server/hosts/master_client.cpp @@ -6,7 +6,7 @@ static struct { /** MASTERCLIENTPOOL CODE **/ -void sosc::MasterClientPool::SetupQueries(Queries *queries) { +void sosc::MasterClientPool::SetupQueries(db::Queries *queries) { #define QRY_USER_REG_CHECK 0 queries->push_back(new db::Query( "SELECT COUNT(*) FROM `USERS` " @@ -53,6 +53,6 @@ sosc::MasterClient::MasterClient(const ScapeConnection &client) { this->auth_attempts = 0; } -bool sosc::MasterClient::Process(const Queries *queries) { +bool sosc::MasterClient::Process(const db::Queries *queries) { } \ No newline at end of file diff --git a/src/server/hosts/master_intra.cpp b/src/server/hosts/master_intra.cpp index cd3256b..694145f 100644 --- a/src/server/hosts/master_intra.cpp +++ b/src/server/hosts/master_intra.cpp @@ -6,7 +6,7 @@ static struct { /** MASTERINTRAPOOL CODE **/ -void sosc::MasterIntraPool::SetupQueries(Queries* queries) { +void sosc::MasterIntraPool::SetupQueries(db::Queries* queries) { #define QRY_LICENSE_CHECK 0 queries->push_back(new db::Query( "SELECT COUNT(*) FROM `SERVER_LICENSES` " @@ -81,7 +81,7 @@ sosc::MasterIntra::MasterIntra(const IntraClient& client) { this->auth_attempts = 0; } -bool sosc::MasterIntra::Process(const Queries* queries) { +bool sosc::MasterIntra::Process(const db::Queries* queries) { Packet pck; int status = this->sock.Receive(&pck); if(status == PCK_ERR) diff --git a/src/server/hosts/slave.hpp b/src/server/hosts/slave.hpp index 019eb9f..d3c568b 100644 --- a/src/server/hosts/slave.hpp +++ b/src/server/hosts/slave.hpp @@ -20,7 +20,7 @@ protected: bool ProcessClient (SlaveClient& client, ctx::SlaveContext* context, - const Queries* queries) override + const db::Queries* queries) override { // TODO implement return true; diff --git a/src/server/sock/pool.hpp b/src/server/sock/pool.hpp index a8c1549..9da4dcd 100644 --- a/src/server/sock/pool.hpp +++ b/src/server/sock/pool.hpp @@ -8,7 +8,6 @@ #include "db/database.hpp" namespace sosc { -typedef std::vector Queries; typedef struct { // amount of threads to start with (never close) @@ -45,9 +44,9 @@ public: virtual void Stop(); protected: - virtual void SetupQueries(Queries* queries) {}; + virtual void SetupQueries(db::Queries* queries) {}; virtual bool ProcessClient - (T& client, U* context, const Queries* queries) = 0; + (T& client, U* context, const db::Queries* queries) = 0; private: bool IsStackFull(int stackCount) const; bool CanAddStack() const; @@ -69,7 +68,7 @@ private: private: void StackThread(); - Queries queries; + db::Queries queries; std::thread* thread; Pool* pool; bool is_open; @@ -83,7 +82,7 @@ private: bool is_open; U context; - Queries queries; + db::Queries queries; std::vector stacks; friend class Stack;