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
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
|
// Copyright Maarten L. Hekkelman 2026
// Distributed under the Boost Software License, Version 1.0.
// (See accompanying file LICENSE_1_0.txt or copy at
// http://www.boost.org/LICENSE_1_0.txt)
#include "client-test-code.hpp"
#include "zeep/http/controller.hpp"
#include "zeep/http/daemon.hpp"
#include "zeep/http/reply.hpp"
#include "zeep/http/server.hpp"
#include <catch2/catch_test_macros.hpp>
#include <cstdint>
#include <filesystem>
#include <iostream>
#include <pwd.h>
#include <random>
#include <string>
#include <thread>
#include <unistd.h>
namespace zh = zeep::http;
// a very simple controller, serving only /test/one and /test/three
class my_controller : public zh::controller
{
public:
my_controller()
: zh::controller("/")
{
map_get_request("test", &my_controller::test);
}
zh::reply test()
{
return { zh::status_type::ok };
}
};
TEST_CASE("daemon-test-1")
{
// start up a http server and stop it again
std::filesystem::path log_dir = std::filesystem::temp_directory_path() / "daemon-test";
std::filesystem::remove_all(log_dir);
std::filesystem::create_directories(log_dir);
std::filesystem::path access_file, error_file;
access_file = log_dir / "access.log";
error_file = log_dir / "error.log";
auto pw = getpwuid(getuid());
REQUIRE(pw != nullptr);
zh::daemon d([]()
{
auto s = new zh::server;
s->add_controller(new my_controller());
return s; },
log_dir / "daemon-test.pid",
access_file.string(),
error_file.string());
std::random_device rng;
uint16_t port = 1024 + (rng() % 10240);
std::clog << "starting daemon at port " << port << '\n';
SECTION("single process")
{
d.start("::", port, 1, pw->pw_name);
}
SECTION("pre-forked process")
{
d.start("::", port, 1, 1, pw->pw_name);
}
using namespace std::chrono_literals;
std::this_thread::sleep_for(100ms);
auto reply = simple_request(port, "GET /test HTTP/1.0\r\n\r\n");
CHECK(reply.get_status() == zh::status_type::ok);
std::filesystem::rename(access_file, log_dir / "access.log.1");
std::filesystem::rename(error_file, log_dir / "error.log.1");
d.reload();
std::this_thread::sleep_for(100ms);
reply = simple_request(port, "GET /test HTTP/1.0\r\n\r\n");
CHECK(reply.get_status() == zh::status_type::ok);
d.stop();
CHECK(std::filesystem::file_size(access_file) > 0);
CHECK(std::filesystem::file_size(error_file) > 0);
}
|
