device_grpc.hpp

Go to the documentation of this file.

// (C) Copyright 2025, SECO Mind Srl
//
// SPDX-License-Identifier: Apache-2.0
 
#ifndef ASTARTE_DEVICE_SDK_DEVICE_GRPC_H
#define ASTARTE_DEVICE_SDK_DEVICE_GRPC_H

 
#include <chrono>
#include <filesystem>
#include <memory>
#include <optional>
#include <string>
#include <string_view>
 
#include "astarte_device_sdk/data.hpp"
#include "astarte_device_sdk/device.hpp"
#include "astarte_device_sdk/msg.hpp"
#include "astarte_device_sdk/object.hpp"

namespace AstarteDeviceSdk {

class AstarteDeviceGRPC : public AstarteDevice {
 public:
  AstarteDeviceGRPC(const std::string& server_addr, const std::string& node_uuid);
  ~AstarteDeviceGRPC() override;
  AstarteDeviceGRPC(AstarteDeviceGRPC& other) = delete;
  auto operator=(AstarteDeviceGRPC& other) -> AstarteDeviceGRPC& = delete;
  AstarteDeviceGRPC(AstarteDeviceGRPC&& other) = delete;
  auto operator=(AstarteDeviceGRPC&& other) -> AstarteDeviceGRPC& = delete;

  void add_interface_from_json(const std::filesystem::path& json_file) override;
  void add_interface_from_str(std::string json) override;
  void add_interface_from_str(std::string_view json) override;
  void connect() override;
  // NOLINTNEXTLINE(misc-include-cleaner)
  [[nodiscard]] auto is_connected(const std::chrono::milliseconds& timeout) const -> bool override;
  void disconnect() override;
  void send_individual(const std::string& interface_name, const std::string& path,
                       const AstarteData& data,
                       const std::chrono::system_clock::time_point* timestamp) override;
  void send_object(const std::string& interface_name, const std::string& path,
                   const AstarteDatastreamObject& object,
                   const std::chrono::system_clock::time_point* timestamp) override;
  void set_property(const std::string& interface_name, const std::string& path,
                    const AstarteData& data) override;
  void unset_property(const std::string& interface_name, const std::string& path) override;
  auto poll_incoming(const std::chrono::milliseconds& timeout)
      -> std::optional<AstarteMessage> override;
 
 private:
  struct AstarteDeviceGRPCImpl;
  std::shared_ptr<AstarteDeviceGRPCImpl> astarte_device_impl_;
};
 
}  // namespace AstarteDeviceSdk
 
#endif  // ASTARTE_DEVICE_SDK_DEVICE_GRPC_H