storjscan

Documentation

Index

• Variables
• type Client
  • func NewClient(endpoint, identifier, secret string) *Client
  • func (client *Client) ClaimNewEthAddress(ctx context.Context) (_ blockchain.Address, err error)
  • func (client *Client) Payments(ctx context.Context, from int64) (_ LatestPayments, err error)
• type Config
• type DB
• type Header
• type LatestPayments
• type Payment
• type Service
  • 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)
• type WalletsDB

Variables

var (
	// ClientErr is general purpose storjscan client error class.
	ClientErr = errs.Class("storjscan client")
	// ClientErrUnauthorized is unauthorized err storjscan client error class.
	ClientErrUnauthorized = errs.Class("storjscan client unauthorized")
)

var (
	// Error defines storjscan service error.
	Error = errs.Class("storjscan service")
)

Types

type Client

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

Client is storjscan HTTP API client.

func NewClient

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

NewClient creates new storjscan API client.

func (*Client) ClaimNewEthAddress

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

ClaimNewEthAddress claims a new ethereum wallet address for the given user.

func (*Client) Payments

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

Payments retrieves all payments after specified block for wallets associated with particular API key.

type Config

type Config struct {
	Endpoint string `help:"storjscan API endpoint"`
	Auth     struct {
		Identifier string `help:"basic auth identifier"`
		Secret     string `help:"basic auth secret"`
	}
	Confirmations int `help:"required number of following blocks in the chain to accept payment as confirmed" default:"12"`
}

Config stores needed information for storjscan service initialization.

type DB

type DB interface {
	// Wallets is getter for wallets db.
	Wallets() WalletsDB
}

DB is storjscan DB interface.

architecture: Database

type Header

type Header struct {
	Hash      blockchain.Hash
	Number    int64
	Timestamp time.Time
}

Header holds ethereum blockchain block header data.

type LatestPayments

type LatestPayments struct {
	LatestBlock Header
	Payments    []Payment
}

LatestPayments contains latest payments and latest chain block header.

type Payment

type Payment struct {
	From        blockchain.Address
	To          blockchain.Address
	TokenValue  *big.Int
	BlockHash   blockchain.Hash
	BlockNumber int64
	Transaction blockchain.Hash
	LogIndex    int
	Timestamp   time.Time
}

Payment holds storjscan payment data.

type Service

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

Service is an implementation for payment service via Stripe and Coinpayments.

architecture: Service

func NewService

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

NewService creates a Service instance.

func (*Service) Claim

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

Claim gets a new crypto wallet and associates it with a user.

func (*Service) Get

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

Get returns the crypto wallet address associated with the given user.

type WalletsDB

type WalletsDB interface {
	// Add adds a new storjscan wallet to the DB and associates it with a user.
	Add(ctx context.Context, userID uuid.UUID, walletAddress blockchain.Address) error
	// Get returns the wallet address associated with the given user.
	Get(ctx context.Context, userID uuid.UUID) (blockchain.Address, error)
	// GetAllUsers returns all user IDs that have associated storjscan wallets.
	GetAllUsers(ctx context.Context) (_ []uuid.UUID, err error)
}

WalletsDB is an interface which defines functionality of DB which stores user storjscan wallets.

architecture: Database