InputPort.hpp

// SPDX-FileCopyrightText: 2025-2026 Vincent Leroy
// SPDX-License-Identifier: MIT
//
// This file is part of dfx.
//
// Licensed under the MIT License. See the LICENSE file in the project root
// for full license information.
 
#pragma once
 
// Standard includes
#include <atomic>
 
// Project includes
#include "../messages/Message.hpp"
#include "Port.hpp"
#include <dfx-utilities/JsonValidator.hpp>
 
namespace dfx::Core
{
class InputPort : public Port
{
public:
    InputPort(Id id, NodeWPtr node, std::string name, Kind kind, MimeTypes supportedMimeTypes = {}, std::optional<bool> allowsMimeTypePropagation = std::nullopt);

    MimeTypes supportedMimeTypes() const noexcept { return _supportedMimeTypes; }

    bool isMimeTypeSupported(MimeType const & mimeType) const noexcept;
 
public:
    void processAllPendingMessages();

    void processMessage(MessagePtr message);
 
public:
    void setAllowUnknownControlCommand(bool allow)       { _allowUnknownControlCommand = allow; }

    bool isUnknownControlCommandAllowed() const noexcept { return _allowUnknownControlCommand; }

    void registerControlCommand(std::string_view command, nlohmann::json schema, bool allowOverride = false);

    void deregisterControlCommand(std::string_view command);
 
public:

    bool testAndSetScheduled() noexcept { return _scheduled->test_and_set(std::memory_order::acq_rel); }

    void clearScheduled() noexcept      { _scheduled->clear(std::memory_order::release); }

 
private:
    MimeTypes _supportedMimeTypes;
 
private:
    bool _allowUnknownControlCommand = false;
    Utils::JsonValidator _controlJsonValidator;
    std::unique_ptr<std::atomic_flag> _scheduled;
};
} // !namespace dfx::Core