cpp-rotor/tests/009-system-context.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 "system_context_test.h"

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

TEST_CASE("misconfigured root supervisor", "[system_context]") {
    rt::system_context_test_t system_context;
    auto sup = system_context.create_supervisor<rt::supervisor_test_t>().finish();
    REQUIRE(!sup);
    REQUIRE(system_context.reason->ec.value() == static_cast<int>(r::error_code_t::actor_misconfigured));
    REQUIRE(system_context.reason == system_context.reason->root());
    CHECK_THAT(system_context.reason->message(), Catch::EndsWith("actor is misconfigured"));
    REQUIRE(!system_context.get_supervisor());
}

TEST_CASE("properly configured root supervisor", "[system_context]") {
    rt::system_context_test_t system_context;
    auto sup = system_context.create_supervisor<rt::supervisor_test_t>().timeout(rt::default_timeout).finish();
    REQUIRE(sup);
    CHECK(!system_context.reason);
    CHECK(system_context.get_supervisor() == sup);

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

TEST_CASE("root supervisor cannot be created twice", "[system_context]") {
    rt::system_context_test_t system_context;
    auto sup1 = system_context.create_supervisor<rt::supervisor_test_t>().timeout(rt::default_timeout).finish();
    REQUIRE(sup1);
    REQUIRE(system_context.get_supervisor() == sup1);

    auto sup2 = system_context.create_supervisor<rt::supervisor_test_t>().timeout(rt::default_timeout).finish();
    REQUIRE(!sup2);
    REQUIRE(system_context.get_supervisor() == sup1);
    REQUIRE(system_context.reason->ec.value() == static_cast<int>(r::error_code_t::supervisor_defined));
    CHECK_THAT(system_context.reason->message(), Catch::EndsWith("supervisor is already defined"));

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