Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
8 changes: 4 additions & 4 deletions example/main.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -6,17 +6,17 @@ int main(int argc, char **argv) {
connection.port = 80;

mochios::Client client(connection);
client.interceptors.request.use([](mochios::message::Request &request) {
client.interceptors.request.use([](mochios::messages::Request &request) {
logger::info("Intercepting request!");
request.print();
});
mochios::message::Response response;
mochios::messages::Response response;

mochios::message::Request healthRequest("/health");
mochios::messages::Request healthRequest("/health");
response = client.get(healthRequest);
logger::success(response.body);

mochios::message::Request request("/about");
mochios::messages::Request request("/about");
response = client.get(request);
logger::success(response.body.dumps(2));

Expand Down
16 changes: 8 additions & 8 deletions include/mochios/client/client.h
Original file line number Diff line number Diff line change
Expand Up @@ -21,21 +21,21 @@ class Client {
mochios::client::Connection connection;

void connect();
mochios::message::Response sendHelper(mochios::message::Request &request);
mochios::messages::Response sendHelper(mochios::messages::Request &request);

public:
Client(const mochios::client::Connection &connection);
~Client();

mochios::interceptor::Interceptors interceptors;

mochios::message::Response get(mochios::message::Request &request);
mochios::message::Response post(mochios::message::Request &request);
mochios::message::Response put(mochios::message::Request &request);
mochios::message::Response patch(mochios::message::Request &request);
mochios::message::Response del(mochios::message::Request &request);
mochios::message::Response options(mochios::message::Request &request);
mochios::message::Response head(mochios::message::Request &request);
mochios::messages::Response get(mochios::messages::Request &request);
mochios::messages::Response post(mochios::messages::Request &request);
mochios::messages::Response put(mochios::messages::Request &request);
mochios::messages::Response patch(mochios::messages::Request &request);
mochios::messages::Response del(mochios::messages::Request &request);
mochios::messages::Response options(mochios::messages::Request &request);
mochios::messages::Response head(mochios::messages::Request &request);
};

} // namespace mochios
10 changes: 5 additions & 5 deletions include/mochios/helpers/client.h
Original file line number Diff line number Diff line change
Expand Up @@ -8,20 +8,20 @@
#include <brewtils/url.h>

#include <mochios/enums/method.h>
#include <mochios/message/request.h>
#include <mochios/message/response.h>
#include <mochios/messages/request.h>
#include <mochios/messages/response.h>

namespace mochios {

namespace helpers {

std::pair<std::string, std::string>
buildRequest(mochios::message::Request &request);
buildRequest(mochios::messages::Request &request);

void buildResponse(mochios::message::Response &res,
void buildResponse(mochios::messages::Response &res,
std::stringstream &response);

mochios::message::Response send(mochios::message::Request &request,
mochios::messages::Response send(mochios::messages::Request &request,
const int &socket);

} // namespace helpers
Expand Down
8 changes: 4 additions & 4 deletions include/mochios/interceptors/interceptor.h
Original file line number Diff line number Diff line change
Expand Up @@ -2,8 +2,8 @@

#include <functional>

#include <mochios/message/request.h>
#include <mochios/message/response.h>
#include <mochios/messages/request.h>
#include <mochios/messages/response.h>

namespace mochios {

Expand All @@ -30,8 +30,8 @@ template <typename T> class Manager {
};

typedef struct {
mochios::interceptor::Manager<mochios::message::Request> request;
mochios::interceptor::Manager<mochios::message::Response> response;
mochios::interceptor::Manager<mochios::messages::Request> request;
mochios::interceptor::Manager<mochios::messages::Response> response;
} Interceptors;

} // namespace interceptor
Expand Down
4 changes: 2 additions & 2 deletions include/mochios/interceptors/request/user_agent.h
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
#pragma once

#include <mochios/message/request.h>
#include <mochios/messages/request.h>
#include <mochios/version.h>

namespace mochios {
Expand All @@ -9,7 +9,7 @@ namespace interceptor {

namespace request {

void userAgent(mochios::message::Request &request);
void userAgent(mochios::messages::Request &request);

} // namespace request

Expand Down
4 changes: 2 additions & 2 deletions include/mochios/interceptors/response/json.h
Original file line number Diff line number Diff line change
Expand Up @@ -2,15 +2,15 @@

#include <json/parse.h>

#include <mochios/message/response.h>
#include <mochios/messages/response.h>

namespace mochios {

namespace interceptor {

namespace response {

void json(mochios::message::Response &response);
void json(mochios::messages::Response &response);

} // namespace response

Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@

namespace mochios {

namespace message {
namespace messages {

class Message {
private:
Expand All @@ -27,6 +27,6 @@ class Message {
virtual void print() = 0;
};

} // namespace message
} // namespace messages

} // namespace mochios
Original file line number Diff line number Diff line change
@@ -1,11 +1,11 @@
#pragma once

#include <mochios/enums/method.h>
#include <mochios/message/message.h>
#include <mochios/messages/message.h>

namespace mochios {

namespace message {
namespace messages {

class Request : public Message {
private:
Expand All @@ -19,6 +19,6 @@ class Request : public Message {
void print() override;
};

} // namespace message
} // namespace messages

} // namespace mochios
Original file line number Diff line number Diff line change
@@ -1,10 +1,10 @@
#pragma once

#include <mochios/message/message.h>
#include <mochios/messages/message.h>

namespace mochios {

namespace message {
namespace messages {

class Response : public Message {
private:
Expand All @@ -18,6 +18,6 @@ class Response : public Message {
void print() override;
};

} // namespace message
} // namespace messages

} // namespace mochios
38 changes: 19 additions & 19 deletions src/client/client.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -31,44 +31,44 @@ mochios::Client::~Client() {
return;
}

mochios::message::Response
mochios::Client::get(mochios::message::Request &request) {
mochios::messages::Response
mochios::Client::get(mochios::messages::Request &request) {
request.method = mochios::enums::method::GET;
return this->sendHelper(request);
}

mochios::message::Response
mochios::Client::post(mochios::message::Request &request) {
mochios::messages::Response
mochios::Client::post(mochios::messages::Request &request) {
request.method = mochios::enums::method::POST;
return this->sendHelper(request);
}

mochios::message::Response
mochios::Client::put(mochios::message::Request &request) {
mochios::messages::Response
mochios::Client::put(mochios::messages::Request &request) {
request.method = mochios::enums::method::PUT;
return this->sendHelper(request);
}

mochios::message::Response
mochios::Client::patch(mochios::message::Request &request) {
mochios::messages::Response
mochios::Client::patch(mochios::messages::Request &request) {
request.method = mochios::enums::method::PATCH;
return this->sendHelper(request);
}

mochios::message::Response
mochios::Client::del(mochios::message::Request &request) {
mochios::messages::Response
mochios::Client::del(mochios::messages::Request &request) {
request.method = mochios::enums::method::DELETE;
return this->sendHelper(request);
}

mochios::message::Response
mochios::Client::options(mochios::message::Request &request) {
mochios::messages::Response
mochios::Client::options(mochios::messages::Request &request) {
request.method = mochios::enums::method::OPTIONS;
return this->sendHelper(request);
}

mochios::message::Response
mochios::Client::head(mochios::message::Request &request) {
mochios::messages::Response
mochios::Client::head(mochios::messages::Request &request) {
request.method = mochios::enums::method::HEAD;
return this->sendHelper(request);
}
Expand All @@ -92,19 +92,19 @@ void mochios::Client::connect() {
}
}

mochios::message::Response
mochios::Client::sendHelper(mochios::message::Request &request) {
mochios::messages::Response
mochios::Client::sendHelper(mochios::messages::Request &request) {
request.set("Host", this->connection.host);
request.set("Accept", "*/*");
request.set("Connection", "close");
for (const std::function<void(mochios::message::Request &)>
for (const std::function<void(mochios::messages::Request &)>
&requestInterceptor : this->interceptors.request.interceptors) {
requestInterceptor(request);
}
this->connect();
mochios::message::Response res =
mochios::messages::Response res =
mochios::helpers::send(request, this->socket);
for (const std::function<void(mochios::message::Response &)>
for (const std::function<void(mochios::messages::Response &)>
&responseInterceptor : this->interceptors.response.interceptors) {
responseInterceptor(res);
}
Expand Down
18 changes: 9 additions & 9 deletions src/helpers/client.cpp
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
#include <mochios/helpers/client.h>

std::pair<std::string, std::string>
mochios::helpers::buildRequest(mochios::message::Request &request) {
mochios::helpers::buildRequest(mochios::messages::Request &request) {
std::ostringstream oss;
oss << request.method << " " << request.path;
if (request.queries.size() > 0) {
Expand Down Expand Up @@ -35,7 +35,7 @@ mochios::helpers::buildRequest(mochios::message::Request &request) {
return std::make_pair(oss.str(), jsonifiedBody);
}

void mochios::helpers::buildResponse(mochios::message::Response &res,
void mochios::helpers::buildResponse(mochios::messages::Response &res,
std::stringstream &response) {
std::string line;

Expand All @@ -61,24 +61,24 @@ void mochios::helpers::buildResponse(mochios::message::Response &res,
return;
}

mochios::message::Response
mochios::helpers::send(mochios::message::Request &request, const int &socket) {
mochios::messages::Response
mochios::helpers::send(mochios::messages::Request &request, const int &socket) {
std::pair<std::string, std::string> requestString =
mochios::helpers::buildRequest(request);
if (brewtils::sys::send(socket, requestString.first.c_str(),
requestString.first.size(), 0) < 0) {
logger::error("Error sending request headers",
"mochios::message::Response "
"mochios::helpers::send(mochios::message::Request &request, "
"mochios::messages::Response "
"mochios::helpers::send(mochios::messages::Request &request, "
"const mochios::enums::method &method, const int &socket)");
}
if (requestString.second.size() > 0) {
if (brewtils::sys::send(socket, requestString.second.c_str(),
requestString.second.size(), 0) < 0) {
logger::error(
"Error sending request body",
"mochios::message::Response "
"mochios::helpers::send(mochios::message::Request &request, "
"mochios::messages::Response "
"mochios::helpers::send(mochios::messages::Request &request, "
"const mochios::enums::method &method, const int &socket)");
}
}
Expand All @@ -92,7 +92,7 @@ mochios::helpers::send(mochios::message::Request &request, const int &socket) {
}
close(socket);

mochios::message::Response res;
mochios::messages::Response res;
std::string line;
std::getline(oss, line);
std::vector<std::string> parts = brewtils::string::split(line, " ");
Expand Down
2 changes: 1 addition & 1 deletion src/interceptors/request/user_agent.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -3,6 +3,6 @@
const std::string mochiosUserAgent = "mochios/" + mochios::version;

void mochios::interceptor::request::userAgent(
mochios::message::Request &request) {
mochios::messages::Request &request) {
request.set("User-Agent", mochiosUserAgent);
}
2 changes: 1 addition & 1 deletion src/interceptors/response/json.cpp
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
#include <mochios/interceptors/response/json.h>

void mochios::interceptor::response::json(
mochios::message::Response &response) {
mochios::messages::Response &response) {
if (response.get("content-type") != "application/json") {
return;
}
Expand Down
15 changes: 0 additions & 15 deletions src/message/message.cpp

This file was deleted.

15 changes: 15 additions & 0 deletions src/messages/message.cpp
Original file line number Diff line number Diff line change
@@ -0,0 +1,15 @@
#include <mochios/messages/message.h>

mochios::messages::Message::Message() { return; }

mochios::messages::Message::~Message() { return; }

void mochios::messages::Message::set(const std::string &key,
const std::string &value) {
this->headers[brewtils::string::lower(key)] = value;
return;
}

const std::string mochios::messages::Message::get(const std::string &key) const {
return this->headers.at(brewtils::string::lower(key));
}
Loading
Loading