opencodeevent

type ChannelGate ¶

type ChannelGate interface {
	Channels(context.Context) (desktop, webhook bool)
}

ChannelGate binds a product setup decision to the same event observation. Legacy test gates retain their existing allow-all-channel behavior.

type Clock ¶

type Clock interface {
	Now() (bootID string, seconds float64, err error)
}

type Consumer ¶

type Consumer struct {
	Gate        Gate
	Config      *config.Config
	Desktop     notification.DeliveryPort
	Clock       Clock
	SendWebhook WebhookSender
}

func (c Consumer) Consume(ctx context.Context, input io.Reader) Receipt

type Gate ¶

type Gate interface{ Enabled(context.Context) bool }

Gate is the current, read-only opt-in and registration decision. A nil gate denies delivery. PR4 supplies the persisted implementation at composition.

type GateFunc ¶

type GateFunc func(context.Context) bool

func (f GateFunc) Enabled(ctx context.Context) bool

type Receipt ¶

type Receipt struct {
	Status  string `json:"status"`
	Reason  string `json:"reason,omitempty"`
	Desktop string `json:"desktop,omitempty"`
	Webhook string `json:"webhook,omitempty"`
}

Receipt contains only stable classification. It never includes event IDs, raw data, transport errors, configuration, or remote response content.

type WebhookSender ¶

type WebhookSender func(*config.Config, webhook.SendContext) error

WebhookSender allows a single, non-replayed external attempt.