kafka

type AvailabilityStatusMessage struct {
	SourceID string `json:"source_id"`
}

type Broker interface {
	// Send one or more messages to the kafka
	Send(ctx context.Context, messages ...*GenericMessage) error

	// Consume messages of a single topic in a loop. Blocking call, use context cancellation to stop.
	Consume(ctx context.Context, topic string, since time.Time, handler func(ctx context.Context, message *GenericMessage))
}

type GenericHeader struct {
	Key   string
	Value string
}

type GenericMessage struct {
	// Topic of the message. Some producers already have associated topic, in that case Topic from the message will be ignored.
	Topic string

	// Key is used for topic partitioning. Can be nil.
	Key []byte

	// Value is the payload. Typically, a JSON marshaled data.
	Value []byte

	// List of key-value pairs for each message.
	Headers []GenericHeader
}

type NativeMessage interface {
	// GenericMessage returns a generic message that is platform independent.
	GenericMessage(ctx context.Context) (GenericMessage, error)
}

type NotificationContext struct {
	LaunchID int64  `json:"launch_id"`
	Provider string `json:"provider"`
}

type NotificationError struct {
	Error string `json:"error"`
}

type NotificationEvent struct {
	Payload json.RawMessage `json:"payload"`
}

type NotificationMessage struct {
	Version     string                   `json:"version"`
	Bundle      string                   `json:"bundle"`
	Application string                   `json:"application"`
	EventType   string                   `json:"event_type"`
	Timestamp   string                   `json:"timestamp"`
	AccountID   string                   `json:"account_id"`
	OrgId       string                   `json:"org_id"`
	Context     interface{}              `json:"context"`
	Events      []NotificationEvent      `json:"events"`
	Recipients  []notificationRecipients `json:"recipients"`
	ID          string                   `json:"id"`
}

type SourceResult struct {
	MessageContext     context.Context `json:"-"` // Carries logger and identity
	ResourceID         string          `json:"resource_id"`
	ResourceType       string          `json:"resource_type"`
	Status             StatusType      `json:"status"`
	UserError          string          `json:"error"`
	Err                error           `json:"-"` // Sources do not support error field
	MissingPermissions []string        `json:"-"` // Sources do not support reason field
}

type StatusType string