pingpong

type ConsumerBalance struct {
	BCBalance          *big.Int
	BCSettled          *big.Int
	GrandTotalPromised *big.Int

	// IsOffchain is an optional indicator which marks an offchain balanace.
	// Offchain balances receive no updates on the blockchain and their
	// actual remaining balance should be retreived from hermes.
	IsOffchain       bool
	LastOffchainSync time.Time
}

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

type ConsumerBalanceTrackerConfig struct {
	FastSync PollConfig
	LongSync PollConfig
}

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

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

type DataTransferred struct {
	Up, Down uint64
}

type ExchangeRequest struct {
	Message crypto.ExchangeMessage `json:"exchangeMessage"`
}

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

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

type HermesCallerFactory func(url string) HermesHTTPRequester

type HermesChannel struct {
	ChannelID string
	Identity  identity.Identity
	HermesID  common.Address
	Channel   client.ProviderChannel

	Beneficiary common.Address
	// contains filtered or unexported fields
}

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

type HermesErrorResponse struct {
	CausedBy     string `json:"cause"`
	ErrorMessage string `json:"message"`
	ErrorData    string `json:"data"`
	// contains filtered or unexported fields
}

type HermesHTTPRequester interface {
	PayAndSettle(rp RequestPromise) (crypto.Promise, error)
	RequestPromise(rp RequestPromise) (crypto.Promise, error)
	RevealR(r string, provider string, agreementID *big.Int) error
	UpdatePromiseFee(promise crypto.Promise, newFee *big.Int) (crypto.Promise, error)
	GetConsumerData(chainID int64, id string, cacheTime time.Duration) (HermesUserInfo, error)
	GetProviderData(chainID int64, id string) (HermesUserInfo, error)
	SyncProviderPromise(promise crypto.Promise, signer identity.Signer) error
}

type HermesPromise struct {
	ChannelID   string
	Identity    identity.Identity
	HermesID    common.Address
	Promise     crypto.Promise
	R           string
	Revealed    bool
	AgreementID *big.Int
}

type HermesPromiseFilter struct {
	Identity *identity.Identity
	HermesID *common.Address
	ChainID  int64
}

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

type HermesPromiseHandlerDeps struct {
	HermesPromiseStorage hermesPromiseStorage
	FeeProvider          feeProvider
	Encryption           encryption
	EventBus             eventbus.Publisher
	HermesURLGetter      hermesURLGetter
	HermesCallerFactory  HermesCallerFactory
	Signer               identity.SignerFactory
	Chains               []int64
}

type HermesPromiseSettler interface {
	ForceSettle(chainID int64, providerID identity.Identity, hermesID ...common.Address) error
	ForceSettleAsync(chainID int64, providerID identity.Identity, hermesID ...common.Address) error
	SettleWithBeneficiary(chainID int64, providerID identity.Identity, beneficiary common.Address, hermeses []common.Address) error
	SettleIntoStake(chainID int64, providerID identity.Identity, hermesID ...common.Address) error
	GetHermesFee(chainID int64, hermesID common.Address) (uint16, error)
	Withdraw(fromChainID int64, toChainID int64, providerID identity.Identity, hermesID, beneficiary common.Address, amount *big.Int) error
	CheckLatestWithdrawal(chainID int64, providerID identity.Identity, hermesID common.Address) (*big.Int, string, error)
	RetryWithdrawLatest(chainID int64, amountToWithdraw *big.Int, chid string, beneficiary common.Address, providerID identity.Identity) error
}

type HermesPromiseSettlerConfig struct {
	MaxFeeThreshold         float64
	MinAutoSettleAmount     float64
	MaxUnSettledAmount      float64
	L1ChainID               int64
	L2ChainID               int64
	SettlementCheckInterval time.Duration
	SettlementCheckTimeout  time.Duration
	BalanceThreshold        float64
}

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

type HermesStatus struct {
	HermesID   common.Address
	ChainID    int64
	IsActive   bool
	Fee        uint16
	ValidUntil time.Time
}

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

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

