storjscan

Mar 15, 2024

Changes in this version

type CachedPayment

+ ChainID int64

type Header

+ ChainID int64

type LatestPayments

+ LatestBlocks []Header

type Payment

+ ChainID int64

type PaymentsDB

+ LastBlocks func(ctx context.Context, status payments.PaymentStatus) (map[int64]int64, error)

type Service

+ func (service *Service) Sources() []string

Jul 24, 2023

Changes in this version

type Client

+ func (client *Client) AllPayments(ctx context.Context, from int64) (payments LatestPayments, err error)

type Service

+ func (service *Service) PaymentsWithConfirmations(ctx context.Context, wallet blockchain.Address) (_ []payments.WalletPaymentWithConfirmations, err error)

Aug 22, 2022

Changes in this version

type PaymentsDB

+ ListConfirmed func(ctx context.Context, blockNumber int64, logIndex int) ([]CachedPayment, error)

type Service

+ func (service *Service) GetNewTransactions(ctx context.Context, _ time.Time, lastPaymentMetadata []byte) ([]billing.Transaction, error)

+ func (service *Service) Source() string

+ func (service *Service) Type() billing.TransactionType

+ type Wallet struct

+ Address blockchain.Address

+ UserID uuid.UUID

type WalletsDB

+ GetAll func(ctx context.Context) (_ []Wallet, err error)

+ GetUser func(ctx context.Context, wallet blockchain.Address) (uuid.UUID, error)

+ GetWallet func(ctx context.Context, userID uuid.UUID) (blockchain.Address, error)

Aug 8, 2022

Changes in this version

type CachedPayment

+ USDValue monetary.Amount

Jul 25, 2022

Changes in this version

+ var ErrService = errs.Class("storjscan service")

type Config

+ DisableLoop bool

+ Interval time.Duration

type Service

+ func (service *Service) Payments(ctx context.Context, wallet blockchain.Address, limit int, offset int64) (_ []payments.WalletPayment, err error)

Jul 13, 2022

Changes in this version

type Payment

+ USDValue float64

Jun 29, 2022

Changes in this version

+ const PaymentStatusConfirmed

+ const PaymentStatusPending

+ var ChoreErr = errs.Class("storjscan chore")

+ var ErrNoPayments = errs.New("no payments in the database")

+ type CachedPayment struct

+ BlockHash blockchain.Hash

+ BlockNumber int64

+ From blockchain.Address

+ LogIndex int

+ Status PaymentStatus

+ Timestamp time.Time

+ To blockchain.Address

+ TokenValue monetary.Amount

+ Transaction blockchain.Hash

+ type Chore struct

+ TransactionCycle *sync2.Cycle

+ func NewChore(log *zap.Logger, client *Client, paymentsDB PaymentsDB, confirmations int, ...) *Chore

+ func (chore *Chore) Close() (err error)

+ func (chore *Chore) Run(ctx context.Context) (err error)

+ type PaymentStatus string

+ type PaymentsDB interface

+ DeletePending func(ctx context.Context) error

+ InsertBatch func(ctx context.Context, payments []CachedPayment) error

+ LastBlock func(ctx context.Context, status PaymentStatus) (int64, error)

+ List func(ctx context.Context) ([]CachedPayment, error)

+ ListWallet func(ctx context.Context, wallet blockchain.Address, limit int, offset int64) ([]CachedPayment, error)

Jun 13, 2022

Changes in this version

+ var Error = errs.Class("storjscan service")

type Client

+ func (client *Client) ClaimNewEthAddress(ctx context.Context) (_ blockchain.Address, err error)

+ type Config struct

+ Auth struct{ ... }

+ Confirmations int

+ Endpoint string

+ type Service struct

+ func NewService(db DB, storjscanClient *Client) (*Service, error)

+ func (service *Service) Claim(ctx context.Context, userID uuid.UUID) (_ blockchain.Address, err error)

+ func (service *Service) Get(ctx context.Context, userID uuid.UUID) (_ blockchain.Address, err error)

May 30, 2022

Changes in this version

+ var ClientErr = errs.Class("storjscan client")

+ var ClientErrUnauthorized = errs.Class("storjscan client unauthorized")

+ type Client struct

+ func NewClient(endpoint, identifier, secret string) *Client

+ func (client *Client) Payments(ctx context.Context, from int64) (_ LatestPayments, err error)

+ type DB interface

+ Wallets func() WalletsDB

+ type Header struct

+ Hash blockchain.Hash

+ Number int64

+ Timestamp time.Time

+ type LatestPayments struct

+ LatestBlock Header

+ Payments []Payment

+ type Payment struct

+ BlockHash blockchain.Hash

+ BlockNumber int64

+ From blockchain.Address

+ LogIndex int

+ Timestamp time.Time

+ To blockchain.Address

+ TokenValue *big.Int

+ Transaction blockchain.Hash

+ type WalletsDB interface

+ Add func(ctx context.Context, userID uuid.UUID, walletAddress blockchain.Address) error

+ Get func(ctx context.Context, userID uuid.UUID) (blockchain.Address, error)

+ GetAllUsers func(ctx context.Context) (_ []uuid.UUID, err error)