subscriber

type BlockByHashOutput struct {
	Jsonrpc string          `json:"jsonrpc"`
	Id      int             `json:"id"`
	Result  *ethtypes.Block `json:"result"`
}

type BlockByNumberOutput struct {
	Jsonrpc string           `json:"jsonrpc"`
	Id      string           `json:"id"`
	Result  *ethtypes.Header `json:"result"`
	Error   *struct {
		Code    int    `json:"code"`
		Message string `json:"message"`
	} `json:"error"`
}

type BlockNumberOutput struct {
	Jsonrpc string `json:"jsonrpc"`
	Id      int    `json:"id"`
	Result  string `json:"result"`
}

type EthRpcInput struct {
	JsonRpc string        `json:"jsonrpc"`
	Method  string        `json:"method"`
	Params  []interface{} `json:"params"`
	Id      string        `json:"id"`
}

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

type FilterLogOutput struct {
	Jsonrpc string         `json:"jsonrpc"`
	Id      string         `json:"id"`
	Result  []ethtypes.Log `json:"result"`
}

type OwnerOfOutput struct {
	JsonRpc string `json:"jsonrpc"`
	Id      int    `json:"id"`
	Result  string `json:"result"`
}

type Subscriber interface {
	Id() string
	Start(ctx context.Context)
	Stop()
	GetOldestBlock(timestamp uint64) (oracletypes.BlockData, error)
	OwnerOf(ctx context.Context, nftAddressHex string, tokenIdHex string, blockHash string) (string, error)
}