entities

type Attempt struct {
	ID            string             `json:"id" db:"id"`
	EventId       string             `json:"event_id" db:"event_id"`
	EndpointId    string             `json:"endpoint_id" db:"endpoint_id"`
	Status        AttemptStatus      `json:"status" db:"status"`
	AttemptNumber int                `json:"attempt_number" db:"attempt_number"`
	ScheduledAt   types.Time         `json:"scheduled_at" db:"scheduled_at"`
	AttemptedAt   *types.Time        `json:"attempted_at" db:"attempted_at"`
	TriggerMode   AttemptTriggerMode `json:"trigger_mode" db:"trigger_mode"`
	Exhausted     bool               `json:"exhausted" db:"exhausted"`

	ErrorCode *AttemptErrorCode `json:"error_code" db:"error_code"`
	Request   *AttemptRequest   `json:"request" db:"request"`
	Response  *AttemptResponse  `json:"response" db:"response"`

	Event *Event `json:"-" db:"-"`

	BaseModel
}

type AttemptDetail struct {
	ID              string   `json:"id" db:"id"`
	RequestHeaders  Headers  `json:"request_headers" db:"request_headers"`
	RequestBody     *string  `json:"request_body" db:"request_body"`
	ResponseHeaders *Headers `json:"response_headers" db:"response_headers"`
	ResponseBody    *string  `json:"response_body" db:"response_body"`

	BaseModel
}

type AttemptErrorCode = string

type AttemptRequest struct {
	Method  string  `json:"method"`
	URL     string  `json:"url"`
	Headers Headers `json:"headers"`
	Body    *string `json:"body"`
}

type AttemptResponse struct {
	Status  int     `json:"status"`
	Latency int64   `json:"latency"`
	Headers Headers `json:"headers"`
	Body    *string `json:"body"`
}

type AttemptStatus = string

type AttemptTriggerMode = string

type BaseModel struct {
	CreatedAt   *types.Time `db:"created_at" json:"created_at,omitempty"`
	UpdatedAt   *types.Time `db:"updated_at" json:"updated_at,omitempty"`
	WorkspaceId string      `db:"ws_id" json:"-"`
}

type CustomResponse struct {
	Code        int    `json:"code"`
	ContentType string `json:"content_type"`
	Body        string `json:"body"`
}

type Endpoint struct {
	ID          string        `json:"id" db:"id"`
	Name        *string       `json:"name" db:"name"`
	Description *string       `json:"description" db:"description"`
	Enabled     bool          `json:"enabled" db:"enabled"`
	Request     RequestConfig `json:"request" db:"request"`
	Retry       Retry         `json:"retry" db:"retry"`
	Events      Strings       `json:"events" db:"events"`
	Metadata    Metadata      `json:"metadata" db:"metadata"`
	RateLimit   *RateLimit    `json:"rate_limit" db:"rate_limit"`

	Plugins []*Plugin `json:"-" db:"-"`

	BaseModel
}

type Event struct {
	ID         string          `json:"id" validate:"required"`
	EventType  string          `json:"event_type" db:"event_type" validate:"required"`
	Data       json.RawMessage `json:"data" validate:"required"`
	IngestedAt types.Time      `json:"ingested_at" db:"ingested_at"`
	UniqueId   *string         `json:"unique_id" db:"unique_id" validate:"omitempty,max=50"`

	BaseModel
}

type FixedStrategyConfig struct {
	Attempts []int64 `json:"attempts"`
}

type Headers map[string]string

type HttpSourceConfig struct {
	Path     string          `json:"path"`
	Methods  Strings         `json:"methods"`
	Response *CustomResponse `json:"response"`
}

type Metadata map[string]string

type Plugin struct {
	ID         string              `json:"id" db:"id"`
	Name       string              `json:"name" db:"name"`
	Enabled    bool                `json:"enabled" db:"enabled"`
	EndpointId *string             `json:"endpoint_id" db:"endpoint_id"`
	SourceId   *string             `json:"source_id" db:"source_id"`
	Config     PluginConfiguration `json:"config" db:"config"`
	Metadata   Metadata            `json:"metadata" db:"metadata"`

	BaseModel
}

type PluginConfiguration map[string]interface{}

type RateLimit struct {
	Quota  int `json:"quota"`
	Period int `json:"period"`
}

type RequestConfig struct {
	URL     string  `json:"url"`
	Method  string  `json:"method"`
	Headers Headers `json:"headers"`
	Timeout int64   `json:"timeout"`
}

type Retry struct {
	Strategy RetryStrategy       `json:"strategy"`
	Config   FixedStrategyConfig `json:"config"`
}

type RetryStrategy string

type Schema interface {
	SchemaName() string
}

type Source struct {
	ID        string       `json:"id" db:"id"`
	Name      *string      `json:"name" db:"name"`
	Enabled   bool         `json:"enabled" db:"enabled"`
	Type      string       `json:"type" db:"type"`
	Config    SourceConfig `json:"config" db:"config"`
	Async     bool         `json:"async" db:"async"`
	Metadata  Metadata     `json:"metadata" db:"metadata"`
	RateLimit *RateLimit   `json:"rate_limit" db:"rate_limit"`

	Plugins []*Plugin `json:"-" db:"-"`

	BaseModel
}

type SourceConfig struct {
	HTTP HttpSourceConfig `json:"http"`
}

type Strings = pq.StringArray

type Workspace struct {
	ID          string   `json:"id" db:"id"`
	Name        *string  `json:"name" db:"name"`
	Description *string  `json:"description" db:"description"`
	Metadata    Metadata `json:"metadata" db:"metadata"`

	CreatedAt types.Time `db:"created_at" json:"created_at"`
	UpdatedAt types.Time `db:"updated_at" json:"updated_at"`
}