mirror of
https://github.com/tendermint/tendermint.git
synced 2026-02-03 02:22:04 +00:00
f9c6cc9306
The main change here is to use encoding/json to encode and decode RPC parameters, rather than the custom tmjson package. This includes: - Update the HTTP POST handler parameter handling. - Add field tags to 64-bit integer types to get string encoding (to match amino/tmjson). - Add marshalers to struct types that mention interfaces. - Inject wrappers to decode interface arguments in RPC handlers.
45 lines
1.5 KiB
Go
45 lines
1.5 KiB
Go
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)
|
|
}
|
|
|
|
func (p proxyService) BroadcastEvidence(ctx context.Context, ev coretypes.Evidence) (*coretypes.ResultBroadcastEvidence, error) {
|
|
return p.Client.BroadcastEvidence(ctx, ev.Value)
|
|
}
|