34c2593e43
* Restructure ethermint/rpc repo structure and change import statements * Add #400 to changelog * fix filepath in util and json_rpc * Move #400 to unreleased section
63 lines
1.7 KiB
Go
63 lines
1.7 KiB
Go
package filters
|
|
|
|
import (
|
|
"time"
|
|
|
|
"github.com/ethereum/go-ethereum/common"
|
|
ethtypes "github.com/ethereum/go-ethereum/core/types"
|
|
"github.com/ethereum/go-ethereum/eth/filters"
|
|
"github.com/ethereum/go-ethereum/rpc"
|
|
coretypes "github.com/tendermint/tendermint/rpc/core/types"
|
|
)
|
|
|
|
// Subscription defines a wrapper for the private subscription
|
|
type Subscription struct {
|
|
id rpc.ID
|
|
typ filters.Type
|
|
event string
|
|
created time.Time
|
|
logsCrit filters.FilterCriteria
|
|
logs chan []*ethtypes.Log
|
|
hashes chan []common.Hash
|
|
headers chan *ethtypes.Header
|
|
installed chan struct{} // closed when the filter is installed
|
|
eventCh <-chan coretypes.ResultEvent
|
|
err chan error
|
|
}
|
|
|
|
// ID returns the underlying subscription RPC identifier.
|
|
func (s Subscription) ID() rpc.ID {
|
|
return s.id
|
|
}
|
|
|
|
// Unsubscribe from the current subscription to Tendermint Websocket. It sends an error to the
|
|
// subscription error channel if unsubscription fails.
|
|
func (s *Subscription) Unsubscribe(es *EventSystem) {
|
|
go func() {
|
|
uninstallLoop:
|
|
for {
|
|
// write uninstall request and consume logs/hashes. This prevents
|
|
// the eventLoop broadcast method to deadlock when writing to the
|
|
// filter event channel while the subscription loop is waiting for
|
|
// this method to return (and thus not reading these events).
|
|
select {
|
|
case es.uninstall <- s:
|
|
break uninstallLoop
|
|
case <-s.logs:
|
|
case <-s.hashes:
|
|
case <-s.headers:
|
|
}
|
|
}
|
|
}()
|
|
}
|
|
|
|
// Err returns the error channel
|
|
func (s *Subscription) Err() <-chan error {
|
|
return s.err
|
|
}
|
|
|
|
// Event returns the tendermint result event channel
|
|
func (s *Subscription) Event() <-chan coretypes.ResultEvent {
|
|
return s.eventCh
|
|
}
|