approval

type Decision struct {
	ID        string    `json:"id"`
	Approved  bool      `json:"approved"`
	Reason    string    `json:"reason,omitempty"`
	DecidedAt time.Time `json:"decidedAt"`
}

type Event struct {
	Topic   string
	Data    interface{}
	Headers map[string]string `json:"headers,omitempty"`
}

type Message[T any] interface {
	T() *T
	Ack() error
	Nack(error) error
}

type Queue[T any] interface {
	Publish(ctx context.Context, t *T) error
	Consume(ctx context.Context) (Message[T], error)
}

type Request struct {
	ID          string                 `json:"id"`
	ProcessID   string                 `json:"processId"`
	ExecutionID string                 `json:"executionId"`
	Action      string                 `json:"action"`
	Args        json.RawMessage        `json:"args,omitempty"`
	CreatedAt   time.Time              `json:"createdAt"`
	ExpiresAt   *time.Time             `json:"expiresAt,omitempty"`
	Meta        map[string]interface{} `json:"meta,omitempty"`
}

type Service interface {
	RequestApproval(ctx context.Context, r *Request) error
	ListPending(ctx context.Context) ([]*Request, error)
	Decide(ctx context.Context, id string, approved bool, reason string) (*Decision, error)
	Queue() Queue[Event]
}