assignment_input_sequence_length.cpp

Go to the documentation of this file.

#include "irsol/server/handlers/assignment_input_sequence_length.hpp"
 
#include "irsol/server/client/session.hpp"
#include "irsol/utils.hpp"
 
namespace irsol {
namespace server {
namespace handlers {
AssignmentInputSequenceLengthHandler::AssignmentInputSequenceLengthHandler(
  std::shared_ptr<Context> ctx)
  : AssignmentHandler(ctx)
{}
 
std::vector<out_message_t>
AssignmentInputSequenceLengthHandler::process(
  std::shared_ptr<irsol::server::ClientSession> session,
  protocol::Assignment&&                        message)
{
  auto& frameListeningState = session->userData().frameListeningState;
  if(frameListeningState.running()) {
    IRSOL_NAMED_LOG_WARN(
      session->id(), "Session is already listening to frames. Cannot set a inputSequenceLength.");
    std::vector<out_message_t> result;
    result.emplace_back(irsol::protocol::Error::from(
      message, "Session is already listening to frames. Cannot set a inputSequenceLength."));
    return result;
  }
  const int inputSequenceLength = irsol::utils::toInt(message.value);
  if(inputSequenceLength <= 0) {
    IRSOL_NAMED_LOG_WARN(
      session->id(), "inputSequenceLength ({}) must be positive.", inputSequenceLength);
    std::vector<out_message_t> result;
    result.emplace_back(
      irsol::protocol::Error::from(message, "InputSequenceLength must be positive."));
    return result;
  }
  IRSOL_NAMED_LOG_INFO(session->id(), "Setting 'inputSequenceLength' to {}", inputSequenceLength);
 
  frameListeningState.gisParams.inputSequenceLength = static_cast<uint64_t>(inputSequenceLength);
  std::vector<out_message_t> result;
  result.emplace_back(irsol::protocol::Success::from(message));
  return result;
}
}  // namespace handlers
}  // namespace server
}  // namespace irsol