sources

type Adapter interface {
	// Identity
	ID() string
	Name() string

	// Credentials
	CredentialFields() []CredentialField
	SetCredentials(creds map[string]string)
	ValidateCredentials(ctx context.Context) error

	// Data fetching
	FetchProducts(ctx context.Context) ([]ProductInfo, error)
	FetchDeliveries(ctx context.Context, productID string) ([]DeliveryInfo, error)
	FetchFiles(ctx context.Context, productID, deliveryID string) ([]FileInfo, error)

	// Download
	DownloadFile(ctx context.Context, file FileInfo, dst io.Writer, progress ProgressFunc) error
}

type AdapterConfig struct {
	DownloadTimeoutSeconds int
}

type AdapterError struct {
	Code    string
	Message string
	Err     error
}

type ConfigurableAdapter interface {
	Configure(cfg AdapterConfig)
}

type CredentialDecryptor interface {
	DecryptCredentials(ciphertext []byte) ([]byte, error)
}

type CredentialDecryptorEncryptor interface {
	CredentialEncryptor
	CredentialDecryptor
}

type CredentialEncryptor interface {
	EncryptCredentials(plaintext []byte) ([]byte, error)
}

type CredentialField struct {
	Key      string `json:"key"`
	Label    string `json:"label"`
	Type     string `json:"type"` // "text", "password"
	Required bool   `json:"required"`
	HelpText string `json:"helpText,omitempty"`
}

type DeliveryInfo struct {
	ExternalID  string     `json:"externalId"`
	Name        string     `json:"name"`
	PublishedAt time.Time  `json:"publishedAt"`
	ExpiresAt   *time.Time `json:"expiresAt,omitempty"`
}

type FileInfo struct {
	ExternalID        string    `json:"externalId"`
	FileName          string    `json:"fileName"`
	FileSize          int64     `json:"fileSize"`
	Checksum          string    `json:"checksum,omitempty"`
	ChecksumAlgorithm string    `json:"checksumAlgorithm,omitempty"`
	DownloadURI       string    `json:"downloadUri"`
	ReleasedAt        time.Time `json:"releasedAt"`
}

type ProductInfo struct {
	ExternalID    string `json:"externalId"`
	Name          string `json:"name"`
	Description   string `json:"description"`
	CheckSchedule string `json:"checkSchedule"` // Default cron schedule for this product
}

type ProgressFunc func(bytesWritten, totalBytes int64)

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

type SourceInfo struct {
	ID               string            `json:"id"`
	Name             string            `json:"name"`
	Enabled          bool              `json:"enabled"`
	HasCredentials   bool              `json:"hasCredentials"`
	LastSyncAt       *time.Time        `json:"lastSyncAt,omitempty"`
	CredentialFields []CredentialField `json:"credentialFields"`
}