Publicar mensajes

POST /v1/topics/{topic_id}/publish
Content-Type: application/json

{
  "subject": "Order paid",
  "message": "{\"order_id\":\"A-1001\",\"amount\":149.50}",
  "attributes": {
    "event": { "type": "String", "value": "order.paid" },
    "environment": { "type": "String", "value": "production" },
    "amount": { "type": "Number", "value": "149.50" }
  }
}

basaltic notifications topic publish "$TOPIC_ID" --from-file request-1.json

package main

import (
	"context"
	"encoding/json"
	"fmt"
	"os"

	basaltic "github.com/basaltic-sh/sdk-go"
	"github.com/basaltic-sh/sdk-go/notifications"
)

func readJSON(path string, value any) error {
	data, err := os.ReadFile(path)
	if err != nil {
		return err
	}
	return json.Unmarshal(data, value)
}

func run() error {
	ctx := context.Background()
	cfg, err := basaltic.NewConfig(ctx)
	if err != nil {
		return err
	}
	client := notifications.New(cfg)
	var request1 notifications.PublishRequest
	if err := readJSON("request-1.json", &request1); err != nil {
		return err
	}
	result1, err := client.Publish(ctx, os.Getenv("TOPIC_ID"), &request1)
	if err != nil {
		return err
	}
	fmt.Printf("%+v\n", result1)
	return nil
}

func main() {
	if err := run(); err != nil {
		fmt.Fprintln(os.Stderr, err)
		os.Exit(1)
	}
}