notifications

type Action struct {
	ID    string `json:"id"`
	Label string `json:"label"`
}

type ActionableRequest struct {
	NotificationRequest
	Actions       []Action      // required, at least one
	RequestID     string        // UUIDv7, set by router
	Timeout       time.Duration // how long to wait for response
	TimeoutAction string        // action ID to auto-execute, "escalate", or "cancel"
	Context       string        // model-provided context for callback handling
}

type CallbackDispatcher struct {
	// contains filtered or unexported fields
}

type ContactResolver interface {
	ResolveContact(name string) (*contacts.Contact, error)
	GetPropertiesMap(contactID uuid.UUID) (map[string][]string, error)
}

type DelegateSpawner interface {
	Spawn(ctx context.Context, task, guidance string) error
}

type EscalationSender interface {
	Send(ctx context.Context, n Notification) error
}

type HAClient interface {
	CallService(ctx context.Context, domain, service string, data map[string]any) error
}

type HAPushProvider struct {
	// contains filtered or unexported fields
}

type Notification struct {
	Recipient     string        // contact name (e.g., "nugget")
	Title         string        // notification title (optional)
	Message       string        // notification body (required)
	Priority      string        // "low", "normal" (default), "urgent"
	Actions       []Action      // optional: action buttons (creates tracked notification)
	RequestID     string        // UUIDv7, set by caller when Actions is non-empty
	Timeout       time.Duration // how long to wait for response (default: 30m)
	TimeoutAction string        // action ID to auto-execute on timeout, or "escalate"/"cancel"
	Context       string        // model-provided context for callback handling
}

type NotificationProvider interface {
	// Send delivers a fire-and-forget notification.
	Send(ctx context.Context, req NotificationRequest) error
	// SendActionable delivers a notification with action buttons.
	// The RequestID is pre-set by the router before calling the
	// provider; the provider only handles delivery.
	SendActionable(ctx context.Context, req ActionableRequest) error
	// Name returns the provider identifier (e.g., "ha_push").
	Name() string
}

type NotificationRequest struct {
	Recipient string // contact name (resolved by router)
	Title     string // optional
	Message   string // required
	Priority  string // "low", "normal", "urgent"
}

type NotificationRouter struct {
	// contains filtered or unexported fields
}

type OpstateStore interface {
	SetWithTTL(namespace, key, value string, ttl time.Duration) error
}

type Record struct {
	RequestID          string
	Recipient          string
	OriginSession      string
	OriginConversation string
	Context            string
	Actions            []Action
	TimeoutSeconds     int
	TimeoutAction      string
	Status             string
	ResponseAction     string
	RespondedAt        time.Time
	CreatedAt          time.Time
	ExpiresAt          time.Time
}

type RecordStore struct {
	// contains filtered or unexported fields
}

type Sender struct {
	// contains filtered or unexported fields
}

type SessionInjector interface {
	// InjectSystemMessage adds a system message to the conversation's
	// memory. The message will be visible on the next agent turn.
	InjectSystemMessage(conversationID, message string) error
	// IsSessionAlive reports whether a conversation has an active
	// archive session.
	IsSessionAlive(conversationID string) bool
}

type TimeoutWatcher struct {
	// contains filtered or unexported fields
}