1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
|
#ifndef CPR_TEST_HTTP_SERVER_H
#define CPR_TEST_HTTP_SERVER_H
#include <string>
#include "abstractServer.hpp"
#include "mongoose.h"
namespace cpr {
class HttpServer : public AbstractServer {
public:
~HttpServer() override = default;
std::string GetBaseUrl() override;
uint16_t GetPort() override;
void OnRequest(mg_connection* conn, mg_http_message* msg) override;
/**
* Returns the current date and time + 100 hours from when this function was invoked for the first time.
**/
static std::chrono::system_clock::time_point GetCookieExpiresIn100HoursTimePoint();
/**
* Returns the current date and time + 100 hours from when this function (or better GetCookieExpiresIn100HoursTimePoint()) was invoked for the first time as cookies expires string.
* For example: Wed, 30 Sep 2093 03:18:00 GMT
**/
static std::string GetCookieExpiresIn100HoursString();
private:
static void OnRequestHello(mg_connection* conn, mg_http_message* msg);
static void OnRequestRoot(mg_connection* conn, mg_http_message* msg);
static void OnRequestOptions(mg_connection* conn, mg_http_message* msg);
static void OnRequestNotFound(mg_connection* conn, mg_http_message* msg);
static void OnRequestTimeout(mg_connection* conn, mg_http_message* msg);
static void OnRequestLongTimeout(mg_connection* conn, mg_http_message* msg);
static void OnRequestLowSpeedTimeout(mg_connection* conn, mg_http_message* msg, TimerArg* arg);
static void OnRequestLowSpeed(mg_connection* conn, mg_http_message* msg, mg_mgr* mgr);
static void OnRequestLowSpeedBytes(mg_connection* conn, mg_http_message* msg, TimerArg* arg);
static void OnRequestBasicCookies(mg_connection* conn, mg_http_message* msg);
static void OnRequestEmptyCookies(mg_connection* conn, mg_http_message* msg);
static void OnRequestCookiesReflect(mg_connection* conn, mg_http_message* msg);
static void OnRequestRedirectionWithChangingCookies(mg_connection* conn, mg_http_message* msg);
static void OnRequestBasicAuth(mg_connection* conn, mg_http_message* msg);
static void OnRequestBearerAuth(mg_connection* conn, mg_http_message* msg);
static void OnRequestBasicJson(mg_connection* conn, mg_http_message* msg);
static void OnRequestHeaderReflect(mg_connection* conn, mg_http_message* msg);
static void OnRequestTempRedirect(mg_connection* conn, mg_http_message* msg);
static void OnRequestPermRedirect(mg_connection* conn, mg_http_message* msg);
static void OnRequestResolvePermRedirect(mg_connection* conn, mg_http_message* msg);
static void OnRequestTwoRedirects(mg_connection* conn, mg_http_message* msg);
static void OnRequestUrlPost(mg_connection* conn, mg_http_message* msg);
static void OnRequestPostReflect(mg_connection* conn, mg_http_message* msg);
static void OnRequestBodyGet(mg_connection* conn, mg_http_message* msg);
static void OnRequestJsonPost(mg_connection* conn, mg_http_message* msg);
static void OnRequestFormPost(mg_connection* conn, mg_http_message* msg);
static void OnRequestFileUploadPost(mg_connection* conn, mg_http_message* msg);
static void OnRequestDelete(mg_connection* conn, mg_http_message* msg);
static void OnRequestDeleteNotAllowed(mg_connection* conn, mg_http_message* msg);
static void OnRequestPut(mg_connection* conn, mg_http_message* msg);
static void OnRequestPutNotAllowed(mg_connection* conn, mg_http_message* msg);
static void OnRequestPatch(mg_connection* conn, mg_http_message* msg);
static void OnRequestPatchNotAllowed(mg_connection* conn, mg_http_message* msg);
static void OnRequestDownloadGzip(mg_connection* conn, mg_http_message* msg);
static void OnRequestLocalPort(mg_connection* conn, mg_http_message* msg);
static void OnRequestCheckAcceptEncoding(mg_connection* conn, mg_http_message* msg);
static void OnRequestCheckExpect100Continue(mg_connection* conn, mg_http_message* msg);
static void OnRequestGetDownloadFileLength(mg_connection* conn, mg_http_message* msg);
protected:
mg_connection* initServer(mg_mgr* mgr, mg_event_handler_t event_handler) override;
void acceptConnection(mg_connection* conn) override;
};
} // namespace cpr
#endif
|
