tenso

type Configuration struct {
	DatabaseURL   *url.URL
	EnabledRoutes []Route
}

type DeliveryHandler interface {
	pluggable.Plugin
	// Init will be called at least once during startup if this DeliveryHandler
	// is enabled in the configuration.
	//
	// A (ProviderClient, EndpointOpts) pair is provided for handlers that need to
	// talk to OpenStack. During unit tests, (nil, nil) will be provided instead.
	Init(pc *gophercloud.ProviderClient, eo gophercloud.EndpointOpts) error

	// The `routingInfo` argument contains the metadata that was supplied in the
	// `X-Tenso-Routing-Info` header when posting the original event.
	DeliverPayload(ctx context.Context, payload []byte, routingInfo map[string]string) (*DeliveryLog, error)
}

type DeliveryLog struct {
	Message string
}

type Event struct {
	ID              int64     `db:"id"`
	CreatorID       int64     `db:"creator_id"` // ID into the `users` table
	CreatedAt       time.Time `db:"created_at"`
	PayloadType     string    `db:"payload_type"`
	Payload         string    `db:"payload"`
	Description     string    `db:"description"`       // a short summary that appears in log messages
	RoutingInfoJSON string    `db:"routing_info_json"` // from the X-Tenso-Routing-Info header
}

type PayloadInfo struct {
	// Description is a short summary of the event with this payload. It is used
	// to identify the event in log messages.
	Description string
}

type PendingDelivery struct {
	EventID     int64  `db:"event_id"`
	PayloadType string `db:"payload_type"`
	// Payload and ConvertedAt are nil when the payload has not been converted from event.Payload yet.
	Payload               *string    `db:"payload"`
	ConvertedAt           *time.Time `db:"converted_at"`
	FailedConversionCount int64      `db:"failed_conversions"`
	NextConversionAt      time.Time  `db:"next_conversion_at"`
	FailedDeliveryCount   int64      `db:"failed_deliveries"`
	NextDeliveryAt        time.Time  `db:"next_delivery_at"`
}

type Route struct {
	SourcePayloadType  string
	TargetPayloadType  string
	ValidationHandler  ValidationHandler
	TranslationHandler TranslationHandler
	DeliveryHandler    DeliveryHandler
}

type TranslationHandler interface {
	pluggable.Plugin
	// Init will be called at least once during startup if this TranslationHandler
	// is enabled in the configuration.
	//
	// A (ProviderClient, EndpointOpts) pair is provided for handlers that need to
	// talk to OpenStack. During unit tests, (nil, {}) will be provided instead.
	Init(pc *gophercloud.ProviderClient, eo gophercloud.EndpointOpts) error

	TranslatePayload(payload []byte, routingInfo map[string]string) ([]byte, error)
}

type User struct {
	ID         int64  `db:"id"`
	UUID       string `db:"uuid"`
	Name       string `db:"name"`
	DomainName string `db:"domain_name"`
}

type ValidationHandler interface {
	pluggable.Plugin
	// Init will be called at least once during startup if this ValidationHandler
	// is enabled in the configuration.
	//
	// A (ProviderClient, EndpointOpts) pair is provided for handlers that need to
	// talk to OpenStack. During unit tests, (nil, nil) will be provided instead.
	Init(pc *gophercloud.ProviderClient, eo gophercloud.EndpointOpts) error

	ValidatePayload(payload []byte) (*PayloadInfo, error)
}