contracts

type Gorcure interface {
	// Publish sends data to a single topic and returns the event id assigned by the hub.
	Publish(topic string, data any) (string, error)
	// PublishUpdate sends a fully described update (multiple topics, private, etc.).
	PublishUpdate(update Update) (string, error)
}

type Update struct {
	// Topics the update is published to. At least one is required.
	Topics []string
	// Data is the payload sent to subscribers (already serialized, usually JSON).
	Data string
	// Private marks the update as private; only subscribers authorized for one of
	// the topics (via their JWT) will receive it.
	Private bool
	// ID is an optional SSE event id. When empty the hub generates one.
	ID string
	// Type is an optional SSE event type.
	Type string
	// Retry is the optional SSE reconnection time in milliseconds.
	Retry int
}