export

type Actor struct {
	ID      string         `json:"id"`
	Scope   Scope          `json:"scope"`
	Roles   []string       `json:"roles,omitempty"`
	Details map[string]any `json:"details,omitempty"`
}

type ActorProvider interface {
	FromContext(ctx context.Context) (Actor, error)
}

type ArtifactMeta struct {
	ContentType string    `json:"content_type,omitempty"`
	Size        int64     `json:"size,omitempty"`
	Filename    string    `json:"filename,omitempty"`
	CreatedAt   time.Time `json:"created_at,omitempty"`
	ExpiresAt   time.Time `json:"expires_at,omitempty"`
}

type ArtifactRef struct {
	Key  string       `json:"key"`
	Meta ArtifactMeta `json:"meta"`
}

type ArtifactStore interface {
	Put(ctx context.Context, key string, r io.Reader, meta ArtifactMeta) (ArtifactRef, error)
	Open(ctx context.Context, key string) (io.ReadCloser, ArtifactMeta, error)
	Delete(ctx context.Context, key string) error
	SignedURL(ctx context.Context, key string, ttl time.Duration) (string, error)
}

type ArtifactTracker interface {
	SetArtifact(ctx context.Context, id string, ref ArtifactRef) error
}

type AugmentTransformer struct {
	Columns     []Column
	AugmentFunc RowAugmentFunc
}

type BufferedTransformer interface {
	Process(ctx context.Context, rows RowIterator, schema Schema) ([]Row, Schema, error)
}

type BufferedTransformerFactory func(config TransformerConfig) (BufferedTransformer, error)

type CSVOptions struct {
	IncludeHeaders bool
	Delimiter      rune
	HeadersSet     bool
}

type CSVRenderer struct{}

type CancelHook interface {
	Cancel(ctx context.Context, exportID string) error
}

type ChangeEmitter interface {
	Emit(ctx context.Context, evt ChangeEvent) error
}

type ChangeEvent struct {
	Name       string
	ExportID   string
	Definition string
	Format     Format
	Delivery   DeliveryMode
	Actor      Actor
	Timestamp  time.Time
	Metadata   map[string]any
}

type Column struct {
	Name   string
	Label  string
	Type   string
	Format ColumnFormat
}

type ColumnFormat struct {
	Layout string
	Number string
	Excel  string
}

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

type DeleteParams struct {
	Record  ExportRecord
	Tracker ProgressTracker
	Store   ArtifactStore
	Now     time.Time
}

type DeleteStrategy interface {
	Delete(ctx context.Context, params DeleteParams) error
}

type DeliveryMode string

type DeliveryPolicy struct {
	Default    DeliveryMode
	Thresholds DeliveryThresholds
}

type DeliveryThresholds struct {
	MaxRows     int
	MaxBytes    int64
	MaxDuration time.Duration
}

type DownloadInfo struct {
	ExportID string
	Artifact ArtifactRef
}

type ErrorKind string

type ExportCounts struct {
	Processed int64 `json:"processed,omitempty"`
	Total     int64 `json:"total,omitempty"`
	Errors    int64 `json:"errors,omitempty"`
}

type ExportDefinition struct {
	Name             string
	Resource         string
	Schema           Schema
	AllowedFormats   []Format
	DefaultFilename  string
	RowSourceKey     string
	Transformers     []TransformerConfig
	DefaultSelection Selection
	SelectionPolicy  SelectionPolicy
	SourceVariants   map[string]SourceVariant
	Policy           ExportPolicy
	DeliveryPolicy   *DeliveryPolicy
	Template         TemplateOptions
}

type ExportError struct {
	Kind ErrorKind
	Msg  string
	Err  error
}

type ExportPolicy struct {
	AllowedColumns []string
	RedactColumns  []string
	RedactionValue any
	MaxRows        int
	MaxBytes       int64
	MaxDuration    time.Duration
}

type ExportRecord struct {
	ID           string        `json:"id"`
	Definition   string        `json:"definition"`
	Format       Format        `json:"format"`
	State        ExportState   `json:"state"`
	RequestedBy  Actor         `json:"requested_by"`
	Scope        Scope         `json:"scope"`
	Request      ExportRequest `json:"-"`
	Counts       ExportCounts  `json:"counts"`
	BytesWritten int64         `json:"bytes_written,omitempty"`
	Artifact     ArtifactRef   `json:"artifact"`
	CreatedAt    time.Time     `json:"created_at"`
	StartedAt    time.Time     `json:"started_at,omitempty"`
	CompletedAt  time.Time     `json:"completed_at,omitempty"`
	ExpiresAt    time.Time     `json:"expires_at,omitempty"`
}

type ExportRequest struct {
	Definition        string
	Resource          string
	SourceVariant     string
	Format            Format
	Query             any
	Selection         Selection
	Columns           []string
	Locale            string
	Timezone          string
	Delivery          DeliveryMode
	IdempotencyKey    string
	EstimatedRows     int
	EstimatedBytes    int64
	EstimatedDuration time.Duration
	Output            io.Writer
	RenderOptions     RenderOptions
}

type ExportResult struct {
	ID       string       `json:"id"`
	Delivery DeliveryMode `json:"delivery"`
	Format   Format       `json:"format"`
	Rows     int64        `json:"rows"`
	Bytes    int64        `json:"bytes"`
	Filename string       `json:"filename"`
	Artifact *ArtifactRef `json:"artifact,omitempty"`
}

type ExportState string

type FilterTransformer struct {
	FilterFunc RowFilterFunc
}

type Format string

type FormatOptions struct {
	Locale   string
	Timezone string
}

type Guard interface {
	AuthorizeExport(ctx context.Context, actor Actor, req ExportRequest, def ResolvedDefinition) error
	AuthorizeDownload(ctx context.Context, actor Actor, exportID string) error
}

type JSONMode string

type JSONOptions struct {
	Mode JSONMode
}

type JSONRenderer struct{}

type Logger interface {
	Debugf(format string, args ...any)
	Infof(format string, args ...any)
	Errorf(format string, args ...any)
}

type MapTransformer struct {
	MapFunc RowMapFunc
}

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

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

type MetricsEvent struct {
	Name       string
	ExportID   string
	Definition string
	Format     Format
	Delivery   DeliveryMode
	Actor      Actor
	Rows       int64
	Bytes      int64
	Duration   time.Duration
	ErrorKind  ErrorKind
	Timestamp  time.Time
}

type MetricsHook interface {
	Emit(ctx context.Context, evt MetricsEvent) error
}

type NopLogger struct{}

type PDFExternalAssetsPolicy string

type PDFOptions struct {
	PageSize             string
	Landscape            *bool
	PrintBackground      *bool
	Scale                float64
	MarginTop            string
	MarginBottom         string
	MarginLeft           string
	MarginRight          string
	PreferCSSPageSize    *bool
	BaseURL              string
	ExternalAssetsPolicy PDFExternalAssetsPolicy
}

type ProgressDelta struct {
	Rows  int64
	Bytes int64
}

type ProgressFilter struct {
	Definition string
	State      ExportState
	Since      time.Time
	Until      time.Time
}

type ProgressTracker interface {
	Start(ctx context.Context, record ExportRecord) (string, error)
	Advance(ctx context.Context, id string, delta ProgressDelta, meta map[string]any) error
	SetState(ctx context.Context, id string, state ExportState, meta map[string]any) error
	Fail(ctx context.Context, id string, err error, meta map[string]any) error
	Complete(ctx context.Context, id string, meta map[string]any) error
	Status(ctx context.Context, id string) (ExportRecord, error)
	List(ctx context.Context, filter ProgressFilter) ([]ExportRecord, error)
}

type QuotaHook interface {
	Allow(ctx context.Context, actor Actor, req ExportRequest, def ResolvedDefinition) error
}

type RateLimiter struct {
	Max     int
	Window  time.Duration
	KeyFunc func(actor Actor, req ExportRequest, def ResolvedDefinition) string
	Now     func() time.Time
	// contains filtered or unexported fields
}

type RecordDeleter interface {
	Delete(ctx context.Context, id string) error
}

type RecordUpdater interface {
	Update(ctx context.Context, record ExportRecord) error
}

type RenderOptions struct {
	CSV      CSVOptions
	JSON     JSONOptions
	Template TemplateOptions
	XLSX     XLSXOptions
	SQLite   SQLiteOptions
	PDF      PDFOptions
	Format   FormatOptions
}

type RenderStats struct {
	Rows  int64
	Bytes int64
}

type Renderer interface {
	Render(ctx context.Context, schema Schema, rows RowIterator, w io.Writer, opts RenderOptions) (RenderStats, error)
}

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

type ResolvedDefinition struct {
	ExportDefinition
	Variant string
}

type ResolvedExport struct {
	Request       ExportRequest
	Definition    ResolvedDefinition
	Columns       []Column
	ColumnNames   []string
	RedactIndices map[int]any
	Filename      string
}

type RetentionPolicy interface {
	TTL(ctx context.Context, actor Actor, req ExportRequest, def ResolvedDefinition) (time.Duration, error)
}

type RetentionRule struct {
	Definition string
	Format     Format
	Role       string
	TTL        time.Duration
}

type RetentionRules struct {
	DefaultTTL   time.Duration
	ByDefinition map[string]time.Duration
	ByFormat     map[Format]time.Duration
	ByRole       map[string]time.Duration
	Rules        []RetentionRule
	RoleResolver func(actor Actor) []string
}

type RouterRegistrar interface {
	RegisterRoutes(router any)
}

type Row []any

type RowAugmentFunc func(ctx context.Context, row Row) ([]any, error)

type RowFilterFunc func(ctx context.Context, row Row) (bool, error)

type RowIterator interface {
	Next(ctx context.Context) (Row, error)
	Close() error
}

type RowMapFunc func(ctx context.Context, row Row) (Row, error)

type RowSource interface {
	Open(ctx context.Context, spec RowSourceSpec) (RowIterator, error)
}

type RowSourceFactory func(req ExportRequest, def ResolvedDefinition) (RowSource, error)

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

type RowSourceSpec struct {
	Definition ResolvedDefinition
	Request    ExportRequest
	Columns    []Column
	Actor      Actor
}

type RowTransformer interface {
	Wrap(ctx context.Context, in RowIterator, schema Schema) (RowIterator, Schema, error)
}

type Runner struct {
	Definitions    *DefinitionRegistry
	RowSources     *RowSourceRegistry
	Renderers      *RendererRegistry
	Transformers   *TransformerRegistry
	Tracker        ProgressTracker
	Store          ArtifactStore
	Guard          Guard
	ActorProvider  ActorProvider
	Logger         Logger
	Emitter        ChangeEmitter
	Metrics        MetricsHook
	QuotaHook      QuotaHook
	Retention      RetentionPolicy
	DeliveryPolicy DeliveryPolicy
	Now            func() time.Time
	IDGenerator    func() string
}

type SQLiteOptions struct {
	TableName string
}

type Schema struct {
	Columns []Column
}

type Scope struct {
	TenantID    string `json:"tenant_id,omitempty"`
	WorkspaceID string `json:"workspace_id,omitempty"`
}

type Selection struct {
	Mode  SelectionMode
	IDs   []string
	Query SelectionQueryRef
}

type SelectionMode string

type SelectionPolicy interface {
	DefaultSelection(ctx context.Context, actor Actor, req ExportRequest, def ResolvedDefinition) (Selection, bool, error)
}

type SelectionPolicyFunc func(ctx context.Context, actor Actor, req ExportRequest, def ResolvedDefinition) (Selection, bool, error)

type SelectionQueryRef struct {
	Name   string
	Params any
}

type Service interface {
	RequestExport(ctx context.Context, actor Actor, req ExportRequest) (ExportRecord, error)
	GenerateExport(ctx context.Context, actor Actor, exportID string, req ExportRequest) (ExportResult, error)
	CancelExport(ctx context.Context, actor Actor, exportID string) (ExportRecord, error)
	DeleteExport(ctx context.Context, actor Actor, exportID string) error
	Status(ctx context.Context, actor Actor, exportID string) (ExportRecord, error)
	History(ctx context.Context, actor Actor, filter ProgressFilter) ([]ExportRecord, error)
	DownloadMetadata(ctx context.Context, actor Actor, exportID string) (DownloadInfo, error)
	Cleanup(ctx context.Context, now time.Time) (int, error)
}

type ServiceConfig struct {
	Runner         *Runner
	Tracker        ProgressTracker
	Store          ArtifactStore
	Guard          Guard
	DeliveryPolicy DeliveryPolicy
	DeleteStrategy DeleteStrategy
	CancelHook     CancelHook
	Now            func() time.Time
	IDGenerator    func() string
}

type SoftDeleteStrategy struct{}

type SourceVariant struct {
	RowSourceKey    string
	AllowedFormats  []Format
	DefaultFilename string
	Transformers    []TransformerConfig
	Policy          *ExportPolicy
	Template        *TemplateOptions
}

type TemplateOptions struct {
	Strategy     TemplateStrategy
	MaxRows      int
	TemplateName string
	Layout       string
	Title        string
	Definition   string
	GeneratedAt  time.Time
	ChartConfig  any
	Theme        map[string]any
	Header       map[string]any
	Footer       map[string]any
	Data         map[string]any
}

type TemplateStrategy string

type TombstoneDeleteStrategy struct {
	TTL time.Duration
}

type TransformerConfig struct {
	Key    string         `json:"key"`
	Params map[string]any `json:"params,omitempty"`
}

type TransformerFactory func(config TransformerConfig) (RowTransformer, error)

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

type XLSXOptions struct {
	IncludeHeaders bool
	HeadersSet     bool
	SheetName      string
	MaxRows        int
	MaxBytes       int64
}

type XLSXRenderer struct{}