db

type Configurator interface {
	DBConStr() string
}

type DBMigrator struct {
	// contains filtered or unexported fields
}

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
}

type FilesystemProvider interface {
	ReadDir(name string) ([]fs.FileInfo, error)
	ReadFile(name string) ([]byte, error)
	Open(name string) (fs.File, error)
}

type Info struct {
	DBConnStr  string
	Port       string
	Database   string
	Migrations MigrationInfo
}

type Logger interface {
	Debug(msg string, ephemeralArgs ...any)
	Info(msg string, ephemeralArgs ...any)
	Error(msg string, err error, severity string, ephemeralArgs ...any)
}

type MigrationFS struct {
	FS embed.FS
}

type MigrationInfo struct {
	CurrentVersion int32
	TargetVersion  int32
	Stages         []Stage
	Summary        string
}

type Querier interface {
	GetAPIRequests(ctx context.Context) (RemoteApiRequest, error)
	StoreAPIRequest(ctx context.Context, arg StoreAPIRequestParams) error
}

type Queries struct {
	// contains filtered or unexported fields
}

type RemoteApiRequest struct {
	Id              int32              `db:"id" json:"id"`
	Url             string             `db:"url" json:"url"`
	Method          string             `db:"method" json:"method"`
	RequestHeaders  []byte             `db:"request_headers" json:"request_headers"`
	RequestBody     pgtype.Text        `db:"request_body" json:"request_body"`
	ResponseTimeMs  int64              `db:"response_time_ms" json:"response_time_ms"`
	ResponseHeaders []byte             `db:"response_headers" json:"response_headers"`
	ResponseBody    pgtype.Text        `db:"response_body" json:"response_body"`
	StatusCode      int32              `db:"status_code" json:"status_code"`
	CreatedAt       pgtype.Timestamptz `db:"created_at" json:"created_at"`
}

type Stage struct {
	Sequence int32
	Name     string
	Migrated bool
}

type StoreAPIRequestParams struct {
	Url             string      `db:"url" json:"url"`
	Method          string      `db:"method" json:"method"`
	RequestHeaders  []byte      `db:"request_headers" json:"request_headers"`
	RequestBody     pgtype.Text `db:"request_body" json:"request_body"`
	ResponseTimeMs  int64       `db:"response_time_ms" json:"response_time_ms"`
	ResponseHeaders []byte      `db:"response_headers" json:"response_headers"`
	ResponseBody    pgtype.Text `db:"response_body" json:"response_body"`
	StatusCode      int32       `db:"status_code" json:"status_code"`
}