upload

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

type ArtifactConfirmRequest struct {
	ArtifactID     string    `json:"artifact_id"` // Backend-assigned ULID (required!)
	Filename       string    `json:"filename"`    // Changed from file_name to match backend
	ChecksumSHA256 string    `json:"checksum_sha256"`
	UploadedAt     time.Time `json:"uploaded_at"`
}

type ArtifactPresignRequest struct {
	Filename       string `json:"filename"` // Changed from file_name to match backend
	Role           string `json:"role"`     // Required by backend (manifest, data, log, etc.)
	ContentType    string `json:"content_type"`
	SizeBytes      int64  `json:"size_bytes"`
	ChecksumSHA256 string `json:"checksum_sha256"`
	Source         string `json:"source,omitempty"` // Optional, defaults to "cli"
}

type ArtifactPresignResponse struct {
	ArtifactID string            `json:"artifact_id"`          // Backend-assigned ULID
	URL        string            `json:"url,omitempty"`        // Presigned URL (empty if existing)
	Method     string            `json:"method,omitempty"`     // Usually "PUT"
	Headers    map[string]string `json:"headers,omitempty"`    // Additional headers required
	ExpiresAt  string            `json:"expires_at,omitempty"` // ISO timestamp
	Status     string            `json:"status,omitempty"`     // "existing" if artifact already uploaded
}

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

type Config struct {
	APIURL     string
	AuthToken  string
	ProjectID  string
	CacheRoot  string
	MaxRetries int
}

type ConfirmUploadRequest struct {
	Artifacts []ArtifactConfirmRequest `json:"artifacts"`
}

type CreateRunRequest struct {
	ProjectID    string               `json:"project_id"`
	Manifest     core.Manifest        `json:"manifest"`
	Source       core.SourceMeta      `json:"source"`
	Capture      core.CaptureSettings `json:"capture"`
	StartedAt    time.Time            `json:"started_at"`
	Completed    *time.Time           `json:"completed_at,omitempty"`
	RecordsCount uint64               `json:"records_count"`
}

type CreateRunResponse struct {
	RunID string `json:"run_id"`
}

type MockUploadCall struct {
	RunID string
	Error error
}

type MockUploadClient struct {

	// UploadFunc is called when UploadRun is invoked
	// If nil, returns success by default
	UploadFunc func(ctx context.Context, runID string) error

	// Calls tracks all calls to UploadRun
	Calls []MockUploadCall

	// Results maps runID to predetermined results
	// Useful for testing specific scenarios
	Results map[string]error
	// contains filtered or unexported fields
}

type PresignedURLRequest struct {
	Artifacts []ArtifactPresignRequest `json:"artifacts"`
}

type PresignedURLResponse struct {
	Artifacts []ArtifactPresignResponse `json:"artifacts"`
}

type UploadClient interface {
	UploadRun(ctx context.Context, runID string) error
}

type UploadResult struct {
	Artifact   core.Artifact
	Success    bool
	Attempts   int
	Error      error
	UploadedAt *time.Time
}

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