SNode.C
Loading...
Searching...
No Matches
jsonclient.cpp File Reference
Include dependency graph for jsonclient.cpp:

Go to the source code of this file.

Functions

int main (int argc, char *argv[])
 

Function Documentation

◆ main()

int main ( int  argc,
char *  argv[] 
)

Definition at line 53 of file jsonclient.cpp.

53 {
54 core::SNodeC::init(argc, argv);
55
57 using Request = Client::Request;
58 using Response = Client::Response;
59 using SocketAddress = Client::SocketAddress;
60
61 const Client jsonClient(
62 "legacy",
63 [](const std::shared_ptr<Request>& req) {
64 VLOG(1) << "-- OnRequest";
65 req->method = "POST";
66 req->url = "/index.html";
67 req->type("application/json");
68 req->set("Connection", "close");
69 req->send("{\"userId\":1,\"schnitzel\":\"good\",\"hungry\":false}",
70 []([[maybe_unused]] const std::shared_ptr<Request>& req, const std::shared_ptr<Response>& res) {
71 VLOG(1) << "-- OnResponse";
72 VLOG(1) << " Status:";
73 VLOG(1) << " " << res->httpVersion;
74 VLOG(1) << " " << res->statusCode;
75 VLOG(1) << " " << res->reason;
76
77 VLOG(1) << " Headers:";
78 for (const auto& [field, value] : res->headers) {
79 VLOG(1) << " " << field + " = " + value;
80 }
81
82 VLOG(1) << " Cookies:";
83 for (const auto& [name, cookie] : res->cookies) {
84 VLOG(1) << " " + name + " = " + cookie.getValue();
85 for (const auto& [option, value] : cookie.getOptions()) {
86 VLOG(1) << " " + option + " = " + value;
87 }
88 }
89
90 res->body.push_back(0);
91 VLOG(1) << " Body:\n----------- start body -----------" << res->body.data()
92 << "------------ end body ------------";
93 });
94 },
95 []([[maybe_unused]] const std::shared_ptr<Request>& req) {
96 LOG(INFO) << " -- OnRequestEnd";
97 });
98
99 jsonClient.connect("localhost",
100 8080,
101 [instanceName = jsonClient.getConfig().getInstanceName()](
102 const SocketAddress& socketAddress,
103 const core::socket::State& state) { // example.com:81 simulate connect timeout
104 switch (state) {
106 VLOG(1) << instanceName << ": connected to '" << socketAddress.toString() << "'";
107 break;
109 VLOG(1) << instanceName << ": disabled";
110 break;
112 LOG(ERROR) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
113 break;
115 LOG(FATAL) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
116 break;
117 }
118 });
119 /*
120 jsonClient.connect("localhost",
121 8080,
122 [instanceName = jsonClient.getConfig().getInstanceName()](
123 const SocketAddress& socketAddress,
124 const core::socket::State& state) { // example.com:81 simulate connnect timeout
125 switch (state) {
126 case core::socket::State::OK:
127 VLOG(1) << instanceName << ": connected to '" << socketAddress.toString() << "'";
128 break;
129 case core::socket::State::DISABLED:
130 VLOG(1) << instanceName << ": disabled";
131 break;
132 case core::socket::State::ERROR:
133 LOG(ERROR) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
134 break;
135 case core::socket::State::FATAL:
136 LOG(FATAL) << instanceName << ": " << socketAddress.toString() << ": " << state.what();
137 break;
138 }
139 });
140 */
141 /*
142 jsonClient.post("localhost", 8080, "/index.html", "{\"userId\":1,\"schnitzel\":\"good\",\"hungry\":false}", [](int err) {
143 if (err != 0) {
144 PLOG(ERROR) << "OnError: " << err;
145 }
146 });
147 */
148
149 return core::SNodeC::start();
150}
static void init(int argc, char *argv[])
Definition SNodeC.cpp:54
static int start(const utils::Timeval &timeOut={LONG_MAX, 0})
Definition SNodeC.cpp:60
static constexpr int DISABLED
Definition State.h:56
static constexpr int ERROR
Definition State.h:57
static constexpr int FATAL
Definition State.h:58
static constexpr int OK
Definition State.h:55
Client::Response Response
Definition clients.h:87
Client::Request Request
Definition clients.h:86
web::http::legacy::NET::Client Client
Definition clients.h:85
SocketClient::SocketAddress SocketAddress
web::http::client::Client< net::in::stream::legacy::SocketClient > Client
Definition Client.h:54

References web::http::client::Response::body, web::http::client::Client< SocketClientT >::Client(), net::in::stream::SocketClient< SocketConnectorT, ConfigSocketClientT, SocketContextFactoryT, Args >::connect(), web::http::client::Response::cookies, core::socket::State::DISABLED, core::socket::State::ERROR, core::socket::State::FATAL, core::socket::Socket< ConfigT >::getConfig(), net::config::ConfigInstance::getInstanceName(), web::http::CookieOptions::getOptions(), web::http::CookieOptions::getValue(), web::http::client::Response::headers, web::http::client::Response::httpVersion, core::SNodeC::init(), web::http::client::Request::method, core::socket::State::OK, web::http::client::Response::reason, web::http::client::Request::send(), web::http::client::Request::set(), core::SNodeC::start(), web::http::client::Response::statusCode, net::in::SocketAddress::toString(), web::http::client::Request::type(), web::http::client::Request::url, and core::socket::State::what().

Here is the call graph for this function: