models

type DeliveryAttempt struct {
	At     time.Time             `json:"at"`
	Status DeliveryAttemptStatus `json:"status"`
	Error  string                `json:"error"`
}

type DeliveryAttemptStatus string

type Flow struct {
	ID     string  `yaml:"id"`
	Source *Source `yaml:"source"`
	Sinks  []*Sink `yaml:"sinks"`
}

type InhooksConfig struct {
	Flows []*Flow `yaml:"flows"`
}

type Message struct {
	ID       string `json:"id"`
	FlowID   string `json:"flowID"`
	SourceID string `json:"sourceID"`
	// Ingested Request ID
	IngestedReqID string      `json:"ingestedReqID"`
	SinkID        string      `json:"sinkID"`
	HttpHeaders   http.Header `json:"httpHeaders"`
	RawQuery      string      `json:"rawQuery"`
	Payload       []byte      `json:"payload"`

	// Processing Info
	DeliveryAttempts []*DeliveryAttempt `json:"deliveryAttempts"`
	DeliverAfter     time.Time
}

type MessageStatus string

type QueueStatus string

type QueuedInfo struct {
	MessageID    string
	QueueStatus  QueueStatus
	DeliverAfter time.Time
}

type Sink struct {
	// Sink ID
	ID string `yaml:"id"`
	// Sink Type
	Type SinkType `yaml:"type"`
	// Sink Url for HTTP sinks
	URL string `yaml:"url"`
	// Process after delay
	Delay *time.Duration `yaml:"delay"`
	// Retry every x time
	RetryInterval *time.Duration `yaml:"retryInterval"`
	// Retry exponential multiplier. 1 is constant backoff. Set to > 1 for exponential backoff.
	RetryExpMultiplier *float64 `yaml:"retryExpMultiplier"`
	// Max attempts
	MaxAttempts *int `yaml:"maxAttempts"`
}

type SinkType string

type Source struct {
	ID   string     `yaml:"id"`
	Slug string     `yaml:"slug"`
	Type SourceType `yaml:"type"`
}

type SourceType string