ZeroTierOne/nonfree/controller/PubSubWriter.hpp
Grant Limberg 012443acfa
Some checks are pending
/ build_macos (push) Waiting to run
/ build_windows (push) Waiting to run
/ Central Controller Build (push) Waiting to run
/ multi-arch-docker (push) Blocked by required conditions
/ build_ubuntu (push) Waiting to run
wire up pubsub notifications from controller to frontend
2025-09-08 16:01:50 -07:00

41 lines
No EOL
1,006 B
C++

#ifndef ZT_CONTROLLER_PUBSUBWRITER_HPP
#define ZT_CONTROLLER_PUBSUBWRITER_HPP
#include <google/cloud/pubsub/publisher.h>
#include <memory>
#include <nlohmann/json.hpp>
#include <string>
namespace ZeroTier {
class PubSubWriter {
public:
PubSubWriter(std::string project, std::string topic, std::string controller_id);
virtual ~PubSubWriter();
bool publishNetworkChange(const nlohmann::json& oldNetwork, const nlohmann::json& newNetwork);
bool publishMemberChange(const nlohmann::json& oldMember, const nlohmann::json& newMember);
bool publishStatusChange(
std::string frontend,
std::string network_id,
std::string node_id,
std::string os,
std::string arch,
std::string version,
int64_t last_seen);
protected:
bool publishMessage(const std::string& payload);
private:
std::string _controller_id;
std::string _project;
std::string _topic;
std::shared_ptr<google::cloud::pubsub::Publisher> _publisher;
};
} // namespace ZeroTier
#endif // ZT_CONTROLLER_PUBSUBWRITER_HPP