transactions

Documentation

Index

• Constants
• type AlephiumTxInfo
• type AlephiumWatcher
  • func NewAlephiumWatcher(config *common.ChainConfig, nodeUrl string, apiKey string, logger *zap.Logger, ...) *AlephiumWatcher
  • func (w *AlephiumWatcher) Run() func(ctx context.Context) error
• type BlockTransactions
• type BridgeTransaction
• type EVMWatcher
  • func NewEVMWatcher(logger *zap.Logger, ctx context.Context, rpcUrl string, chainId vaa.ChainID, ...) (*EVMWatcher, error)
  • func (w *EVMWatcher) Run() func(ctx context.Context) error
• type EventsPerIndex
• type Input
• type TransactionUpdate
• type Watcher
  • func NewWatcher(logger *zap.Logger, configs *common.BridgeConfig, db *mongo.Database, ...) *Watcher
  • func (w *Watcher) GetLatestEventIndex(ctx context.Context, emitterChain vaa.ChainID) (*uint32, error)
  • func (w *Watcher) GetLatestEventIndexAlephium(ctx context.Context) (*uint32, error)
  • func (w *Watcher) GetLatestEventIndexBsc(ctx context.Context) (*uint32, error)
  • func (w *Watcher) GetLatestEventIndexEth(ctx context.Context) (*uint32, error)
  • func (w *Watcher) GetLatestEventIndexEvm(ctx context.Context, chainId vaa.ChainID, confirmations uint32) (*uint32, error)
  • func (w *Watcher) Run() func(context.Context) error

Constants

const ALPHContractAddressPrefix byte = 3

const BlockRangeLimit = 5000

Types

type AlephiumTxInfo

type AlephiumTxInfo struct {
	Inputs []Input `json:"inputs"`
}

type AlephiumWatcher

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

func NewAlephiumWatcher

func NewAlephiumWatcher(
	config *common.ChainConfig,
	nodeUrl string,
	apiKey string,
	logger *zap.Logger,
	blockTxsC chan<- []*BlockTransactions,
	explorerBackendUrl string,
	fromEventIndex uint32,
	pollInterval uint,
) *AlephiumWatcher

func (*AlephiumWatcher) Run

func (w *AlephiumWatcher) Run() func(ctx context.Context) error

type BlockTransactions

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

type BridgeTransaction

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

type EVMWatcher

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

func NewEVMWatcher

func NewEVMWatcher(
	logger *zap.Logger,
	ctx context.Context,
	rpcUrl string,
	chainId vaa.ChainID,
	chainConfig *common.ChainConfig,
	getEventIndex func(context.Context) (*uint32, error),
	blockTxsC chan<- []*BlockTransactions,
) (*EVMWatcher, error)

func (*EVMWatcher) Run

func (w *EVMWatcher) Run() func(ctx context.Context) error

type EventsPerIndex

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

type Input

type Input struct {
	Address string `json:"address"`
}

type TransactionUpdate

type TransactionUpdate struct {
	ID           string      `bson:"_id"`
	TxId         string      `bson:"txId"`
	Address      string      `bson:"address"`
	BlockHash    string      `bson:"blockHash"`
	BlockNumber  uint32      `bson:"blockNumber"`
	EventIndex   uint32      `bson:"eventIndex"`
	Sequence     uint64      `bson:"sequence"`
	EmitterChain vaa.ChainID `bson:"emitterChain"`
	TargetChain  vaa.ChainID `bson:"targetChain"`
	Timestamp    *time.Time  `bson:"timestamp"`
}

type Watcher

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

func NewWatcher

func NewWatcher(logger *zap.Logger, configs *common.BridgeConfig, db *mongo.Database, blockTxsC chan []*BlockTransactions) *Watcher

func (*Watcher) GetLatestEventIndex

func (w *Watcher) GetLatestEventIndex(ctx context.Context, emitterChain vaa.ChainID) (*uint32, error)

func (*Watcher) GetLatestEventIndexAlephium

func (w *Watcher) GetLatestEventIndexAlephium(ctx context.Context) (*uint32, error)

func (*Watcher) GetLatestEventIndexBsc

func (w *Watcher) GetLatestEventIndexBsc(ctx context.Context) (*uint32, error)

func (*Watcher) GetLatestEventIndexEth

func (w *Watcher) GetLatestEventIndexEth(ctx context.Context) (*uint32, error)

func (*Watcher) GetLatestEventIndexEvm

func (w *Watcher) GetLatestEventIndexEvm(ctx context.Context, chainId vaa.ChainID, confirmations uint32) (*uint32, error)

func (*Watcher) Run

func (w *Watcher) Run() func(context.Context) error