oracle

Documentation

Index

• Variables
• type Broadcaster
• type Config
• type HTTPClient
• type Oracle
  • func NewOracle(cfg Config) (*Oracle, error)
  • func (o *Oracle) AddRequests(reqs map[uint64]*state.OracleRequest)
  • func (o *Oracle) AddResponse(pub *keys.PublicKey, reqID uint64, txSig []byte)
  • func (o *Oracle) CreateResponseTx(gasForResponse int64, height uint32, resp *transaction.OracleResponse) (*transaction.Transaction, error)
  • func (o *Oracle) ProcessRequestsInternal(reqs map[uint64]*state.OracleRequest)
  • func (o *Oracle) RemoveRequests(ids []uint64)
  • func (o *Oracle) Run()
  • func (o *Oracle) SetBroadcaster(b Broadcaster)
  • func (o *Oracle) SetOnTransaction(cb TxCallback)
  • func (o *Oracle) Shutdown()
  • func (o *Oracle) UpdateNativeContract(script, resp []byte, h util.Uint160, verifyOffset int)
  • func (o *Oracle) UpdateOracleNodes(oracleNodes keys.PublicKeys)
• type TxCallback
• type URIValidator

Variables

var ErrResponseTooLarge = errors.New("too big response")

ErrResponseTooLarge is returned when response exceeds max allowed size.

Types

type Broadcaster

type Broadcaster interface {
	SendResponse(priv *keys.PrivateKey, resp *transaction.OracleResponse, txSig []byte)
	Run()
	Shutdown()
}

Broadcaster broadcasts oracle responses.

type Config

type Config struct {
	Log             *zap.Logger
	Network         netmode.Magic
	MainCfg         config.OracleConfiguration
	Client          HTTPClient
	Chain           blockchainer.Blockchainer
	ResponseHandler Broadcaster
	OnTransaction   TxCallback
	URIValidator    URIValidator
}

Config contains oracle module parameters.

type HTTPClient

type HTTPClient interface {
	Do(*http.Request) (*http.Response, error)
}

HTTPClient is an interface capable of doing oracle requests.

type Oracle

type Oracle struct {
	Config
	// contains filtered or unexported fields
}

Oracle represents oracle module capable of talking with the external world.

func NewOracle

func NewOracle(cfg Config) (*Oracle, error)

NewOracle returns new oracle instance.

func (*Oracle) AddRequests

func (o *Oracle) AddRequests(reqs map[uint64]*state.OracleRequest)

AddRequests saves all requests in-fly for further processing.

func (*Oracle) AddResponse

func (o *Oracle) AddResponse(pub *keys.PublicKey, reqID uint64, txSig []byte)

AddResponse processes oracle response from node pub. sig is response transaction signature.

func (*Oracle) CreateResponseTx

func (o *Oracle) CreateResponseTx(gasForResponse int64, height uint32, resp *transaction.OracleResponse) (*transaction.Transaction, error)

CreateResponseTx creates unsigned oracle response transaction.

func (*Oracle) ProcessRequestsInternal

func (o *Oracle) ProcessRequestsInternal(reqs map[uint64]*state.OracleRequest)

ProcessRequestsInternal processes provided requests synchronously.

func (*Oracle) RemoveRequests

func (o *Oracle) RemoveRequests(ids []uint64)

RemoveRequests removes all data associated with requests which have been processed by oracle contract.

func (*Oracle) Run

func (o *Oracle) Run()

Run runs must be executed in a separate goroutine.

func (*Oracle) SetBroadcaster

func (o *Oracle) SetBroadcaster(b Broadcaster)

SetBroadcaster sets callback to broadcast response.

func (*Oracle) SetOnTransaction

func (o *Oracle) SetOnTransaction(cb TxCallback)

SetOnTransaction sets callback to pool and broadcast tx.

func (*Oracle) Shutdown

func (o *Oracle) Shutdown()

Shutdown shutdowns Oracle.

func (*Oracle) UpdateNativeContract

func (o *Oracle) UpdateNativeContract(script, resp []byte, h util.Uint160, verifyOffset int)

UpdateNativeContract updates native oracle contract info for tx verification.

func (*Oracle) UpdateOracleNodes

func (o *Oracle) UpdateOracleNodes(oracleNodes keys.PublicKeys)

UpdateOracleNodes updates oracle nodes list.

type TxCallback

type TxCallback = func(tx *transaction.Transaction)

TxCallback executes on new transactions when they are ready to be pooled.

type URIValidator

type URIValidator = func(*url.URL) error

URIValidator is used to check if provided URL is valid.