REST API bridge

// Node.js / Browser
async function publishMessage(topic, payload) {
  const response = await fetch('https://rest.cloudsignal.io/api/v1/publish', {
    method: 'POST',
    headers: {
      'Content-Type': 'application/json',
      'X-API-Key': process.env.CLOUDSIGNAL_API_KEY
    },
    body: JSON.stringify({
      topic,
      payload: JSON.stringify(payload),
      qos: 1
    })
  });

  if (!response.ok) {
    throw new Error(`Publish failed: ${response.status}`);
  }

  return response.json();
}

// Usage
await publishMessage('agents/agent-01/inbox', { task: 'summarize-thread' });

import os
import json
import requests

def publish_message(topic: str, payload: dict, qos: int = 0):
    response = requests.post(
        'https://rest.cloudsignal.io/api/v1/publish',
        headers={
            'Content-Type': 'application/json',
            'X-API-Key': os.environ['CLOUDSIGNAL_API_KEY']
        },
        json={
            'topic': topic,
            'payload': json.dumps(payload),
            'qos': qos
        }
    )
    response.raise_for_status()
    return response.json()

# Usage
publish_message('presence/room-9', {'online': 12, 'typing': 2})

package main

import (
    "bytes"
    "encoding/json"
    "net/http"
    "os"
)

type PublishRequest struct {
    Topic   string `json:"topic"`
    Payload string `json:"payload"`
    QoS     int    `json:"qos"`
}

func publishMessage(topic string, payload interface{}) error {
    payloadBytes, _ := json.Marshal(payload)
    
    reqBody, _ := json.Marshal(PublishRequest{
        Topic:   topic,
        Payload: string(payloadBytes),
        QoS:     1,
    })

    req, _ := http.NewRequest("POST", 
        "https://rest.cloudsignal.io/api/v1/publish",
        bytes.NewBuffer(reqBody))
    
    req.Header.Set("Content-Type", "application/json")
    req.Header.Set("X-API-Key", os.Getenv("CLOUDSIGNAL_API_KEY"))

    resp, err := http.DefaultClient.Do(req)
    if err != nil {
        return err
    }
    defer resp.Body.Close()
    
    return nil
}

<?php
function publishMessage(string $topic, array $payload, int $qos = 0): array {
    $ch = curl_init('https://rest.cloudsignal.io/api/v1/publish');
    
    curl_setopt_array($ch, [
        CURLOPT_POST => true,
        CURLOPT_RETURNTRANSFER => true,
        CURLOPT_HTTPHEADER => [
            'Content-Type: application/json',
            'X-API-Key: ' . getenv('CLOUDSIGNAL_API_KEY')
        ],
        CURLOPT_POSTFIELDS => json_encode([
            'topic' => $topic,
            'payload' => json_encode($payload),
            'qos' => $qos
        ])
    ]);

    $response = curl_exec($ch);
    curl_close($ch);

    return json_decode($response, true);
}

// Usage
publishMessage('alerts/system', ['level' => 'warning', 'message' => 'CPU high']);

# Basic publish
curl -X POST https://rest.cloudsignal.io/api/v1/publish \
  -H "Content-Type: application/json" \
  -H "X-API-Key: $CLOUDSIGNAL_API_KEY" \
  -d '{
    "topic": "notifications/user-123",
    "payload": "{\"title\": \"New message\", \"body\": \"Hello!\"}",
    "qos": 1
  }'

# With retain flag
curl -X POST https://rest.cloudsignal.io/api/v1/publish \
  -H "Content-Type: application/json" \
  -H "X-API-Key: $CLOUDSIGNAL_API_KEY" \
  -d '{
    "topic": "agents/agent-42/state",
    "payload": "{\"status\": \"idle\"}",
    "retain": true
  }'