ethcall

Jul 6, 2023

Changes in this version

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

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

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

+ type Call struct

+ func NewCall(method string, args []any, address string, abiJSON []byte) (Call, error)

+ func (c Call) Args() ([]any, error)

+ func (c Call) Call(ctx context.Context, caller ethereum.ContractCaller, blockNumber *big.Int) (Result, error)

+ func (c Call) Hash() []byte

+ func (c Call) UnpackResult(bytes []byte) ([]any, error)

+ type Config struct

+ Level encoding.LogLevel

+ type Engine struct

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

+ func (e *Engine) AddSpec(s Spec) (string, error)

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

+ func (e *Engine) OnTick(ctx context.Context, vegaTime time.Time)

+ type EthReaderCaller interface

+ type Forwarder interface

+ ForwardFromSelf func(*commandspb.ChainEvent)

+ type Result struct

+ Bytes []byte

+ func (r Result) Values() ([]any, error)

+ type Spec struct

+ func NewSpec(call Call, trigger Trigger) Spec

+ func NewSpecFromProto(proto *vega.DataSourceDefinition) (Spec, error)

+ func (s Spec) Hash() []byte

+ func (s Spec) HashHex() string

+ func (s Spec) ToProto() (*vega.DataSourceDefinition, error)

+ type TimeTrigger struct

+ Every uint64

+ Initial uint64

+ Until uint64

+ func TimeTriggerFromProto(proto *vega.EthTimeTrigger) TimeTrigger

+ func (t TimeTrigger) Hash() []byte

+ func (t TimeTrigger) ToProto() *vega.EthCallTrigger

+ func (t TimeTrigger) Trigger(prev blockish, current blockish) bool

+ type Trigger interface

+ Hash func() []byte

+ ToProto func() *vega.EthCallTrigger

+ Trigger func(prev blockish, current blockish) bool

+ func TriggerFromProto(proto *vega.EthCallTrigger) (Trigger, error)