synapse

type AddPiecesStatusInput struct {
	ServiceURL         string
	StatusURL          string
	DataSetID          string
	TransactionID      string
	ExpectedPieceCount int
}

type ChainEpochReader interface {
	CurrentEpoch(ctx context.Context) (int64, error)
}

type CleanupContext interface {
	DeletePieceByID(context.Context, sdktypes.BigInt) (*sdktypes.WriteResult, error)
	PieceStatus(context.Context, cid.Cid) (*storage.PieceStatus, error)
}

type ClientConfig struct {
	PrivateKey           string
	RPCURL               string
	WithCDN              bool
	AllowPrivateNetworks bool
	Logger               *slog.Logger
}

type DataSetCreationStatusInput struct {
	StatusURL         string
	TransactionID     string
	ExpectedDataSetID string
}

type DataSetServiceEndedError struct {
	Cause error
}

type DataSetTarget interface {
	StorageTarget
	Store(context.Context, io.Reader, *storage.StoreOptions) (*storage.StoreResult, error)
	PresignForCommit(context.Context, []storage.PieceInput) ([]byte, error)
	Pull(context.Context, storage.PullRequest) (*storage.PullResult, error)
	SubmitCommit(context.Context, storage.CommitRequest) (*storage.CommitSubmission, error)
	GetCommitStatus(context.Context, storage.CommitSubmission) (*storage.CommitStatus, error)
	PieceStatus(context.Context, cid.Cid) (*storage.PieceStatus, error)
}

type NoProviderCandidatesError struct {
	Cause error
}

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

type PDPStatusCheckerOptions struct {
	Timeout              time.Duration
	AllowPrivateNetworks bool
}

type PDPStatusResult struct {
	State                  PDPStatusState
	StatusURL              string
	TxStatus               string
	DataSetID              string
	DataSetCreated         bool
	PiecesAdded            bool
	PieceCount             int
	ConfirmedPieceIDs      []string
	ConfirmedTransactionID string
	Error                  string
}

type PDPStatusState string

type PaymentAccountInfo struct {
	Funds               *big.Int
	AvailableFunds      *big.Int
	LockupCurrent       *big.Int
	LockupRate          *big.Int
	LockupLastSettledAt *big.Int
	FundedUntilEpoch    *big.Int
	FundedUntilTime     *time.Time
	RunwaySeconds       *int64
	LockupRatePerDay    *big.Int
	LockupRatePerMonth  *big.Int
	NoActiveSpend       bool
}

type ProviderTarget interface {
	StorageTarget
	CreateDataSet(context.Context, *storage.CreateDataSetOptions) (*storage.CreateDataSetResult, error)
	WaitForDataSetCreated(context.Context, storage.CreateDataSetSubmission) (*storage.CreateDataSetResult, error)
}

type ProviderUnavailableError struct {
	Cause error
}

type ReadinessCheck struct {
	ID            string          `json:"id"`
	Status        ReadinessStatus `json:"status"`
	Message       string          `json:"message"`
	Action        string          `json:"action,omitempty"`
	RequiredUSDFC string          `json:"required_usdfc,omitempty"`
}

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

type ReadinessCheckerOption func(*ReadinessChecker)

type ReadinessClient interface {
	Address() common.Address
	Chain() chain.Chain
	ResolvedAddresses() sdk.ResolvedAddresses
	Payments() readinessPayments
	Storage() readinessStorage
	Close() error
}

type ReadinessClientFactory func(context.Context, ReadinessConfig) (ReadinessClient, error)

type ReadinessConfig struct {
	Network              string
	RPCURL               string
	PrivateKey           string
	WithCDN              bool
	AllowPrivateNetworks bool
	DefaultCopies        int
}

type ReadinessMode string

type ReadinessResult struct {
	Status        ReadinessStatus   `json:"status"`
	Mode          ReadinessMode     `json:"mode"`
	CheckedAt     time.Time         `json:"checked_at"`
	Checks        []ReadinessCheck  `json:"checks"`
	PartialErrors map[string]string `json:"partial_errors,omitempty"`
}

type ReadinessStatus string

type ServiceTerminator interface {
	TerminateService(ctx context.Context, dataSetID sdktypes.BigInt) (*TerminationResult, error)
}

type StorageClient interface {
	Download(ctx context.Context, pieceCID cid.Cid, opts *storage.DownloadOptions) (io.ReadCloser, error)
	PrepareUpload(ctx context.Context, dataSize uint64, targets []StorageTarget) (*storage.MultiContextCosts, error)
	SelectUploadTargets(ctx context.Context, opts storage.SelectUploadContextsOptions) ([]StorageTarget, error)
	OpenProviderTarget(ctx context.Context, providerID sdktypes.BigInt, opts storage.NewProviderContextOptions) (ProviderTarget, error)
	OpenDataSetTarget(ctx context.Context, dataSetID sdktypes.BigInt, opts storage.NewDataSetContextOptions) (DataSetTarget, error)
	FindMatchingDataSet(ctx context.Context, providerID sdktypes.BigInt, metadata map[string]string, withCDN bool) (*storage.DataSetRef, error)
	OpenCleanupContext(ctx context.Context, dataSetID sdktypes.BigInt, opts storage.NewDataSetContextOptions) (CleanupContext, error)
}

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

type StorageTarget interface {
	ProviderID() sdktypes.BigInt
	DataSetRef() (storage.DataSetRef, bool)
	GetProviderInfo() storage.Provider
	CDNEnabled() bool
	PieceURL(cid.Cid) string
	ServiceURL() string
}

type TerminationBlockedError struct {
	Reason    string
	Shortfall *big.Int
	Err       error
}

type TerminationResult struct {
	TxHash   string
	EndEpoch int64
}

type WalletInfo struct {
	Address              string
	Network              string
	ChainID              int64
	Nonce                *uint64
	CurrentEpoch         *big.Int
	EpochDurationSeconds int64
	PaymentsAddress      string
	USDFCAddress         string
	USDFCDecimals        uint8
	FILGasBalance        *big.Int
	USDFCWalletBalance   *big.Int
	PaymentAccount       *PaymentAccountInfo
	Errors               map[string]string
}

type WalletOperator interface {
	FundUSDFC(ctx context.Context, amount *big.Int) (string, error)
	WithdrawUSDFC(ctx context.Context, amount *big.Int) (string, error)
	ApproveFWSS(ctx context.Context) (string, error)
}

type WalletQuerier interface {
	GetWalletInfo(ctx context.Context) (*WalletInfo, error)
}