type HermesUserInfo struct {
	Identity         string        `json:"Identity"`
	Beneficiary      string        `json:"Beneficiary"`
	ChannelID        string        `json:"ChannelID"`
	Balance          *big.Int      `json:"Balance"`
	Settled          *big.Int      `json:"Settled"`
	Stake            *big.Int      `json:"Stake"`
	LatestPromise    LatestPromise `json:"LatestPromise"`
	LatestSettlement time.Time     `json:"LatestSettlement"`
	IsOffchain       bool          `json:"IsOffchain"`
}

type HistoryType string

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

type InvoicePayerDeps struct {
	InvoiceChan               chan crypto.Invoice
	PeerExchangeMessageSender PeerExchangeMessageSender
	ConsumerTotalsStorage     consumerTotalsStorage
	TimeTracker               timeTracker
	Ks                        hashSigner
	Identity, Peer            identity.Identity
	AgreedPrice               market.Price
	SenderUUID                string
	SessionID                 string
	AddressProvider           addressProvider
	EventBus                  eventbus.EventBus
	HermesAddress             common.Address
	DataLeeway                datasize.BitSize
	ChainID                   int64
}

type InvoiceRequest struct {
	Invoice crypto.Invoice `json:"invoice"`
}

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

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

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

type InvoiceTrackerDeps struct {
	AgreedPrice                market.Price
	Peer                       identity.Identity
	PeerInvoiceSender          PeerInvoiceSender
	InvoiceStorage             providerInvoiceStorage
	TimeTracker                timeTracker
	ChargePeriodLeeway         time.Duration
	ExchangeMessageChan        chan crypto.ExchangeMessage
	ExchangeMessageWaitTimeout time.Duration
	ProviderID                 identity.Identity
	ConsumersHermesID          common.Address
	AddressProvider            addressProvider
	MaxHermesFailureCount      uint64
	MaxAllowedHermesFee        uint16
	HermesStatusChecker        hermesStatusChecker
	EventBus                   eventbus.EventBus
	SessionID                  string
	PromiseHandler             promiseHandler
	ChainID                    int64
	ChargePeriod               time.Duration
	LimitChargePeriod          time.Duration
	LimitNotPaidInvoice        *big.Int
	MaxNotPaidInvoice          *big.Int
	Observer                   observerApi
}

type LatestPromise struct {
	ChainID   int64    `json:"ChainID"`
	ChannelID string   `json:"ChannelID"`
	Amount    *big.Int `json:"Amount"`
	Fee       *big.Int `json:"Fee"`
	Hashlock  string   `json:"Hashlock"`
	Signature string   `json:"Signature"`
}

type PeerExchangeMessageSender interface {
	Send(crypto.ExchangeMessage) error
}

type PeerInvoiceSender interface {
	Send(crypto.Invoice) error
}

type PollConfig struct {
	Interval time.Duration
	Timeout  time.Duration
}

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

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

type RequestPromise struct {
	ExchangeMessage crypto.ExchangeMessage `json:"exchange_message"`
	TransactorFee   *big.Int               `json:"transactor_fee"`
	RRecoveryData   string                 `json:"r_recovery_data"`
}

type RevealObject struct {
	R           string
	Provider    string
	AgreementID *big.Int
}

type RevealSuccess struct {
	Message string `json:"message"`
}

type SetPromiseFeeRequest struct {
	HermesPromise crypto.Promise `json:"hermes_promise"`
	NewFee        *big.Int       `json:"new_fee"`
}

type SettlementHistoryEntry struct {
	TxHash           common.Hash `storm:"id"`
	BlockExplorerURL string
	ProviderID       identity.Identity
	HermesID         common.Address
	ChannelAddress   common.Address
	Time             time.Time
	Promise          crypto.Promise
	Beneficiary      common.Address
	Amount           *big.Int
	TotalSettled     *big.Int
	Fees             *big.Int
	IsWithdrawal     bool
	Error            string
}

type SettlementHistoryFilter struct {
	TimeFrom   *time.Time
	TimeTo     *time.Time
	ProviderID *identity.Identity
	HermesID   *common.Address
	Types      []HistoryType
}

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