simCmdsImpl.hpp

Go to the documentation of this file.

// SPDX-FileCopyrightText: 2020-2025 European Southern Observatory (ESO)
//
// SPDX-License-Identifier: LGPL-3.0-only

#ifndef HLCC_TELIF_TELIF_SIMCMDSIMPL_HPP
#define HLCC_TELIF_TELIF_SIMCMDSIMPL_HPP
 
#include <rad/exceptions.hpp>
#include <rad/smAdapter.hpp>
 
#include "telif/simCmds.rad.hpp"
#include "telif/logger.hpp"
 
namespace hlcc::telif {
 
 
class SimCmdsImpl : public telifif::AsyncSimCmds {
public:
    explicit SimCmdsImpl(rad::SMAdapter& sm) : m_sm(sm) {
        RAD_TRACE(GetLogger());
    }
 
    virtual ~SimCmdsImpl() {
        RAD_TRACE(GetLogger());
    }
 
    virtual elt::mal::future<std::string> UpdateRousTimer(std::uint16_t new_time) override {
 
        RAD_TRACE(GetLogger());
        LOG4CPLUS_INFO(GetLogger(), "Received UpdateRousTimer with: new_time  " << new_time);
 
        auto ev = std::make_shared<SimCmds::UpdateRousTimer>(new_time);
        m_sm.RegisterDefaultRequestRejectHandler<SimCmds::UpdateRousTimer>();
        m_sm.PostEvent(ev);
 
        return ev->GetPayload().GetReplyFuture();
    }
 
private:
    rad::SMAdapter& m_sm;
 
    static std::string ContinuationCheckRejection(elt::mal::future<std::string> future, std::string method_name) {
        std::string reply = future.get(); // the future is (normally) already fulfilled when called from a then-continuation.
        if (reply.find("Request rejected in state") != std::string::npos) { // TODO C++20 use std::string::starts_with.
            LOG4CPLUS_INFO(GetLogger(), method_name << " command rejected by eltpk: " << reply);
        }
        return reply;
    };
 
};
 
}  // namespace hlcc::telif
 
#endif  // HLCC_TELIF_TELIF_SIMCMDSIMPL_HPP