ethcall

Documentation

Index

• func AnyArgsToJson(args []any) ([]string, error)
• func CanonicalizeJSON(in []byte) ([]byte, error)
• func JsonArgsToAny(methodName string, jsonArgs []string, abiJSON []byte) ([]any, error)
• type Call
  • func NewCall(spec ethcallcommon.Spec) (Call, error)
  • func (c Call) Call(ctx context.Context, ethClient EthReaderCaller, blockNumber uint64) (Result, error)
  • func (c Call) Spec() ethcallcommon.Spec
• type Config
  • func NewDefaultConfig() Config
• type ContractCallEvent
  • func EthereumContractCallResultFromProto(qr *vegapb.EthContractCallEvent) (ContractCallEvent, error)
  • func (q ContractCallEvent) Hash() string
  • func (q *ContractCallEvent) IntoProto() *vegapb.EthContractCallEvent
• type Engine
  • func NewEngine(log *logging.Logger, cfg Config, isValidator bool, client EthReaderCaller, ...) *Engine
  • func (e *Engine) CallSpec(ctx context.Context, id string, atBlock uint64) (Result, error)
  • func (e *Engine) EnsureChainID(chainID string, blockInterval uint64, confirmWithClient bool)
  • func (e *Engine) GetEthTime(ctx context.Context, atBlock uint64) (uint64, error)
  • func (e *Engine) GetInitialTriggerTime(id string) (uint64, error)
  • func (e *Engine) GetRequiredConfirmations(id string) (uint64, error)
  • func (e *Engine) GetSpec(id string) (common.Spec, bool)
  • func (e *Engine) MakeResult(specID string, bytes []byte) (Result, error)
  • func (e *Engine) OnSpecActivated(ctx context.Context, spec datasource.Spec) error
  • func (e *Engine) OnSpecDeactivated(ctx context.Context, spec datasource.Spec)
  • func (e *Engine) Poll(ctx context.Context, wallTime time.Time)
  • func (e *Engine) ReloadConf(cfg Config)
  • func (e *Engine) Start()
  • func (e *Engine) StartAtHeight(height uint64, time uint64)
  • func (e *Engine) Stop()
• type EthReaderCaller
• type Forwarder
• type Result
  • func NewResult(spec ethcallcommon.Spec, bytes []byte) (Result, error)

Functions

func AnyArgsToJson

func AnyArgsToJson(args []any) ([]string, error)

AnyArgsToJson does the inverse of the JsonArgsToAny; takes a list of arguments in go types and marshals them to a list of JSON strings.

func CanonicalizeJSON

func CanonicalizeJSON(in []byte) ([]byte, error)

func JsonArgsToAny

func JsonArgsToAny(methodName string, jsonArgs []string, abiJSON []byte) ([]any, error)

JsonArgsToAny takes a list of arguments marshalled as JSON strings. It then uses the ethereum ABI to convert each JSON argument into the go type which corresponds to the ethereum type defined in the ABI for that argument.

Types

type Call

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

func NewCall

func NewCall(spec ethcallcommon.Spec) (Call, error)

func (Call) Call

func (c Call) Call(ctx context.Context, ethClient EthReaderCaller, blockNumber uint64) (Result, error)

func (Call) Spec

func (c Call) Spec() ethcallcommon.Spec

type Config

type Config struct {
	Level                                   encoding.LogLevel `long:"log-level"`
	PollEvery                               encoding.Duration
	HeartbeatIntervalForTestOnlyDoNotChange encoding.Duration
}

func NewDefaultConfig

func NewDefaultConfig() Config

type ContractCallEvent

type ContractCallEvent struct {
	BlockHeight   uint64
	BlockTime     uint64
	SpecId        string
	Result        []byte
	Error         *string
	SourceChainID *uint64
	Heartbeat     bool
}

func EthereumContractCallResultFromProto

func EthereumContractCallResultFromProto(
	qr *vegapb.EthContractCallEvent,
) (ContractCallEvent, error)

func (ContractCallEvent) Hash

func (q ContractCallEvent) Hash() string

func (*ContractCallEvent) IntoProto

func (q *ContractCallEvent) IntoProto() *vegapb.EthContractCallEvent

type Engine

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

func NewEngine

func NewEngine(log *logging.Logger, cfg Config, isValidator bool, client EthReaderCaller, forwarder Forwarder) *Engine

func (*Engine) CallSpec

func (e *Engine) CallSpec(ctx context.Context, id string, atBlock uint64) (Result, error)

func (*Engine) EnsureChainID

func (e *Engine) EnsureChainID(chainID string, blockInterval uint64, confirmWithClient bool)

EnsureChainID tells the engine which chainID it should be related to, and it confirms this against the its client.

func (*Engine) GetEthTime

func (e *Engine) GetEthTime(ctx context.Context, atBlock uint64) (uint64, error)

func (*Engine) GetInitialTriggerTime

func (e *Engine) GetInitialTriggerTime(id string) (uint64, error)

func (*Engine) GetRequiredConfirmations

func (e *Engine) GetRequiredConfirmations(id string) (uint64, error)

func (*Engine) GetSpec

func (e *Engine) GetSpec(id string) (common.Spec, bool)

func (*Engine) MakeResult

func (e *Engine) MakeResult(specID string, bytes []byte) (Result, error)

func (*Engine) OnSpecActivated

func (e *Engine) OnSpecActivated(ctx context.Context, spec datasource.Spec) error

func (*Engine) OnSpecDeactivated

func (e *Engine) OnSpecDeactivated(ctx context.Context, spec datasource.Spec)

func (*Engine) Poll

func (e *Engine) Poll(ctx context.Context, wallTime time.Time)

Poll is called by the poller in it's own goroutine; it isn't part of the abci code path.

func (*Engine) ReloadConf

func (e *Engine) ReloadConf(cfg Config)

func (*Engine) Start

func (e *Engine) Start()

Start starts the polling of the Ethereum bridges, listens to the events they emit and forward it to the network.

func (*Engine) StartAtHeight

func (e *Engine) StartAtHeight(height uint64, time uint64)

func (*Engine) Stop

func (e *Engine) Stop()

type EthReaderCaller

type EthReaderCaller interface {
	ethereum.ContractCaller
	ethereum.ChainReader
	ChainID(context.Context) (*big.Int, error)
}

type Forwarder

type Forwarder interface {
	ForwardFromSelf(*commandspb.ChainEvent)
}

type Result

type Result struct {
	Bytes         []byte
	Values        []any
	Normalised    map[string]string
	PassesFilters bool
}

func NewResult

func NewResult(spec ethcallcommon.Spec, bytes []byte) (Result, error)