archive

type Archiver struct {

	// Now is the clock (tests set it).
	Now func() time.Time
	// MaxObjectBytes caps one object (0: defaultMaxObjectBytes).
	MaxObjectBytes int64
	// Report, when set, is told about every object and every run.
	Report func(Report)
	// contains filtered or unexported fields
}

type Config struct {
	// Env prefixes every key ("prod", "preview"); each environment's MinIO
	// user can only reach its own prefix.
	Env       string
	Endpoint  string
	Bucket    string
	Region    string
	AccessKey string
	SecretKey string
}

type Manifest struct {
	Schema  string   `json:"schema"`
	Columns []string `json:"columns"`
	Rows    int64    `json:"rows"`
	// FirstAt and LastAt are checked at verify and recorded in archive_months,
	// but not written to the plaintext manifest: after a crypto-shred the
	// manifest lingers until the deletion job runs, and should say nothing
	// about when the user drove (DA).
	FirstAt      string    `json:"-"`
	LastAt       string    `json:"-"`
	SHA256Plain  string    `json:"sha256_plain"`
	SHA256Object string    `json:"sha256_object"`
	Bytes        int64     `json:"bytes"`
	CreatedAt    time.Time `json:"created_at"`
}

type Querier interface {
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

type Report struct {
	Month     string
	UserID    uuid.UUID
	VehicleID uuid.UUID
	Rows      int64
	Bytes     int64
	Err       error
	// Done marks the run's summary: Objects archived, Failed objects.
	Done    bool
	Objects int
	Failed  int
}

type Stats struct {
	Rows        int64
	FirstAt     string
	LastAt      string
	SHA256Plain string
}