exportapi

type AsyncRequester interface {
	RequestExport(ctx context.Context, actor export.Actor, req export.ExportRequest) (export.ExportRecord, error)
}

type AsyncResponse struct {
	ID          string `json:"id"`
	StatusURL   string `json:"status_url"`
	DownloadURL string `json:"download_url"`
}

type Config struct {
	Service             export.Service
	Runner              *export.Runner
	Store               export.ArtifactStore
	Guard               export.Guard
	ActorProvider       export.ActorProvider
	DeliveryPolicy      export.DeliveryPolicy
	AsyncRequester      AsyncRequester
	BasePath            string
	HistoryPath         string
	SignedURLTTL        time.Duration
	IdempotencyStore    IdempotencyStore
	IdempotencyTTL      time.Duration
	Logger              export.Logger
	IDGenerator         func() string
	RequestDecoder      RequestDecoder
	QueryRequestDecoder RequestDecoder
	DefinitionResolver  DefinitionResolver
	MaxBufferBytes      int64
}

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

type DefinitionResolver interface {
	ResolveDefinition(ctx context.Context, req export.ExportRequest) (string, error)
}

type DefinitionResolverFunc func(ctx context.Context, req export.ExportRequest) (string, error)

type DownloadPayload struct {
	ContentType    string
	Filename       string
	ExportID       string
	Size           int64
	MaxBufferBytes int64
	Reader         io.Reader
	Bytes          []byte
}

type DownloadResponder interface {
	WriteDownload(ctx context.Context, payload DownloadPayload) error
	WriteStream(ctx context.Context, contentType string, r io.Reader, opts ...StreamOption) error
}

type ErrorBody struct {
	Message string `json:"message"`
	Code    string `json:"code,omitempty"`
}

type ErrorResponse struct {
	Error ErrorBody `json:"error"`
}

type IdempotencyStore interface {
	Get(ctx context.Context, key string) (string, bool, error)
	Set(ctx context.Context, key, exportID string, ttl time.Duration) error
}

type JSONRequestDecoder struct {
	QueryDecoder QueryDecoder
}

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

type QueryDecoder func(definition, variant string, raw json.RawMessage) (any, error)

type QueryRequestDecoder struct{}

type Request interface {
	Context() context.Context
	Method() string
	Path() string
	URL() *url.URL
	Header(name string) string
	Query(name string) string
	Body() io.ReadCloser
}

type RequestDecoder interface {
	Decode(req Request) (export.ExportRequest, error)
}

type Response interface {
	DownloadResponder
	SetHeader(name, value string)
	DelHeader(name string)
	WriteHeader(status int)
	Write(data []byte) (int, error)
	WriteJSON(status int, payload any) error
	Writer() (io.Writer, bool)
	Redirect(location string, status int) error
}

type StreamOption func(*StreamOptions)

type StreamOptions struct {
	Filename       string
	ExportID       string
	ContentLength  int64
	MaxBufferBytes int64
}