flow:

framework layer:
httpd
ServiceHandler

application layer (not include in this framework):
ApplicationService
DomainService
Repository
dbdriver

example:

server.put(..., new ServiceHandler<Service, &Service::action>(conainer));

as title

This issue is for who wants to contribute to this project recently.
Because this project still in alpha stage, documents are not ready, this issue only contains simple descriptions and will close after project reached beta release (documents will be ready then).

Project Concept:

• Use seastar framework to manage io and tasks
  • seastar's share nothing design can elide thread locks and atomic operations
• Avoid copy by using std::string_view and seastar::net::packet (iovec)
• Create an advance web framework with modern architecture
  • middleware, di container, and modules

Progress (Completed Features):

• Handle http 1 connection with nodejs's http_parser (support pipeline)
• Middleware (HttpServerRequestHandlerBase)
• DI Container (support constructor dependency injection and scoped lifetime)

Performance:
See #14

Roadmap:
0.1

• (done) Improve performance
• (done) Add application class and module system (provide a neat api for users)
• (done) Add routing handler
• (done) Add routing module
• Add debian package
• Add examples (basic example)
• Add documents
• Add benchmark result

(For following versions see docs/Roadmap.md)

Contribution Guide:

• Use same code style as existing code (tab indent, no new line for {)
• Use c++17 (will upgrade to c++20 in future for coroutine support)
• Add test cases for each feature added

References:

• Seastar framework: https://github.com/scylladb/seastar
• Seastar framework tutorial: https://github.com/scylladb/seastar/blob/master/doc/tutorial.md

If you want to add major features not listed here, you can comment on this issue.

TBD

• Add metrics data for http client
• Add PrometheusModule

This project seems totally dead, but I thought I'd ask anyway. The design of the application class appears to presume that the cpv http server will be the only thing Seastar is running. One might want to additionally run an rpc endpoint (smf for example, but that also appears dead) or other custom Seastar code.

supported:
seastar::shared_ptr

to support:
seastar::lw_shared_ptr
std::shared_ptr
std::unique_ptr
Object

Would like to write a reverse proxy

HttpClient (interface, with vdtor)
HttpRequest (interface, with vdtor)
HttpResponse (interface, with vdtor)
HttpClientFactory (interface, with vdtor)
HttpClientImpl
HttpRequestImpl
HttpResponseImpl
HttpClientFactoryImpl (with (host,port) => client map)

example:

HttpClientFactory factory = HttpClientFactory::create();
seastar::shared_ptr<HttpClient> client = factory.create("localhost", 8000);
std::unique_ptr<HttpRequest> request = client.makeRequest("GET", "/index.html");
client.send(std::move(request)).then([] (std::unique_ptr<HttpResponse> response) { });

Moved to wiki.

• HelloWorld
• Container
  • Aop
• HttpClient
• HttpServer
• Logging
• Module
• Application
• Metrics
• Benchmark

type definition:

class Application
	class Service (implement in src)
		Container container
		std::vector<std::tuple<
			std::unique_ptr<ModuleBase>,
			std::function<void(ModuleBase*)>> modules
		bool initialized // disallow register after initialized (first start)
		seastar::future<> start()
		seastar::future<> stop()
	seastar::shared_ptr<seastar::shareded<Service>> service_

	template <class Module>
	void add()
	template <class Module>
	void add(std::function<void(Module&)> initFunc); // check static_cast<ModuleBase, Module> address is equal or not
	void add(std::unique_ptr<ModuleBase>, std::function<void(ModuleBase*)> initFunc); // implement in src

	seastar::future<> start() // should do_with copy of service_
	seastar::future<> stop() // should do_with copy of service_
	seastar::future<> run_forever() // should do_with copy of service_

	Application()

enum ApplicationState
	StartInitialize
	RegisterBasicServices
	BeforeCallCustomInitializeFunctions
	CallingCustomInitializeFunctions // dummy state, won't invoke module.handle
	AfterCustomInitializeFunctionsCalled
	RegisterHeadServices
	RegisterServices
	RegisterTailServices
	PatchServices
	AfterServicesRegistered
	AfterInitialized
	BeforeStart // will call for each start
	Starting // will call for each start
	AfterStarted // will call for each start
	BeforeStop // will call for each stop
	Stopping // will call for each stop
	AfterStopped // will call for each stop

class ModuleBase
	virtual ~ModuleBase() = default;
	virtual seastar::future<> handle(Container& container, ApplicationState state) = 0;

class HttpContext
	HttpRequest request
	HttpResponse response
	seastar::socket_address clientAddress
	Container container // shared by all concurrent requests on the same core
	ServiceStorage serviceStorage // used only in this request, clear after request finished

files to add:

Application
	Application.hpp
	ModuleBase.hpp
	Modules
		LoggingModule.hpp
		HttpServerModule.hpp
		HttpServerRoutingModule.hpp
Http
	HttpContext.hpp
HttpServer
	Handlers
		HttpServerRequestRoutingHandler.hpp
		HttpServerRequestFunctionHandler.hpp
		HttpServerRequestStaticFileHandler.hpp
	Routing
		HttpServerRouteTable.hpp
		HttpServerRouteHandlerBase.hpp
		HttpServerRouteFunctionHandler.hpp
		HttpServerRouteControllerHandler.hpp

api usage:

using namespace cpv;
Application app;
app.add<LoggingModule>([] (auto& module) {
	module.setLogger(Logger::CreateConsole(LogLevel::Info));
});
app.add<HttpServerModule>([] (auto& module) {
	auto& config = module.getConfig();
	config.setListenAddresses({ "0.0.0.0:80" });
	config.set404Handler([] (HttpResponse& response) {
		return extensions::redirectTo(response, "/404");
	});
});
app.add<HttpServerStaticFileModule>([] (auto& module) {
	module.map("/static", "./static");
});
app.add<HttpServerRoutingModule>([] (auto& module) {
        using namespace cpv::constants;
	auto& routeTable = module.getRouteTable();
	routeTable.route(GET, "/", [] (HttpResponse& response) {
		return extensions::replyStaticText(response, "Hello World!");
	});
	routeTable.route(GET, "/hello", [] (HttpResponse& response) {
		return extensions::replyString(response, "Hello!");
	});
	// TODO: handle url matching and parse parts
	// TODO: handle dependency injection (controller)
});
app.add<ExampleModule>();
return app.run_forever()

addition:

rules
- request handler could use container and storage inside http context to get services
- route handler holds controller and decide which action to execute
    - api: route(GET, "/", [] (HttpContext& context) { ... })
    - example:
        - route function handler<Func> { operate()(HttpContext& context) { f(context) } Func f; }
        - route controller handler <Controller, Action, Service...> { operator()(HttpContext& context) { c->*action(context, service...) } Controller c; }

as for cql driver

Able to override factories in container for custom proxy types

https://github.com/pantor/inja/blob/master/src/inja.hpp

• Add template handler
• Support resolve Environment from container (replaceable)
• Support cache parsed Template by path

Hello,

I ran Main.cpp file in the example section. But I am getting the following segmentation fault.

WARN 2022-06-16 15:50:23,732 [shard 0] seastar - Creation of perf_event based stall detector failed, falling back to posix timer: std::system_error (error system:13, perf_event_open() failed: Permission denied)
WARN 2022-06-16 15:50:23,734 [shard 0] seastar - Unable to set SCHED_FIFO scheduling policy for timer thread; latency impact possible. Try adding CAP_SYS_NICE
DEBUG 2022-06-16 15:50:23,734 [shard 0] seastar - generate_config dev_id: 0
INFO 2022-06-16 15:50:23,734 [shard 0] seastar - Created fair group io-queue-0, capacity rate 2147483:2147483, limit 12582912, rate 16777216 (factor 1.0), threshold 2000
INFO 2022-06-16 15:50:23,734 [shard 0] seastar - Created io group dev(0), length limit 4194304:4194304, rate 2147483647:2147483647
DEBUG 2022-06-16 15:50:23,734 [shard 0] seastar - allocate 0 IO group
INFO 2022-06-16 15:50:23,734 [shard 0] seastar - Created io queue dev(0) capacities: 512:2000/2000 1024:3000/3000 2048:5000/5000 4096:9000/9000 8192:17000/17000 16384:33000/33000 32768:65000/65000 65536:129000/129000 131072:257000/257000
DEBUG 2022-06-16 15:50:23,734 [shard 0] seastar - attached 0 queue to 0 IO group
TRACE 2022-06-16 15:50:23,778 [shard 4] exception - Throw exception at:
0x581bad 0x581e8a 0x582319 0x45a32c 0x45a5a8 /lib64/libstdc++.so.6+0xb50cb 0x428e74 0x4b69e3 0x4d608b 0x4d69a5 0x4d8e8f 0x492aad /lib64/libpthread.so.0+0x8179 /lib64/libc.so.6+0xfcdc2
WARN 2022-06-16 15:50:23,778 [shard 4] seastar - Creation of perf_event based stall detector failed, falling back to posix timer: std::system_error (error system:13, perf_event_open() failed: Permission denied)
TRACE 2022-06-16 15:50:23,779 [shard 2] exception - Throw exception at:
0x581bad 0x581e8a 0x582319 0x45a32c 0x45a5a8 /lib64/libstdc++.so.6+0xb50cb 0x428e74 0x4b69e3 0x4d608b 0x4d69a5 0x4d8e8f 0x492aad /lib64/libpthread.so.0+0x8179 /lib64/libc.so.6+0xfcdc2
WARN 2022-06-16 15:50:23,779 [shard 2] seastar - Creation of perf_event based stall detector failed, falling back to posix timer: std::system_error (error system:13, perf_event_open() failed: Permission denied)
TRACE 2022-06-16 15:50:23,780 [shard 5] exception - Throw exception at:
0x581bad 0x581e8a 0x582319 0x45a32c 0x45a5a8 /lib64/libstdc++.so.6+0xb50cb 0x428e74 0x4b69e3 0x4d608b 0x4d69a5 0x4d8e8f 0x492aad /lib64/libpthread.so.0+0x8179 /lib64/libc.so.6+0xfcdc2
WARN 2022-06-16 15:50:23,780 [shard 5] seastar - Creation of perf_event based stall detector failed, falling back to posix timer: std::system_error (error system:13, perf_event_open() failed: Permission denied)
DEBUG 2022-06-16 15:50:23,782 [shard 4] seastar - attached 4 queue to 0 IO group
DEBUG 2022-06-16 15:50:23,782 [shard 5] seastar - attached 5 queue to 0 IO group
DEBUG 2022-06-16 15:50:23,782 [shard 2] seastar - attached 2 queue to 0 IO group
TRACE 2022-06-16 15:50:23,784 [shard 7] exception - Throw exception at:
0x581bad 0x581e8a 0x582319 0x45a32c 0x45a5a8 /lib64/libstdc++.so.6+0xb50cb 0x428e74 0x4b69e3 0x4d608b 0x4d69a5 0x4d8e8f 0x492aad /lib64/libpthread.so.0+0x8179 /lib64/libc.so.6+0xfcdc2
WARN 2022-06-16 15:50:23,784 [shard 7] seastar - Creation of perf_event based stall detector failed, falling back to posix timer: std::system_error (error system:13, perf_event_open() failed: Permission denied)
TRACE 2022-06-16 15:50:23,784 [shard 6] exception - Throw exception at:
0x581bad 0x581e8a 0x582319 0x45a32c 0x45a5a8 /lib64/libstdc++.so.6+0xb50cb 0x428e74 0x4b69e3 0x4d608b 0x4d69a5 0x4d8e8f 0x492aad /lib64/libpthread.so.0+0x8179 /lib64/libc.so.6+0xfcdc2
WARN 2022-06-16 15:50:23,784 [shard 6] seastar - Creation of perf_event based stall detector failed, falling back to posix timer: std::system_error (error system:13, perf_event_open() failed: Permission denied)
TRACE 2022-06-16 15:50:23,785 [shard 3] exception - Throw exception at:
0x581bad 0x581e8a 0x582319 0x45a32c 0x45a5a8 /lib64/libstdc++.so.6+0xb50cb 0x428e74 0x4b69e3 0x4d608b 0x4d69a5 0x4d8e8f 0x492aad /lib64/libpthread.so.0+0x8179 /lib64/libc.so.6+0xfcdc2
WARN 2022-06-16 15:50:23,785 [shard 3] seastar - Creation of perf_event based stall detector failed, falling back to posix timer: std::system_error (error system:13, perf_event_open() failed: Permission denied)
DEBUG 2022-06-16 15:50:23,787 [shard 3] seastar - attached 3 queue to 0 IO group
DEBUG 2022-06-16 15:50:23,787 [shard 7] seastar - attached 7 queue to 0 IO group
DEBUG 2022-06-16 15:50:23,787 [shard 6] seastar - attached 6 queue to 0 IO group
TRACE 2022-06-16 15:50:23,788 [shard 1] exception - Throw exception at:
0x581bad 0x581e8a 0x582319 0x45a32c 0x45a5a8 /lib64/libstdc++.so.6+0xb50cb 0x428e74 0x4b69e3 0x4d608b 0x4d69a5 0x4d8e8f 0x492aad /lib64/libpthread.so.0+0x8179 /lib64/libc.so.6+0xfcdc2
WARN 2022-06-16 15:50:23,788 [shard 1] seastar - Creation of perf_event based stall detector failed, falling back to posix timer: std::system_error (error system:13, perf_event_open() failed: Permission denied)
DEBUG 2022-06-16 15:50:23,789 [shard 1] seastar - attached 1 queue to 0 IO group
Segmentation fault on shard 0.
Backtrace:
0x4e1ccb
0x4b2f23
0x4b3664
0x4b36d2
/lib64/libpthread.so.0+0x12c1f
/lib64/libCPVFramework.so+0x1cd9c7
/lib64/libCPVFramework.so+0xeb6f2
/lib64/libCPVFramework.so+0xe7aec
/lib64/libCPVFramework.so+0xe85bd
0x43eff3
0x43fe79
0x43fb5d
0x43f6c3
0x44d3d1
0x44de4d
0x4522ca
0x4aa48d
0x4aa7b0
0x4cf565
0x4cff69
0x450746
0x4511b7
0x4512b7
0x43f0bb
/lib64/libc.so.6+0x23492
0x43ec0d
./run.sh: line 13: 2084508 Segmentation fault ${BIN_PATH} --reactor-backend epoll

I ran the seastar-addr2line and decoded the backtrace. This is what I found.

[Backtrace #0]
addr2line: Dwarf Error: Can't find .debug_ranges section.
void seastar::backtraceseastar::backtrace_buffer::append_backtrace()::{lambda(seastar::frame)#1}(seastar::backtrace_buffer::append_backtrace()::{lambda(seastar::frame)#1}&&) at ??:?
seastar::print_with_backtrace(seastar::backtrace_buffer&, bool) at reactor.cc:?
seastar::print_with_backtrace(char const*, bool) [clone .constprop.0] at reactor.cc:?
seastar::install_oneshot_signal_handler<11, &seastar::sigsegv_action>()::{lambda(int, siginfo_t*, void*)#1}::_FUN(int, siginfo_t*, void*) at reactor.cc:?
.annobin_sigaction.c at sigaction.c:?
addr2line: Dwarf Error: Can't find .debug_ranges section.
seastar::reactor::add_timer(seastar::timerstd::chrono::_V2::steady_clock*) at crtstuff.c:?
seastar::future seastar::sleep<std::chrono::_V2::steady_clock, long, std::ratio<1l, 1l> >(std::chrono::duration<long, std::ratio<1l, 1l> >) at ??:?
auto cpv::Application::runForever()::{lambda(auto:1&, auto:2&)#1}::operator()<seastar::shared_ptrcpv::ApplicationData, seastar<std::atomic > >(seastar::shared_ptrcpv::ApplicationData&, seastar<std::atomic >&) const [clone .constprop.0] at Application.cpp:?
cpv::Application::runForever() at ??:?
main::{lambda()#1}::operator()() const at Main.cpp:?
seastar::future std::__invoke_impl<seastar::future, main::{lambda()#1}&>(std::__invoke_other, main::{lambda()#1}&) at Main.cpp:?
std::enable_if<is_invocable_r_v<seastar::future, main::{lambda()#1}&>, std::enable_if>::type std::__invoke_r<seastar::future, main::{lambda()#1}&>(seastar::future&&, (main::{lambda()#1}&)...) at Main.cpp:?
std::_Function_handler<seastar::future (), main::{lambda()#1}>::_M_invoke(std::_Any_data const&) at Main.cpp:?
addr2line: Dwarf Error: found dwarf version '36730', this reader only handles version 2, 3, 4 and 5 information.
std::_Function_handler<seastar::future (), seastar::app_template::run(int, char**, std::function<seastar::future ()>&&)::{lambda()#1}>::_M_invoke(std::_Any_data const&) at app-template.cc:?
std::_Function_handler<void (), seastar::app_template::run(int, char**, std::function<seastar::future ()>&&)::{lambda()#1}>::_M_invoke(std::_Any_data const&) at app-template.cc:?
seastar::continuation<seastar::internal::promise_base_with_type, std::function<void ()>, seastar::future::then_impl_nrvo<std::function<void ()>, seastar::future >(std::function<void ()>&&)::{lambda(seastar::internal::promise_base_with_type&&, std::function<void ()>&, seastar::future_stateseastar::internal::monostate&&)#1}, void>::run_and_dispose() at ??:?
seastar::reactor::run_tasks(seastar::reactor::task_queue&) at ??:?
seastar::reactor::run_some_tasks() [clone .part.0] at reactor.cc:?
addr2line: Dwarf Error: found dwarf version '41501', this reader only handles version 2, 3, 4 and 5 information.
seastar::reactor::do_run() at ??:?
seastar::reactor::run() at ??:?
seastar::app_template::run_deprecated(int, char**, std::function<void ()>&&) at ??:?
addr2line: Dwarf Error: found dwarf version '17417', this reader only handles version 2, 3, 4 and 5 information.
seastar::app_template::run(int, char**, std::function<seastar::future ()>&&) at ??:?
addr2line: Dwarf Error: found dwarf version '45312', this reader only handles version 2, 3, 4 and 5 information.
seastar::app_template::run(int, char**, std::function<seastar::future ()>&&) at ??:?
main at ??:?
__libc_start_main at ??:?
_start at ??:?

Any help is appreciated.