storage

type Crdb interface {
	CreateJob(
		ctx context.Context,
		cidStr string,
		fileName string,
		timestamp *int64,
		cacheDuration int64,
		sign string,
		hash string,
	) error
	UnfinishedJobs(ctx context.Context) ([]UnfinishedJob, error)
	UpdateJobStatus(ctx context.Context, cid []byte, activation time.Time) error
}

type DBClient struct {
	// Initialize cockroachdb client to store metadata
	DB *sql.DB
}

type FileUploader struct {
	StorageClient GCS        // StorageClient is a GCS instance used to interact with GCS.
	DealClient    w3s.Client // DealClient is a w3s.Client instance used to interact with W3S.
	DBClient      Crdb       // DBClient is a Crdb instance used to interact with CockroachDB.
}

type GCS interface {
	GetObjectReader(ctx context.Context, bName, oName string) (io.ReadCloser, error)
	GetObjectMetadata(ctx context.Context, bName, oName string) (map[string]string, error)
	ParseEvent() (string, string, error)
}

type GCSClient struct {
	Client    *storage.Client
	EventData []byte
}

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

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

type MockReadCloser struct {
	*bytes.Reader
}

type Pub struct {
	Namespace string
	Relation  string
}

type StatusChecker struct {
	// StatusClient is a w3s.Client instance used to interact with W3S.
	StatusClient w3s.Client
	// DBClient is a Crdb instance used to interact with CockroachDB.
	DBClient Crdb
	// contains filtered or unexported fields
}

type StatusCheckerConfig struct {
	W3SToken         string
	CrdbConn         string
	PrivateKey       string
	BackendURL       string
	BasinStorageAddr string
	ChainID          string
}

type UnfinishedJob struct {
	Pub       Pub
	Cid       []byte
	Activated time.Time
	Timestamp *int64
	CachePath string
	ExpiresAt time.Time
}

type UploaderConfig struct {
	W3SToken string
	CrdbConn string
}