Added default GET-example
This commit is contained in:
parent
a2b9412371
commit
4c4ae6ac09
4 changed files with 98 additions and 14 deletions
55
main.cpp
55
main.cpp
|
|
@ -4,6 +4,8 @@
|
||||||
#include <boost/property_tree/ptree.hpp>
|
#include <boost/property_tree/ptree.hpp>
|
||||||
#include <boost/property_tree/json_parser.hpp>
|
#include <boost/property_tree/json_parser.hpp>
|
||||||
|
|
||||||
|
#include<fstream>
|
||||||
|
|
||||||
using namespace std;
|
using namespace std;
|
||||||
using namespace SimpleWeb;
|
using namespace SimpleWeb;
|
||||||
//Added for the json-example:
|
//Added for the json-example:
|
||||||
|
|
@ -46,9 +48,9 @@ int main() {
|
||||||
}
|
}
|
||||||
};
|
};
|
||||||
|
|
||||||
//GET-example for the path /
|
//GET-example for the path /info
|
||||||
//Responds with request-information
|
//Responds with request-information
|
||||||
httpserver.resources["^/$"]["GET"]=[](ostream& response, const Request& request, const smatch& path_match) {
|
httpserver.resources["^/info/?$"]["GET"]=[](ostream& response, const Request& request, const smatch& path_match) {
|
||||||
stringstream content_stream;
|
stringstream content_stream;
|
||||||
content_stream << "<h1>Request:</h1>";
|
content_stream << "<h1>Request:</h1>";
|
||||||
content_stream << request.method << " " << request.path << " HTTP/" << request.http_version << "<br>";
|
content_stream << request.method << " " << request.path << " HTTP/" << request.http_version << "<br>";
|
||||||
|
|
@ -69,6 +71,55 @@ int main() {
|
||||||
response << "HTTP/1.1 200 OK\r\nContent-Length: " << number.length() << "\r\n\r\n" << number;
|
response << "HTTP/1.1 200 OK\r\nContent-Length: " << number.length() << "\r\n\r\n" << number;
|
||||||
};
|
};
|
||||||
|
|
||||||
|
//Default GET-example. If no other matches, this anonymous function will be called.
|
||||||
|
//Will respond with content in the web/-directory, and its subdirectories.
|
||||||
|
//Default file: index.html
|
||||||
|
//Can be used to retrieve an HTML 5 client using REST-resources on this server
|
||||||
|
httpserver.default_resource["^/?(.*)$"]["GET"]=[](ostream& response, const Request& request, const smatch& path_match) {
|
||||||
|
string filename="web/";
|
||||||
|
|
||||||
|
string path=path_match[1];
|
||||||
|
|
||||||
|
//Remove all but the last '.' (so we can't leave the web-directory)
|
||||||
|
size_t last_pos=path.rfind(".");
|
||||||
|
size_t current_pos=0;
|
||||||
|
size_t pos;
|
||||||
|
while((pos=path.find('.', current_pos))!=string::npos && pos!=last_pos) {
|
||||||
|
cout << pos << endl;
|
||||||
|
current_pos=pos;
|
||||||
|
path.erase(pos, 1);
|
||||||
|
last_pos--;
|
||||||
|
}
|
||||||
|
|
||||||
|
filename+=path;
|
||||||
|
ifstream ifs;
|
||||||
|
//HTTP file-or-directory check:
|
||||||
|
if(filename.find('.')!=string::npos) {
|
||||||
|
ifs.open(filename, ifstream::in);
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
if(filename[filename.length()-1]!='/')
|
||||||
|
filename+='/';
|
||||||
|
filename+="index.html";
|
||||||
|
ifs.open(filename, ifstream::in);
|
||||||
|
}
|
||||||
|
|
||||||
|
if(ifs) {
|
||||||
|
ifs.seekg(0, ios::end);
|
||||||
|
size_t length=ifs.tellg();
|
||||||
|
|
||||||
|
ifs.seekg(0, ios::beg);
|
||||||
|
|
||||||
|
response << "HTTP/1.1 200 OK\r\nContent-Length: " << length << "\r\n\r\n" << ifs.rdbuf();
|
||||||
|
|
||||||
|
ifs.close();
|
||||||
|
}
|
||||||
|
else {
|
||||||
|
string content="Could not open file "+filename;
|
||||||
|
response << "HTTP/1.1 400 Bad Request\r\nContent-Length: " << content.length() << "\r\n\r\n" << content;
|
||||||
|
}
|
||||||
|
};
|
||||||
|
|
||||||
//Start HTTP-server
|
//Start HTTP-server
|
||||||
httpserver.start();
|
httpserver.start();
|
||||||
|
|
||||||
|
|
|
||||||
35
server.hpp
35
server.hpp
|
|
@ -21,15 +21,28 @@ namespace SimpleWeb {
|
||||||
unordered_map<string, string> header;
|
unordered_map<string, string> header;
|
||||||
};
|
};
|
||||||
|
|
||||||
template <class type>
|
typedef map<string, unordered_map<string, function<void(ostream&, const Request&, const smatch&)> > > resource_type;
|
||||||
|
|
||||||
|
template <class socket_type>
|
||||||
class Server {
|
class Server {
|
||||||
public:
|
public:
|
||||||
unordered_map<string, unordered_map<string, function<void(ostream&, const Request&, const smatch&)> > > resources;
|
resource_type resources;
|
||||||
|
|
||||||
|
resource_type default_resource;
|
||||||
|
|
||||||
Server(unsigned short port, size_t num_threads=1) : endpoint(ip::tcp::v4(), port),
|
Server(unsigned short port, size_t num_threads=1) : endpoint(ip::tcp::v4(), port),
|
||||||
acceptor(m_io_service, endpoint), num_threads(num_threads) {}
|
acceptor(m_io_service, endpoint), num_threads(num_threads) {}
|
||||||
|
|
||||||
void start() {
|
void start() {
|
||||||
|
//All resources with default_resource at the end of vector
|
||||||
|
//Used in the respond-method
|
||||||
|
for(auto it=resources.begin(); it!=resources.end();it++) {
|
||||||
|
all_resources.push_back(it);
|
||||||
|
}
|
||||||
|
for(auto it=default_resource.begin(); it!=default_resource.end();it++) {
|
||||||
|
all_resources.push_back(it);
|
||||||
|
}
|
||||||
|
|
||||||
accept();
|
accept();
|
||||||
|
|
||||||
//If num_threads>1, start m_io_service.run() in (num_threads-1) threads for thread-pooling
|
//If num_threads>1, start m_io_service.run() in (num_threads-1) threads for thread-pooling
|
||||||
|
|
@ -55,10 +68,14 @@ namespace SimpleWeb {
|
||||||
size_t num_threads;
|
size_t num_threads;
|
||||||
vector<thread> threads;
|
vector<thread> threads;
|
||||||
|
|
||||||
|
//All resources with default_resource at the end of vector
|
||||||
|
//Created in start()
|
||||||
|
vector<resource_type::iterator> all_resources;
|
||||||
|
|
||||||
void accept() {
|
void accept() {
|
||||||
//Create new socket for this connection
|
//Create new socket for this connection
|
||||||
//Shared_ptr is used to pass temporary objects to the asynchronous functions
|
//Shared_ptr is used to pass temporary objects to the asynchronous functions
|
||||||
shared_ptr<type> socket(new type(m_io_service));
|
shared_ptr<socket_type> socket(new socket_type(m_io_service));
|
||||||
|
|
||||||
acceptor.async_accept(*socket, [this, socket](const boost::system::error_code& ec) {
|
acceptor.async_accept(*socket, [this, socket](const boost::system::error_code& ec) {
|
||||||
//Immediately start accepting a new connection
|
//Immediately start accepting a new connection
|
||||||
|
|
@ -70,7 +87,7 @@ namespace SimpleWeb {
|
||||||
});
|
});
|
||||||
}
|
}
|
||||||
|
|
||||||
void process_request_and_respond(shared_ptr<type> socket) {
|
void process_request_and_respond(shared_ptr<socket_type> socket) {
|
||||||
//Create new read_buffer for async_read_until()
|
//Create new read_buffer for async_read_until()
|
||||||
//Shared_ptr is used to pass temporary objects to the asynchronous functions
|
//Shared_ptr is used to pass temporary objects to the asynchronous functions
|
||||||
shared_ptr<boost::asio::streambuf> read_buffer(new boost::asio::streambuf);
|
shared_ptr<boost::asio::streambuf> read_buffer(new boost::asio::streambuf);
|
||||||
|
|
@ -144,16 +161,16 @@ namespace SimpleWeb {
|
||||||
return request;
|
return request;
|
||||||
}
|
}
|
||||||
|
|
||||||
void respond(shared_ptr<type> socket, shared_ptr<Request> request) {
|
void respond(shared_ptr<socket_type> socket, shared_ptr<Request> request) {
|
||||||
//Find path- and method-match, and generate response
|
//Find path- and method-match, and generate response
|
||||||
for(auto& res: resources) {
|
for(auto res_it: all_resources) {
|
||||||
regex e(res.first);
|
regex e(res_it->first);
|
||||||
smatch sm_res;
|
smatch sm_res;
|
||||||
if(regex_match(request->path, sm_res, e)) {
|
if(regex_match(request->path, sm_res, e)) {
|
||||||
if(res.second.count(request->method)>0) {
|
if(res_it->second.count(request->method)>0) {
|
||||||
shared_ptr<boost::asio::streambuf> write_buffer(new boost::asio::streambuf);
|
shared_ptr<boost::asio::streambuf> write_buffer(new boost::asio::streambuf);
|
||||||
ostream response(write_buffer.get());
|
ostream response(write_buffer.get());
|
||||||
res.second[request->method](response, *request, sm_res);
|
res_it->second[request->method](response, *request, sm_res);
|
||||||
|
|
||||||
//Capture write_buffer in lambda so it is not destroyed before async_write is finished
|
//Capture write_buffer in lambda so it is not destroyed before async_write is finished
|
||||||
async_write(*socket, *write_buffer, [this, socket, request, write_buffer](const boost::system::error_code& ec, size_t bytes_transferred) {
|
async_write(*socket, *write_buffer, [this, socket, request, write_buffer](const boost::system::error_code& ec, size_t bytes_transferred) {
|
||||||
|
|
|
||||||
8
web/index.html
Normal file
8
web/index.html
Normal file
|
|
@ -0,0 +1,8 @@
|
||||||
|
<html>
|
||||||
|
<head>
|
||||||
|
<title>Simple-Web-Server html-file</title>
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
This is the content of index.html
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
8
web/test.html
Normal file
8
web/test.html
Normal file
|
|
@ -0,0 +1,8 @@
|
||||||
|
<html>
|
||||||
|
<head>
|
||||||
|
<title>Simple-Web-Server html-file</title>
|
||||||
|
</head>
|
||||||
|
<body>
|
||||||
|
This is the content of test.html
|
||||||
|
</body>
|
||||||
|
</html>
|
||||||
Loading…
Add table
Add a link
Reference in a new issue