cosmwasm

Documentation

Index

• Constants
• func EventsToMessagePublications(contract string, txHash string, events []gjson.Result, logger *zap.Logger, ...) []*common.MessagePublication
• func StringToAddress(value string) (vaa.Address, error)
• func StringToHash(value string) (eth_common.Hash, error)
• type Watcher
  • func NewWatcher(urlWS string, urlLCD string, contract string, ...) *Watcher
  • func (e *Watcher) Run(ctx context.Context) error
• type WatcherConfig
  • func (wc *WatcherConfig) Create(msgC chan<- *common.MessagePublication, ...) (interfaces.L1Finalizer, supervisor.Runnable, error)
  • func (wc *WatcherConfig) GetChainID() vaa.ChainID
  • func (wc *WatcherConfig) GetNetworkID() watchers.NetworkID
  • func (wc *WatcherConfig) RequiredL1Finalizer() watchers.NetworkID
  • func (wc *WatcherConfig) SetL1Finalizer(l1finalizer interfaces.L1Finalizer)

Constants

const ReadLimitSize = 524288

ReadLimitSize can be used to increase the read limit size on the listening connection. The default read limit size is not large enough, causing "failed to read: read limited at 32769 bytes" errors during testing. Increasing this limit effects an internal buffer that is used to as part of the zero alloc/copy design.

Functions

func EventsToMessagePublications

func EventsToMessagePublications(contract string, txHash string, events []gjson.Result, logger *zap.Logger, chainID vaa.ChainID, contractAddressKey string, b64Encoded bool) []*common.MessagePublication

func StringToAddress

func StringToAddress(value string) (vaa.Address, error)

StringToAddress convert string into address

func StringToHash

func StringToHash(value string) (eth_common.Hash, error)

StringToHash convert string into transaction hash

Types

type Watcher

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

Watcher is responsible for looking over a cosmwasm blockchain and reporting new transactions to the contract

func NewWatcher

func NewWatcher(
	urlWS string,
	urlLCD string,
	contract string,
	msgC chan<- *common.MessagePublication,
	obsvReqC <-chan *gossipv1.ObservationRequest,
	chainID vaa.ChainID,
	env common.Environment,
) *Watcher

NewWatcher creates a new cosmwasm contract watcher

func (*Watcher) Run

func (e *Watcher) Run(ctx context.Context) error

type WatcherConfig

type WatcherConfig struct {
	NetworkID watchers.NetworkID // human readable name
	ChainID   vaa.ChainID        // ChainID
	Websocket string             // Websocket URL
	Lcd       string             // LCD
	Contract  string             // hex representation of the contract address
}

func (*WatcherConfig) Create

func (wc *WatcherConfig) Create(
	msgC chan<- *common.MessagePublication,
	obsvReqC <-chan *gossipv1.ObservationRequest,
	_ <-chan *query.PerChainQueryInternal,
	_ chan<- *query.PerChainQueryResponseInternal,
	_ chan<- *common.PhylaxSet,
	env common.Environment,
) (interfaces.L1Finalizer, supervisor.Runnable, error)

func (*WatcherConfig) GetChainID

func (wc *WatcherConfig) GetChainID() vaa.ChainID

func (*WatcherConfig) GetNetworkID

func (wc *WatcherConfig) GetNetworkID() watchers.NetworkID

func (*WatcherConfig) RequiredL1Finalizer

func (wc *WatcherConfig) RequiredL1Finalizer() watchers.NetworkID

func (*WatcherConfig) SetL1Finalizer

func (wc *WatcherConfig) SetL1Finalizer(l1finalizer interfaces.L1Finalizer)