141 lines
4.3 KiB
C++
141 lines
4.3 KiB
C++
#include "pihttpclient.h"
|
|
#include "pip.h"
|
|
|
|
using namespace PICoutManipulators;
|
|
|
|
PIKbdListener kbd;
|
|
const char * pageTitle = "<!DOCTYPE html>"
|
|
"<html>"
|
|
"<body>"
|
|
"<h1>Title</h1>"
|
|
"</body>"
|
|
"</html>";
|
|
|
|
template<typename T>
|
|
PIString stringify(const T & v) {
|
|
PIString ret;
|
|
PICout::withExternalBuffer(&ret, 0, PICoutManipulators::AddSpaces) << v;
|
|
return ret;
|
|
}
|
|
|
|
int main(int argc, char * argv[]) {
|
|
PIHTTPServer server;
|
|
server.listen({"127.0.0.1:7777"});
|
|
server.setBasicAuthRealm("pip");
|
|
server.setBasicAuthEnabled(true);
|
|
server.setBasicAuthCallback([](const PIString & u, const PIString & p) -> bool {
|
|
piCout << "basic auth" << u << p;
|
|
return (u == "u" && p == "p");
|
|
});
|
|
server.registerUnhandled([](const PIHTTP::MessageConst & msg) -> PIHTTP::MessageMutable {
|
|
PIHTTP::MessageMutable ret;
|
|
piCout << "server rec:\n\tpath: %1\n\tmethod: %2\n\targs: %3\n\theaders: %4\n\tbody: %5\n"_a.arg(msg.path())
|
|
.arg((int)msg.method())
|
|
.arg(stringify(msg.arguments()))
|
|
.arg(PIStringList(msg.headers().map<PIString>([](PIString k, PIString v) { return k + " = " + v; })).join("\n\t\t"))
|
|
.arg(PIString::fromUTF8(msg.body()));
|
|
ret.setCode(PIHTTP::Code::BadRequest);
|
|
ret.setBody(PIByteArray::fromAscii("hello client! 0123456789"));
|
|
return ret;
|
|
});
|
|
|
|
PIHTTP::MessageMutable req;
|
|
req.setBody(PIByteArray::fromAscii("hello server!"));
|
|
auto * c = PIHTTPClient::create("http://u:p@127.0.0.1:7777/api", PIHTTP::Method::Get, req);
|
|
c->onFinish([](PIHTTP::MessageConst msg) {
|
|
piCout << "client rec:\n\tcode: %5\n\tpath: %1\n\tmethod: %2\n\targs: %3\n\tbody: %4\n"_a.arg(msg.path())
|
|
.arg((int)msg.method())
|
|
.arg(stringify(msg.arguments()))
|
|
.arg(PIString::fromUTF8(msg.body()))
|
|
.arg((int)msg.code());
|
|
})
|
|
->onError([c](PIHTTP::MessageConst r) {
|
|
piCout << "error" << (int)r.code();
|
|
piCout << "msg" << c->lastError();
|
|
})
|
|
->onAbort([c](PIHTTP::MessageConst r) {
|
|
piCout << "abort" << (int)r.code();
|
|
piCout << "msg" << c->lastError();
|
|
})
|
|
->start();
|
|
|
|
// piMSleep(500);
|
|
kbd.enableExitCapture();
|
|
WAIT_FOR_EXIT
|
|
|
|
server.stop();
|
|
// c->abort();
|
|
|
|
return 0;
|
|
|
|
// piCout << PIString::readableSize(PISystemMonitor::usedRAM());
|
|
|
|
/*PIVector<int> vi;
|
|
piForTimes(10) {
|
|
piSleep(2.);
|
|
vi.enlarge(1000000);
|
|
piCout << "now" << vi.size() << vi.capacity();
|
|
}
|
|
|
|
piSleep(5.);*/
|
|
/*kbd.enableExitCapture();
|
|
|
|
PIHTTPServer server;
|
|
|
|
server.setFavicon(PIFile::readAll("logo.png", false));
|
|
// server.setOption(MicrohttpdServer::Option::HTTPSEnabled, true);
|
|
server.listen({"127.0.0.1", 7777});
|
|
// server.listen({"192.168.1.10", 7778});
|
|
|
|
server.registerPath("/", MicrohttpdServer::Method::Get, [](const MicrohttpdServer::Request & r) -> MicrohttpdServer::Reply {
|
|
MicrohttpdServer::Reply ret;
|
|
ret.setBody(PIByteArray::fromAscii(pageTitle));
|
|
return ret;
|
|
});
|
|
|
|
server.registerPath("/html", MicrohttpdServer::Method::Get, [](const MicrohttpdServer::Request & r) -> MicrohttpdServer::Reply {
|
|
MicrohttpdServer::Reply ret;
|
|
ret.setBody("<!DOCTYPE html><html><body><p>arg=%1</p></body></html>"_a.arg(r.args.value("a0")).toUTF8());
|
|
return ret;
|
|
});
|
|
|
|
server.registerPath("/api", MicrohttpdServer::Method::Put, [](const MicrohttpdServer::Request & r) -> MicrohttpdServer::Reply {
|
|
MicrohttpdServer::Reply ret;
|
|
ret.setBody(PIByteArray::fromAscii("<!DOCTYPE html><html><body>API</body></html>"));
|
|
return ret;
|
|
});
|
|
|
|
server.registerPath("/api/", MicrohttpdServer::Method::Post, [](const MicrohttpdServer::Request & r) -> MicrohttpdServer::Reply {
|
|
MicrohttpdServer::Reply ret;
|
|
ret.setBody("<!DOCTYPE html><html><body>API etry %1</body></html>"_a.arg(r.path).toUTF8());
|
|
ret.setCode(405);
|
|
return ret;
|
|
});
|
|
|
|
server.registerUnhandled([](const MicrohttpdServer::Request & r) -> MicrohttpdServer::Reply {
|
|
MicrohttpdServer::Reply ret;
|
|
ret.setBody("<!DOCTYPE html><html><body>Unknown</body></html>"_a.arg(r.path).toUTF8());
|
|
ret.setCode(404);
|
|
return ret;
|
|
});*/
|
|
|
|
/*server.setRequestCallback([](MicrohttpdServer::Request r) -> MicrohttpdServer::Reply {
|
|
MicrohttpdServer::Reply rep;
|
|
piCout << "request" << r.path;
|
|
piCout << " header" << r.headers;
|
|
piCout << " args" << r.args;
|
|
piCout << " body" << r.body;
|
|
piCout << "";
|
|
rep.setBody(PIByteArray::fromAscii("[{\"value1\": true, \"value2\": \"ыекштп\"}]"));
|
|
return rep;
|
|
});*/
|
|
|
|
/*piCout << "start" << server.isListen();
|
|
|
|
WAIT_FOR_EXIT
|
|
|
|
server.stop();*/
|
|
|
|
return 0;
|
|
}
|