cpp-rotor/tests/008-config-builder.cpp

//
// Copyright (c) 2019-2021 Ivan Baidakou (basiliscos) (the dot dmol at gmail dot com)
//
// Distributed under the MIT Software License
//

#include "catch.hpp"
#include "rotor.hpp"
#include "supervisor_test.h"
#include "actor_test.h"
#include "system_context_test.h"
#include "access.h"

namespace r = rotor;
namespace rt = rotor::test;

template <typename Actor> struct sample_config_builder_t : public r::actor_config_builder_t<Actor> {
    using parent_t = r::actor_config_builder_t<Actor>;
    using parent_t::parent_t;

    bool validate() noexcept override { return false; }
};

struct sample_actor_t : public rt::actor_test_t {
    using rt::actor_test_t::actor_test_t;
    template <typename Actor> using config_builder_t = sample_config_builder_t<Actor>;
};

TEST_CASE("direct builder configuration", "[config_builder]") {
    r::system_context_t system_context;
    auto sup = system_context.create_supervisor<rt::supervisor_test_t>()
                   .timeout(rt::default_timeout)
                   .locality(&system_context)
                   .finish();
    REQUIRE(sup);
    REQUIRE(sup->locality == &system_context);
    sup->do_process();
    sup->do_shutdown();
    sup->do_process();
    sup->do_process();
    CHECK(rt::empty(sup->get_subscription()));
}

TEST_CASE("indirect builder configuration", "[config_builder]") {
    r::system_context_t system_context;
    auto sup = system_context.create_supervisor<rt::supervisor_test_t>()
                   .locality(&system_context)
                   .timeout(rt::default_timeout)
                   .finish();
    REQUIRE(sup);
    REQUIRE(sup->locality == &system_context);
    sup->do_process();
    sup->do_shutdown();
    sup->do_process();
}

TEST_CASE("validation", "[config_builder]") {
    rt::system_context_test_t system_context;
    auto sup = system_context.create_supervisor<rt::supervisor_test_t>()
                   .locality(&system_context)
                   .timeout(rt::default_timeout)
                   .finish();
    REQUIRE(sup);

    SECTION("custom validator failed") {
        auto act = sup->create_actor<sample_actor_t>().timeout(rt::default_timeout).finish();
        REQUIRE(!act);
        CHECK(system_context.reason->ec == r::error_code_t::actor_misconfigured);
    }

    sup->do_process();
    sup->do_shutdown();
    sup->do_process();
}