TypedBrokerServer.hpp

/*
Copyright (c) 2017-2026,
Battelle Memorial Institute; Lawrence Livermore National Security, LLC; Alliance for Energy
Innovation LLC.  See the top-level NOTICE for additional details. All rights reserved.
SPDX-License-Identifier: BSD-3-Clause
*/
 
#pragma once
 
#include "../core/ActionMessage.hpp"
 
#include <memory>
#include <nlohmann/json_fwd.hpp>
#include <string>
#include <tuple>
#include <vector>
 
namespace helics {
class Broker;
namespace apps {
 
    using portData = std::vector<std::tuple<int, bool, std::shared_ptr<Broker>>>;
    class TypedBrokerServer {
      public:
        virtual ~TypedBrokerServer() = default;
        virtual void startServer(const nlohmann::json* val,
                                 const std::shared_ptr<TypedBrokerServer>& ptr) = 0;
        virtual void stopServer() = 0;
        virtual void processArgs(std::string_view args);
 
      protected:
        static ActionMessage
            generateMessageResponse(const ActionMessage& rxcmd, portData& pdata, CoreType ctype);
        static int getOpenPort(portData& portDataList);
        /* assign a port in the portData structure*/
        static void assignPort(portData& portDataList, int pnumber, std::shared_ptr<Broker>& brk);
        /* log a message to the console */
        static void logMessage(std::string_view message);
    };
}  // namespace apps
}  // namespace helics