pangea

type APIError struct {
	BaseError

	// the reponse header of the request if any
	ResponseHeader *ResponseHeader

	// the result of the request
	RawResult json.RawMessage

	// error details
	PangeaErrors PangeaErrors
}

type AcceptedError struct {
	ResponseHeader
	ResultField    any
	AcceptedResult AcceptedResult
	Response
}

type AcceptedResult struct {
	TTLMins      int               `json:"ttl_mins"`
	RetryCounter int               `json:"retry_counter"`
	Location     string            `json:"location"`
	PostURL      string            `json:"post_url"`
	PutURL       string            `json:"put_url"`
	PostFormData map[string]string `json:"post_form_data"`
}

type AttachedFile struct {
	Filename    string
	File        []byte
	ContentType string
}

type AttachedFileSaveInfo struct {
	Filename string
	Folder   string
}

type BaseError struct {
	// The underlying error that triggered this one, if any.
	Err error

	// the HTTP response
	HTTPResponse *http.Response
}

type BaseRequest struct {
	// Config ID.
	ConfigID string `json:"config_id,omitempty"`
}

type BaseService struct {
	Client *Client
}

type BaseServicer interface {
	GetPendingRequestID() []string
	PollResultByError(ctx context.Context, e AcceptedError) (*PangeaResponse[any], error)
	PollResultByID(ctx context.Context, rid string, v any) (*PangeaResponse[any], error)
	PollResultRaw(ctx context.Context, requestID string) (*PangeaResponse[map[string]any], error)
	DownloadFile(ctx context.Context, url string) (*AttachedFile, error)
}

type Client struct {

	// Client logger
	Logger zerolog.Logger
	// contains filtered or unexported fields
}

type ClientOption func(*Client) error

type Config struct {
	// The Bearer token used to authenticate requests.
	Token string

	// Config ID for multi-config projects
	// @deprecated: Set config_id with options in service initialization if supported
	ConfigID string

	// The HTTP client to be used by the client. It defaults to
	// defaults.HTTPClient
	HTTPClient *http.Client

	// Base domain for API requests.
	Domain string

	// Set to true to use plain http
	Insecure bool

	// Environment specifies the Pangea environment. If set to "local", then
	// Domain must be the full host (i.e., hostname and port) for the Pangea
	// service that this Config will be used for.
	Environment string

	// Set to "local" for testing locally
	//
	// Deprecated: Enviroment is a typo. Use Environment instead.
	Enviroment string

	// AdditionalHeaders is a map of additional headers to be sent with the request.
	AdditionalHeaders map[string]string

	// Custom user agent is a string to be added to pangea sdk user agent header and identify app
	CustomUserAgent string

	// if it should retry request
	// if HTTPClient is set in the config this value won't take effect
	Retry bool

	// Enable queued request retry support
	QueuedRetryEnabled bool

	// Timeout used to poll results after HTTP/202.
	PollResultTimeout time.Duration

	// Retry config defaults to a base retry option
	RetryConfig *RetryConfig

	// Logger
	Logger *zerolog.Logger
}

type ConfigIDer interface {
	SetConfigID(configID string)
	GetConfigID() string
}

type ErrorField struct {
	Code   string `json:"code"`
	Detail string `json:"detail"`
	Source string `json:"source"`
	Path   string `json:"path,omitempty"`
}

type FileData struct {
	File    io.Reader
	Name    string
	Details map[string]string
}

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

type Filter map[string]any

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

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

type FilterEqual[T any] struct {
	FilterCommon
}

type FilterMatch[T any] struct {
	FilterEqual[T]
}

type FilterRange[T any] struct {
	FilterEqual[T]
}

type Option func(*BaseService) error

type PangeaErrors struct {
	Errors []ErrorField `json:"errors,omitempty"`
}

type PangeaResponse[T any] struct {
	Response
	Result         *T
	AcceptedResult *AcceptedResult
}

type Response struct {
	ResponseHeader
	HTTPResponse  *http.Response
	AttachedFiles []AttachedFile

	// Query raw result
	RawResult json.RawMessage `json:"result"`
	// contains filtered or unexported fields
}

type ResponseHeader struct {
	// The request ID
	RequestID *string `json:"request_id"`

	// The time the request was issued, ISO8601
	RequestTime *string `json:"request_time"`

	// The time the response was issued, ISO8601
	ResponseTime *string `json:"response_time"`

	// The HTTP status code msg
	Status *string `json:"status"`

	// The summary of the response
	Summary *string `json:"summary"`
}

type RetryConfig struct {
	RetryWaitMin time.Duration // Minimum time to wait
	RetryWaitMax time.Duration // Maximum time to wait
	RetryMax     int           // Maximum number of retries
	BackOff      float32       //Exponential back of factor
}

type TransferMethod string

type TransferRequest struct {
	TransferMethod TransferMethod `json:"transfer_method,omitempty"` // The transfer method used to upload the file data.
}

type TransferRequester interface {
	GetTransferMethod() TransferMethod
}

type UnmarshalError struct {
	BaseError

	Bytes []byte
}

type UploadFileParams struct {
	Size   int    `json:"size,omitempty"`
	CRC32C string `json:"crc32c,omitempty"`
	SHA256 string `json:"sha256,omitempty"`
}