notifications

type Consumer interface {
	Process(ctx context.Context, details NotificationDetails) (string, error)
	Target() Target
}

type ContentType string

type Dispatcher interface {
	Dispatch(ctx context.Context, refID refs.Identifiable, notification NotificationData) (refs.Identifiable, error)
}

type NotificationData struct {
	Target      string      `json:"target"`
	Recipients  []string    `json:"recipients"`
	Subject     string      `json:"subject"`
	Content     string      `json:"content"`
	ContentType ContentType `json:"content_type"`
}

type NotificationDetails struct {
	RefID  refs.Identifiable
	Data   NotificationData
	State  ProcessingState
	ID     refs.Identifiable
	Out    string
	Target Target
	Err    string
}

type NotificationID refs.Identifiable

type NotificationSummary struct {
	State          ProcessingState `db:"state"`
	NotificationID string          `db:"notification_id"`
	Transport      string          `db:"transport"`
	Timestamp      string          `db:"timestamp"`
	Out            string          `db:"out"`
	Err            string          `db:"err"`
}

type ProcessingState string

type Processor interface {
	Close() error
}

type Store interface {
	Create(ctx context.Context, details NotificationDetails) error
	SetDone(ctx context.Context, details NotificationDetails, out string) error
	SetError(ctx context.Context, details NotificationDetails, out, err string) error
	NotificationStream(target Target) chan NotificationDetails
	Close() error
}

type Target string