bitcoin

type AddressGenerator ¶

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

func NewAddressGenerator(masterPublicKeyString string, chainParams *chaincfg.Params) (*AddressGenerator, error)

func (g *AddressGenerator) Generate(index uint32) (string, error)

type Client ¶

type Client interface {
	GetBlockCount() (int64, error)
	GetBlockHash(blockHeight int64) (*chainhash.Hash, error)
	GetBlock(blockHash *chainhash.Hash) (*wire.MsgBlock, error)
}

type Listener ¶

type Listener struct {
	Enabled              bool
	Client               Client          `inject:""`
	Storage              storage.Storage `inject:""`
	TransactionHandler   TransactionHandler
	Testnet              bool
	ConfirmedBlockNumber uint64
	// contains filtered or unexported fields
}

Listener listens for transactions using bitcoin-core RPC. It calls TransactionHandler for each new transactions. It will reprocess the block if TransactionHandler returns error. It will start from the block number returned from Storage.GetBlockToProcess("bitcoin") or the latest block if it returned 0. Transactions can be processed more than once, it's TransactionHandler responsibility to ignore duplicates. Listener tracks only P2PKH payments. You can run multiple Listeners if Storage is implemented correctly.

func (l *Listener) Start() error

type Transaction ¶

type Transaction struct {
	Hash       string
	TxOutIndex int
	// Value in sats
	ValueSat int64
	To       string
}

func (t *Transaction) ValueToTomo() string

func (t *Transaction) ValueToWei() string

type TransactionHandler ¶

type TransactionHandler func(transaction Transaction) error