16243493732

Committed 13 Jul 2025 12:27AM UTC coverage: 81.986% (-6.2%) from 88.204%

Build # 16243493732

Build Type

push

github

Committed by

egorpristanskii

Commit Message

Fix bw and custom coroutines mix, add middleware integration, add log middleware

Run Details

49 of 66 branches covered (74.24%)

Branch coverage included in aggregate %.

26 of 57 new or added lines in 6 files covered. (45.61%)

2 existing lines in 2 files now uncovered.

306 of 367 relevant lines covered (83.38%)

11.11 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

60.0

/src/middleware/middleware.cpp

#include "middleware/middleware.h"

#include <ranges>
#include <utility>

namespace middleware {

asio::awaitable<network::Response> IMiddleware::execute(
    const AsyncTask& task, const network::Request& request) {
    preprocess(request);
    network::Response response = co_await task(request);
    postprocess(response);
    co_return response;
}

MiddleWareChain::MiddleWareChain(
    std::initializer_list<std::shared_ptr<IMiddleware>> middlewares)
    : middlewares_(middlewares) {}

AsyncTask MiddleWareChain::buildPipeline(AsyncTask handler) {
    auto next = std::move(handler);
    for (const auto& middleware : std::ranges::reverse_view(middlewares_)) {
        auto prev = next;
        next = [middleware, prev](const network::Request& request)
            -> asio::awaitable<network::Response> {
            return middleware->execute(prev, request);
        };
    }

    return next;
}
}  // namespace middleware

1	#include "middleware/middleware.h"
2
3	#include <ranges>
4	#include <utility>
5
6	namespace middleware {
7
8	asio::awaitable<network::Response> IMiddleware::execute(
NEW 9	const AsyncTask& task, const network::Request& request) {	×
NEW 10	preprocess(request);	×
NEW 11	network::Response response = co_await task(request);	×
NEW 12	postprocess(response);	×
NEW 13	co_return response;	×
NEW 14	}	×
15
16	MiddleWareChain::MiddleWareChain(
17	std::initializer_list<std::shared_ptr<IMiddleware>> middlewares)
18	: middlewares_(middlewares) {}	4✔
19
20	AsyncTask MiddleWareChain::buildPipeline(AsyncTask handler) {	4✔
21	auto next = std::move(handler);	4✔
22	for (const auto& middleware : std::ranges::reverse_view(middlewares_)) {	4✔
23	auto prev = next;	4✔
24	next = [middleware, prev](const network::Request& request)	4✔
25	-> asio::awaitable<network::Response> {	4✔
NEW 26	return middleware->execute(prev, request);	×
NEW 27	};	×
28	}	4✔
29
30	return next;	4✔
31	}	4✔
32	} // namespace middleware

egorpristanskii / distributed_storage / 16243493732

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous