importexport

type CancelExportCommand struct {
	ExportID string `json:"export_id" validate:"required"`
	Username string `json:"username" validate:"required"` // For authorization
}

type CreateExportCommand struct {
	Username     string            `json:"username" validate:"required"`
	Type         string            `json:"type" validate:"required,oneof=archive followers following lists bookmarks mutes blocks"`
	Format       string            `json:"format" validate:"required,oneof=activitypub mastodon csv"`
	IncludeMedia bool              `json:"include_media"`
	DateRange    *DateRange        `json:"date_range"`
	Options      map[string]string `json:"options"`
	RequestedBy  string            `json:"requested_by" validate:"required"`
}

type CreateImportCommand struct {
	Username      string            `json:"username" validate:"required"`
	Type          string            `json:"type" validate:"required,oneof=archive followers following lists bookmarks mutes blocks"`
	Format        string            `json:"format" validate:"required,oneof=activitypub mastodon csv"`
	FileURL       string            `json:"file_url" validate:"required,url"`
	Options       map[string]string `json:"options"`
	MergeStrategy string            `json:"merge_strategy" validate:"required,oneof=merge replace skip"`
	RequestedBy   string            `json:"requested_by" validate:"required"`
}

type DateRange struct {
	Start time.Time `json:"start"`
	End   time.Time `json:"end"`
}

type ExportListResult struct {
	Exports    []*models.Export  `json:"exports"`
	NextCursor string            `json:"next_cursor"`
	HasMore    bool              `json:"has_more"`
	Events     []streaming.Event `json:"-"`
}

type ExportResult struct {
	Export      *models.Export    `json:"export"`
	DownloadURL string            `json:"download_url,omitempty"`
	ExpiresAt   *time.Time        `json:"expires_at,omitempty"`
	Events      []streaming.Event `json:"-"` // Events emitted during operation
}

type GetExportQuery struct {
	ExportID string `json:"export_id" validate:"required"`
	Username string `json:"username" validate:"required"` // For authorization
}

type GetImportQuery struct {
	ImportID string `json:"import_id" validate:"required"`
	Username string `json:"username" validate:"required"` // For authorization
}

type ImportListResult struct {
	Imports    []*models.Import  `json:"imports"`
	NextCursor string            `json:"next_cursor"`
	HasMore    bool              `json:"has_more"`
	Events     []streaming.Event `json:"-"`
}

type ImportResult struct {
	Import    *models.Import    `json:"import"`
	Processed int               `json:"processed"`
	Skipped   int               `json:"skipped"`
	Failed    int               `json:"failed"`
	Events    []streaming.Event `json:"-"` // Events emitted during operation
}

type ListExportsQuery struct {
	Username   string                       `json:"username" validate:"required"`
	Status     string                       `json:"status"` // pending, processing, completed, failed
	Pagination interfaces.PaginationOptions `json:"pagination"`
}

type ListImportsQuery struct {
	Username   string                       `json:"username" validate:"required"`
	Status     string                       `json:"status"` // pending, processing, completed, failed
	Pagination interfaces.PaginationOptions `json:"pagination"`
}

type QueueService interface {
	QueueExportJob(ctx context.Context, exportID string) error
	QueueImportJob(ctx context.Context, importID string) error
}

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

type StorageClient interface {
	GeneratePresignedURL(ctx context.Context, key string, expiry time.Duration) (string, error)
	UploadFile(ctx context.Context, key string, data []byte) error
	GetFile(ctx context.Context, key string) ([]byte, error)
}