plugins

type Descriptor struct {
	Provider     string   `json:"provider"`
	Capabilities []string `json:"capabilities"`
	Source       Source   `json:"source"`
	BinaryPath   string   `json:"binary_path,omitempty"`
	ProbeError   string   `json:"probe_error,omitempty"`
}

type ExecutionError struct {
	ExitCode  int
	Retriable bool
	Code      string
	Message   string
	Stderr    string
	Cause     error
}

type Host interface {
	CollectInventory(pathEnv string, builtinMailProviders []string, probeTimeout time.Duration) []Descriptor
	ProbeCapabilities(ctx context.Context, binaryPath string, timeout time.Duration) ([]string, error)
	ExecuteRequest(ctx context.Context, binaryPath string, request RequestEnvelope, timeout time.Duration) (ResponseEnvelope, error)
}

type LocalHost struct{}

type MailSendOutput struct {
	Accepted          bool   `json:"accepted"`
	ProviderRequestID string `json:"provider_request_id,omitempty"`
}

type MailSendPayload struct {
	From    string            `json:"from"`
	To      []string          `json:"to"`
	Subject string            `json:"subject"`
	Body    string            `json:"body"`
	Headers map[string]string `json:"headers,omitempty"`
}

type QueuePublishOutput struct {
	Accepted  bool   `json:"accepted"`
	MessageID string `json:"message_id,omitempty"`
}

type QueuePublishPayload struct {
	Topic   string            `json:"topic"`
	Key     string            `json:"key,omitempty"`
	Body    json.RawMessage   `json:"body"`
	Headers map[string]string `json:"headers,omitempty"`
}

type RequestEnvelope struct {
	Version    string            `json:"version"`
	RequestID  string            `json:"request_id"`
	Timestamp  string            `json:"timestamp"`
	Capability string            `json:"capability"`
	Provider   string            `json:"provider"`
	TimeoutMS  int64             `json:"timeout_ms"`
	Metadata   map[string]string `json:"metadata,omitempty"`
	Payload    json.RawMessage   `json:"payload"`
}

type ResponseEnvelope struct {
	Version           string           `json:"version"`
	RequestID         string           `json:"request_id,omitempty"`
	OK                bool             `json:"ok"`
	ProviderRequestID string           `json:"provider_request_id,omitempty"`
	Retriable         bool             `json:"retriable,omitempty"`
	Output            json.RawMessage  `json:"output,omitempty"`
	Error             *ResponseError   `json:"error,omitempty"`
	Metrics           *ResponseMetrics `json:"metrics,omitempty"`
}

type ResponseError struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type ResponseMetrics struct {
	DurationMS int64 `json:"duration_ms,omitempty"`
}

type Source string

type WebhookDeliverOutput struct {
	Accepted   bool `json:"accepted"`
	StatusCode int  `json:"status_code,omitempty"`
}

type WebhookDeliverPayload struct {
	URL       string            `json:"url"`
	Method    string            `json:"method,omitempty"`
	Headers   map[string]string `json:"headers,omitempty"`
	Body      string            `json:"body,omitempty"`
	TimeoutMS int64             `json:"timeout_ms,omitempty"`
}