types

type Channel string

type Event struct {
	ID         string   `json:"id"`
	TenantSlug string   `json:"tenant_slug"`
	Name       string   `json:"name"`
	Channels   []string `json:"channels,omitempty"`
	TemplateID string   `json:"template_id,omitempty"`
	RateLimit  int      `json:"rate_limit,omitempty"` // per minute, 0 = no limit
	Enabled    bool     `json:"enabled"`
	Created    string   `json:"created"`
	Updated    string   `json:"updated"`
}

type Message struct {
	ID             string         `json:"id"`
	TenantSlug     string         `json:"tenant_slug"`
	Channel        Channel        `json:"channel"`
	Provider       string         `json:"provider"`
	To             string         `json:"to"`
	Subject        string         `json:"subject,omitempty"`
	Body           string         `json:"body,omitempty"`
	TemplateID     string         `json:"template_id,omitempty"`
	Event          string         `json:"event,omitempty"`
	Status         string         `json:"status"`
	Error          string         `json:"error,omitempty"`
	IdempotencyKey string         `json:"idempotency_key,omitempty"`
	TaskID         string         `json:"task_id,omitempty"`
	Created        string         `json:"created"`
	Updated        string         `json:"updated"`
	Sent           string         `json:"sent,omitempty"`
	Delivered      string         `json:"delivered,omitempty"`
	Metadata       map[string]any `json:"metadata,omitempty"`
}

type MeterRow struct {
	ID                string  `json:"id"`
	TenantSlug        string  `json:"tenant_slug"`
	Event             string  `json:"event,omitempty"`
	Provider          string  `json:"provider"`
	Channel           Channel `json:"channel"`
	Units             int     `json:"units"`               // sms segments / email count / voice minutes
	VendorCostMicros  int64   `json:"vendor_cost_micros"`  // provider-side cost in USD micros (1e-6)
	RetailPriceMicros int64   `json:"retail_price_micros"` // billed to tenant
	SentAt            string  `json:"sent_at"`
}

type Provider struct {
	ID             string `json:"id"`
	TenantSlug     string `json:"tenant_slug"`
	Service        string `json:"service"` // "plivo", "twilio", "sendgrid", …
	Mode           string `json:"mode"`    // "shared" | "byo"
	KMSPath        string `json:"kms_path"`
	Status         string `json:"status"` // "pending_test" | "active" | "disabled"
	Channel        string `json:"channel,omitempty"`
	IsDefault      bool   `json:"is_default,omitempty"`
	Created        string `json:"created"`
	LastTestAt     string `json:"last_test_at,omitempty"`
	LastTestResult string `json:"last_test_result,omitempty"`
}

type SendRequest struct {
	// To is the destination address(es). Phone number for SMS/voice/
	// WhatsApp, email for email, device token for push, channel
	// identifier for chat. Multiple recipients fan out into multiple
	// provider calls — one Message row per recipient.
	To []string `json:"to"`

	// Channel selects the delivery channel; the routes layer also exposes
	// per-channel convenience endpoints (/v1/notify/send/sms, etc.) that
	// set this implicitly.
	Channel Channel `json:"channel"`

	// Provider, if set, pins a specific provider service name (e.g.
	// "plivo", "twilio", "sendgrid"). When omitted the service picks the
	// tenant's default for the channel.
	Provider string `json:"provider,omitempty"`

	// Subject + Body are the raw payload when TemplateID is unset.
	Subject string `json:"subject,omitempty"`
	Body    string `json:"body,omitempty"`

	// TemplateID + TemplateVars trigger template rendering. The template
	// must be published and approved for the caller's tenant.
	TemplateID   string         `json:"template_id,omitempty"`
	TemplateVars map[string]any `json:"template_vars,omitempty"`

	// Event is the optional event-catalog identifier. Setting it both
	// tags the resulting Message row and lets the catalog policy apply
	// rate limits and routing overrides.
	Event string `json:"event,omitempty"`

	// IdempotencyKey scopes deduplication per tenant. Two requests with
	// the same (tenant, idempotency_key) return the same task_id and
	// produce a single Message row.
	IdempotencyKey string `json:"idempotency_key,omitempty"`

	// SendAt, if non-zero, schedules the send via hanzoai/tasks. RFC3339
	// string on the wire.
	SendAt string `json:"send_at,omitempty"`

	// Options is the free-form per-provider knob bag. Each provider
	// reads its own subkey (e.g. options["plivo"]["short_code"]).
	Options map[string]any `json:"options,omitempty"`
}

type SendResponse struct {
	// MessageID is the notifyd-generated id used to look up the Message
	// row via GET /v1/notify/messages/{id}.
	MessageID string `json:"message_id"`

	// TaskID is the hanzoai/tasks workflow id when async; empty in sync.
	TaskID string `json:"task_id,omitempty"`

	// Status is one of: queued, sending, sent, delivered, failed.
	Status string `json:"status"`

	// Error is set on terminal failure (sync mode only).
	Error string `json:"error,omitempty"`
}

type Template struct {
	ID         string   `json:"id"`
	TenantSlug string   `json:"tenant_slug"`
	Name       string   `json:"name"`
	Channel    Channel  `json:"channel"`
	Subject    string   `json:"subject,omitempty"`
	Body       string   `json:"body"`
	Vars       []string `json:"vars,omitempty"`
	Status     string   `json:"status"` // draft | pending_approval | approved | published | archived
	Version    int      `json:"version"`
	Created    string   `json:"created"`
	Updated    string   `json:"updated"`
	ApprovedBy string   `json:"approved_by,omitempty"`
}

type Tenant struct {
	ID      string `json:"id"`
	Name    string `json:"name"`
	Created string `json:"created"`
	Updated string `json:"updated"`
}