Echo.hpp

/*
Copyright (c) 2017-2025,
Battelle Memorial Institute; Lawrence Livermore National Security, LLC; Alliance for Sustainable
Energy, LLC.  See the top-level NOTICE for additional details. All rights reserved.
SPDX-License-Identifier: BSD-3-Clause
*/
#pragma once
 
#include "../application_api/MessageFederate.hpp"
#include "helicsApp.hpp"
 
#include <deque>
#include <memory>
#include <mutex>
#include <string>
#include <vector>
 
namespace helics {
namespace apps {
    class HELICS_CXX_EXPORT Echo: public App {
      public:
        Echo() = default;
        explicit Echo(std::vector<std::string> args);
        Echo(int argc, char* argv[]);
        explicit Echo(std::string_view name, const FederateInfo& fedInfo);
        Echo(std::string_view name, const std::shared_ptr<Core>& core, const FederateInfo& fedInfo);
        Echo(std::string_view name, CoreApp& core, const FederateInfo& fedInfo);
        Echo(std::string_view name, const std::string& jsonString);
 
        Echo(Echo&& other_echo) noexcept;
        Echo& operator=(Echo&& other_echo) noexcept;
 
        virtual void runTo(Time stopTime_input) override;
 
        void addEndpoint(std::string_view endpointName, std::string_view endpointType = "");
 
        auto echoCount() const { return echoCounter; }
        void setEchoDelay(Time delay);
 
        auto endpointCount() const { return endpoints.size(); }
 
      private:
        virtual void loadJsonFile(const std::string& jsonFile,
                                  bool enableFederateInterfaceRegistration) override;
        void echoMessage(const Endpoint& ept, Time currentTime);
 
      private:
        void initialSetup();
        void processArgs();
        std::deque<Endpoint> endpoints;  
        Time delayTime = timeZero;  
        size_t echoCounter = 0;  
        std::mutex delayTimeLock;  // mutex protecting delayTime
    };
}  // namespace apps
}  // namespace helics