fibre

type API struct {
	Internal struct {
		Submit func(
			context.Context,
			libshare.Namespace,
			[]byte,
			*txclient.TxConfig,
		) (*SubmitResult, error) `perm:"write"`
		Upload func(
			ctx context.Context,
			ns libshare.Namespace,
			data []byte,
			config *txclient.TxConfig,
		) (*UploadResult, error) `perm:"write"`
		Download func(
			ctx context.Context,
			blobID appfibre.BlobID,
		) (*GetBlobResult, error) `perm:"read"`
		QueryEscrowAccount func(
			ctx context.Context,
			signer string,
		) (*fibre.EscrowAccount, error) `perm:"read"`
		Deposit func(
			ctx context.Context,
			amount sdktypes.Coin,
			cfg *txclient.TxConfig,
		) error `perm:"write"`
		Withdraw func(
			ctx context.Context,
			amount sdktypes.Coin,
			cfg *txclient.TxConfig,
		) error `perm:"write"`
		PendingWithdrawals func(
			ctx context.Context,
			signer string,
		) ([]fibre.PendingWithdrawal, error) `perm:"read"`
	}
}

type GetBlobResult struct {
	Data []byte `json:"data"`
}

type Module interface {
	// Submit runs the full flow: upload to FSPs, aggregate validator signatures,
	// and settle MsgPayForFibre on-chain. Requires a Fibre-capable core endpoint.
	Submit(context.Context, libshare.Namespace, []byte, *txclient.TxConfig) (*SubmitResult, error)
	// Upload does the off-chain half (encode, promise, upload, aggregate
	// signatures) and then sumbits MsgPayForFibre on-chain
	// asynchronously in the background. Use Submit for the full flow.
	Upload(context.Context, libshare.Namespace, []byte, *txclient.TxConfig) (*UploadResult, error)
	// Download reconstructs a blob from FSPs by blobID.
	Download(context.Context, appfibre.BlobID) (*GetBlobResult, error)
	// QueryEscrowAccount returns the escrow account for the given signer.
	QueryEscrowAccount(_ context.Context, signer string) (*fibre.EscrowAccount, error)
	// Deposit adds funds to the node's escrow account.
	Deposit(context.Context, sdktypes.Coin, *txclient.TxConfig) error
	// Withdraw requests a withdrawal; funds unbond before becoming claimable.
	Withdraw(context.Context, sdktypes.Coin, *txclient.TxConfig) error
	// PendingWithdrawals returns not-yet-claimable withdrawals for the signer.
	PendingWithdrawals(_ context.Context, signer string) ([]fibre.PendingWithdrawal, error)
}

type PaymentPromise struct {
	ChainID           string              `json:"chain_id"`
	Namespace         libshare.Namespace  `json:"namespace"`
	BlobSize          uint32              `json:"blob_size"`
	Commitment        appfibre.Commitment `json:"commitment"`
	RowVersion        uint32              `json:"row_version"`
	ValsetHeight      uint64              `json:"valset_height"`
	CreationTimestamp time.Time           `json:"creation_timestamp"`
	Signature         []byte              `json:"signature"`
}

type SubmitResult struct {
	UploadResult
	Height uint64 `json:"height"`
	TxHash string `json:"tx_hash"`
}

type UploadResult struct {
	BlobID              appfibre.BlobID      `json:"blob_id"`
	ValidatorSignatures []ValidatorSignature `json:"validator_signatures"`
	PaymentPromise      *PaymentPromise      `json:"payment_promise,omitempty"`
}

type ValidatorSignature []byte