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"`
	AttemptAt     *int64           `json:"attempt_at" db:"attempt_at"` // attempted_at?
	Request       *AttemptRequest  `json:"request" db:"request"`
	Response      *AttemptResponse `json:"response" db:"response"`

	BaseModel
}

type AttemptRequest struct {
	Method string            `json:"method"`
	URL    string            `json:"url"`
	Header map[string]string `json:"header"`
	Body   string            `json:"body"`
}

type AttemptResponse struct {
	Status int               `json:"status"`
	Header map[string]string `json:"header"`
	Body   string            `json:"body"`
}

type AttemptStatus = string

type BaseModel struct {
	CreatedAt   UnixTime `db:"created_at" json:"created_at"`
	UpdatedAt   UnixTime `db:"updated_at" json:"updated_at"`
	WorkspaceId string   `db:"ws_id" json:"-"`
}

type CustomResponse struct {
	Code        int    `json:"code" validate:"required,gte=200,lte=599"`
	ContentType string `json:"content_type" validate:"required"`
	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" default:"true"`
	Request     RequestConfig  `json:"request" db:"request"`
	Retry       Retry          `json:"retry" db:"retry"`
	Events      pq.StringArray `json:"events" db:"events"`

	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"`

	BaseModel
}

type FixedStrategyConfig struct {
	Attempts []int64 `json:"attempts" default:"[0,60,3600]"`
}

type HeaderEntry struct {
	Name  string `json:"name"`
	Value string `json:"value"`
}

type Metadata map[string]string

type RequestConfig struct {
	URL     string        `json:"url" validate:"required"`
	Method  string        `json:"method" validate:"required,oneof=GET POST PUT DELETE PATCH"`
	Headers []HeaderEntry `json:"headers"`
	Timeout Timeout       `json:"timeout"`
}

type Retry struct {
	Strategy RetryStrategy       `json:"strategy" validate:"oneof=fixed" default:"fixed"`
	Config   FixedStrategyConfig `json:"config"`
}

type RetryStrategy string

type Source struct {
	ID   string  `json:"id" db:"id"`
	Name *string `json:"name" db:"name"`

	Enabled bool           `json:"enabled" db:"enabled"`
	Path    string         `json:"path" db:"path"`
	Methods pq.StringArray `json:"methods" db:"methods"`

	Response *CustomResponse `json:"response" db:"response"`

	BaseModel
}

type Timeout struct {
	Connect int `json:"connect" default:"60000" validate:"gt=0"`
	Read    int `json:"read" default:"60000" validate:"gt=0"`
	Write   int `json:"write" default:"60000" validate:"gt=0"`
}

type UnixTime struct {
	time.Time
}

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

	CreatedAt UnixTime `db:"created_at" json:"created_at"`
	UpdatedAt UnixTime `db:"updated_at" json:"updated_at"`
}