procedure_registry.h

Go to the documentation of this file.

#pragma once
 
#include <cstdint>
#include <expected>
#include <functional>
#include <nlohmann/json_fwd.hpp>
#include <string>
#include <string_view>
#include <variant>
#include <vector>
 
#include "node/device.h"
#include "node/device_manager.h"
#include "node/plant_identification.h"
#include "node/procedure.h"
#include "node/procedure_manager.h"
 
namespace mm::node {
 
 
struct ProcedureRegistryEntry {
  ProcedureDescriptor descriptor;  
 
  std::function<bool(Device& device)> applies;
 
  std::function<std::expected<ProcedureBody, std::string>(const nlohmann::json& request)> makeBody;
};
 
struct ProcedureListing {
  ProcedureDescriptor descriptor;
  ProcedureSnapshot snapshot;
};
void to_json(nlohmann::json& j, const ProcedureListing& listing);
 
struct ProcedureRegistryConfig {
  PlantModelFitFn fitPlantModel;
};
 
class ProcedureRegistry {
 public:
  ProcedureRegistry(DeviceManager& deviceManager, ProcedureManager& procedureManager,
                    ProcedureRegistryConfig config);
 
  const std::vector<ProcedureRegistryEntry>& entries() const { return entries_; }
 
  std::expected<std::vector<ProcedureListing>, ProcedureError> list(uint16_t devicePosition) const;
 
  std::expected<ProcedureSnapshot, ProcedureError> snapshot(uint16_t devicePosition,
                                                            std::string_view name) const;
 
  std::expected<ProcedureSnapshot, ProcedureError> start(uint16_t devicePosition,
                                                         std::string_view name,
                                                         const nlohmann::json& request) const;
 
  std::expected<void, ProcedureError> cancel(uint16_t devicePosition, std::string_view name) const;
 
 private:
  std::expected<std::vector<const ProcedureRegistryEntry*>, ProcedureError> applicableEntries(
      uint16_t devicePosition) const;
 
  std::expected<const ProcedureRegistryEntry*, ProcedureError> applicableEntry(
      uint16_t devicePosition, std::string_view name) const;
 
  DeviceManager& deviceManager_;
  ProcedureManager& procedureManager_;
  std::vector<ProcedureRegistryEntry> entries_;
};
 
}  // namespace mm::node