websocket

type Connection interface {
	// URL returns the backend URL we are connected to
	URL() string

	// BlockNumber returns the current block number at head
	BlockNumber(ctx context.Context) (uint64, error)

	// BlockByNumber can be used to get a block by its number
	BlockByNumber(ctx context.Context, number uint64, full bool) (*eth.Block, error)

	// BlockByHash can be used to get a block by its hash
	BlockByHash(ctx context.Context, hash string, full bool) (*eth.Block, error)

	// eth_getTransactionByHash can be used to get transaction by its hash
	TransactionByHash(ctx context.Context, hash string) (*eth.Transaction, error)

	// Request method can be used by downstream consumers of ChangeEvent to make generic JSONRPC requests
	Request(ctx context.Context, r *jsonrpc.Request) (*jsonrpc.RawResponse, error)

	// Subscibe method can be used to make subscription requests
	Subscribe(ctx context.Context, r *jsonrpc.Request) (Subscription, error)

	// NewHeads subscription
	NewHeads(ctx context.Context) (Subscription, error)

	// NewPendingTransactions subscriptions
	NewPendingTransaction(ctx context.Context, full ...bool) (Subscription, error)

	// TransactionReceipt for a particular transaction
	TransactionReceipt(ctx context.Context, hash string) (*eth.TransactionReceipt, error)

	// GetLogs
	GetLogs(ctx context.Context, filter eth.LogFilter) ([]eth.Log, error)
}

type Subscription interface {
	Response() *jsonrpc.RawResponse
	ID() string
	Ch() chan *jsonrpc.Notification
	Unsubscribe(ctx context.Context) error
	Done() <-chan struct{}
	Err() error
}

type SubscriptionParams struct {
	Subscription string          `json:"subscription"`
	Result       json.RawMessage `json:"result"`
}