run_manager.h

Go to the documentation of this file.

// Copyright (c) 2024 anabrid GmbH
// Contact: https://www.anabrid.com/licensing/
// SPDX-License-Identifier: MIT OR GPL-2.0-or-later
 
#pragma once
 
#include "protocol/handler.h"
#include "run/manager.h"
#include "run/registry.h"
 
namespace msg {
 
namespace handlers {
 
class StartRunRequestHandler : public MessageHandler {
public:
  bool replyStreaming(const Request& req, Stream &io) override {
    run::RunManager::get().start_run(req, io);
    return true; // = is implemented
  }
};
 
class ListRunDriverRegistryHandler : public MessageHandler {
public:
  utils::status replyWithObject(const Request& req, JsonObject &msg_out) override {
    auto types_list = msg_out.createNestedArray("available_types");
    run::drivers::DynamicRegistry::get().write_handler_names_to(types_list);
    return utils::status::success();
  }
};
 
class StopRunRequestHandler : public MessageHandler {
public:
  utils::status replyWithObject(const Request& req, JsonObject &msg_out) override {
    return utils::status(run::RunManager::get().stop_run(req.msg_in, msg_out));
  }
};
 
} // namespace handlers
 
} // namespace msg