You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
42 lines
1.3 KiB
42 lines
1.3 KiB
package proxy
|
|
|
|
import (
|
|
"context"
|
|
|
|
tmbytes "github.com/tendermint/tendermint/libs/bytes"
|
|
lrpc "github.com/tendermint/tendermint/light/rpc"
|
|
rpcclient "github.com/tendermint/tendermint/rpc/client"
|
|
"github.com/tendermint/tendermint/rpc/coretypes"
|
|
)
|
|
|
|
// proxyService wraps a light RPC client to export the RPC service interfaces.
|
|
// This is needed because the service and the client use different signatures
|
|
// for some of the methods.
|
|
type proxyService struct {
|
|
*lrpc.Client
|
|
}
|
|
|
|
func (p proxyService) ABCIQuery(ctx context.Context, path string, data tmbytes.HexBytes,
|
|
height int64, prove bool) (*coretypes.ResultABCIQuery, error) {
|
|
|
|
return p.ABCIQueryWithOptions(ctx, path, data, rpcclient.ABCIQueryOptions{
|
|
Height: height,
|
|
Prove: prove,
|
|
})
|
|
}
|
|
|
|
func (p proxyService) GetConsensusState(ctx context.Context) (*coretypes.ResultConsensusState, error) {
|
|
return p.ConsensusState(ctx)
|
|
}
|
|
|
|
func (p proxyService) Subscribe(ctx context.Context, query string) (*coretypes.ResultSubscribe, error) {
|
|
return p.SubscribeWS(ctx, query)
|
|
}
|
|
|
|
func (p proxyService) Unsubscribe(ctx context.Context, query string) (*coretypes.ResultUnsubscribe, error) {
|
|
return p.UnsubscribeWS(ctx, query)
|
|
}
|
|
|
|
func (p proxyService) UnsubscribeAll(ctx context.Context) (*coretypes.ResultUnsubscribe, error) {
|
|
return p.UnsubscribeAllWS(ctx)
|
|
}
|