publish.cpp

#include <chrono>
#include <cstdlib>
#include <iostream>
#include <thread>

#include <nlohmann/json.hpp>

#include "kinopio/kinopio.hpp"

namespace {

std::string resolveServer() {
  if (const char* value = std::getenv("KINOPIO_NATS_URL")) {
    return value;
  }
  return "nats://demo.nats.io:4222";
}

}  // namespace

int main() {
  kinopio::KinopioOptions options;
  options.servers = {resolveServer()};

  kinopio::KinopioHub hub(options);
  hub.connected(std::chrono::seconds(5));

  auto messages = hub.getScope("chat").getVariable("messages");

  // Message 1: Simple message (matches JS example)
  messages.pub(nlohmann::json{
      {"user", "Alice"},
      {"message", "Hello World!"},
      {"timestamp", std::chrono::duration_cast<std::chrono::milliseconds>(
                       std::chrono::system_clock::now().time_since_epoch())
                       .count()}
  });
  std::cout << "Published message 1\n";

  // Message 2: Another message
  messages.pub(nlohmann::json{
      {"user", "Bob"},
      {"message", "How are you?"},
      {"timestamp", std::chrono::duration_cast<std::chrono::milliseconds>(
                       std::chrono::system_clock::now().time_since_epoch())
                       .count()}
  });
  std::cout << "Published message 2\n";

  // Message 3: System message with extra fields
  messages.pub(nlohmann::json{
      {"user", "System"},
      {"message", "Server restart in 5 minutes"},
      {"type", "warning"},
      {"priority", "high"},
      {"timestamp", std::chrono::duration_cast<std::chrono::milliseconds>(
                       std::chrono::system_clock::now().time_since_epoch())
                       .count()}
  });
  std::cout << "Published system message\n";

  std::cout << "All messages published successfully!\n";

  // Brief wait before disconnect (matching JS pattern)
  std::this_thread::sleep_for(std::chrono::seconds(2));

  hub.dispose();
  std::cout << "Disconnected\n";
  return 0;
}