events

type ArtifactPayload struct {
	AssetID          uuid.UUID `json:"assetId"`
	AssetVersionName string    `json:"assetVersionName"`
	ArtifactName     string    `json:"artifactName,omitempty"`
	UserAgent        string    `json:"userAgent,omitempty"`
	// the vulns a scan opened
	VulnIDs []uuid.UUID `json:"vulnIds,omitempty"`
}

type AssetPayload struct {
	AssetID uuid.UUID `json:"assetId"`
}

type AssetPipelinePayload struct {
	AssetID uuid.UUID `json:"assetId"`
}

type Broker interface {
	// pub/sub - broadcast to all instances of devguard
	Publish(ctx context.Context, topic PubSubTopic, payload any) error
	Subscribe(topic PubSubTopic, handler SubscribeHandler) error

	// deliver exactly once - only a single instance of devguard will receive the message and execute the handler.
	Notify(ctx context.Context, tx pgx.Tx, topic NotifyTopic, payload any, opts *NotifyOptions) error
	Listen(topic NotifyTopic, handler NotifyHandler) error
	// Schedule notifies the topic according to the cron expression - exactly once across all instances.
	Schedule(topic NotifyTopic, cronExpr string) error
	// FinishedSince returns the distinct payloads of the jobs of the topic which completed or were discarded after since.
	// match filters by payload containment (jsonb @>) - nil matches every job.
	// finished jobs are only kept for completedJobRetention, since must not lie further back.
	FinishedSince(ctx context.Context, topic NotifyTopic, since time.Time, match any) ([]json.RawMessage, error)

	IsHealthy() bool
}

type EmptyPayload struct{}

type EventBrokerImpl struct {
	*PostgreSQLBroker
	*Queue
}

type EventBrokerStub struct {
}

type InlineBroker struct {
	EventBrokerStub
	// contains filtered or unexported fields
}

type ListeningConnection struct {
	Conn        *pgxpool.Conn
	Subscribers []SubscribeHandler
}

type NotifyHandler = func(ctx context.Context, payload json.RawMessage) error

type NotifyOptions = river.InsertOpts

type NotifyTopic string

type Payload interface {
	AlertContext() monitoring.AlertContext
}

type PostgreSQLBroker struct {
	ID string // Unique identifier for the broker instance
	// contains filtered or unexported fields
}

type PostgreSQLMessage struct {
	ID        string          `json:"id"`
	Topic     PubSubTopic     `json:"topic"`
	Payload   json.RawMessage `json:"payload"`
	Timestamp time.Time       `json:"timestamp"`
	SenderID  string          `json:"sender_id,omitempty"` // Optional field for sender ID
}

type PubSubTopic string

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

type SubscribeHandler = func(ctx context.Context, payload json.RawMessage)