directives.cpp

Go to the documentation of this file.

// SPDX-License-Identifier: Apache-2.0
#include <entropic/core/directives.h>
#include <entropic/types/logging.h>
 
#include <cstdlib>
#include <string>
 
static auto logger = entropic::log::get("core.directives");
 
namespace entropic {
 
void DirectiveProcessor::register_handler(
    entropic_directive_type_t dtype,
    DirectiveHandler handler) {
    handlers_[static_cast<int>(dtype)] = std::move(handler);
}
 
DirectiveResult DirectiveProcessor::process(
    LoopContext& ctx,
    const std::vector<const Directive*>& directives) {
    logger->info("Processing {} directive(s)", directives.size());
    DirectiveResult result;
    int processed = 0;
    for (const auto* directive : directives) {
        if (directive == nullptr) {
            continue;
        }
 
        auto it = handlers_.find(static_cast<int>(directive->type));
        bool has_handler = it != handlers_.end();
 
        // Hook: ON_DIRECTIVE or ON_CUSTOM_DIRECTIVE (v1.9.1)
        if (!fire_directive_hook(directive, has_handler)) {
            continue; // suppressed by hook
        }
 
        if (has_handler) {
            logger->info("Directive type={}, handler invoked",
                         static_cast<int>(directive->type));
            it->second(ctx, *directive, result);
            ++processed;
            if (result.stop_processing) {
                break;
            }
        }
    }
    logger->info("Directives: {}/{} processed", processed,
                 directives.size());
    return result;
}
 
bool DirectiveProcessor::fire_directive_hook(
    const Directive* directive, bool has_handler) {
    if (hooks_.fire_pre == nullptr) {
        return true;
    }
 
    auto point = has_handler
        ? ENTROPIC_HOOK_ON_DIRECTIVE
        : ENTROPIC_HOOK_ON_CUSTOM_DIRECTIVE;
    std::string json = "{\"type\":"
        + std::to_string(static_cast<int>(directive->type)) + "}";
    char* mod = nullptr;
    int rc = hooks_.fire_pre(hooks_.registry,
        point, json.c_str(), &mod);
    free(mod);
    return rc == 0;
}
 
} // namespace entropic