mirror of
https://github.com/tendermint/tendermint.git
synced 2026-09-26 18:04:22 +00:00
Anton KaliaevandGitHub
fb8b00f1d8
Refs #1771 ADR: https://github.com/tendermint/tendermint/blob/master/docs/architecture/adr-044-lite-client-with-weak-subjectivity.md ## Commits: * add Verifier and VerifyCommitTrusting * add two more checks make trustLevel an option * float32 for trustLevel * check newHeader time * started writing lite Client * unify Verify methods * ensure h2.Header.bfttime < h1.Header.bfttime + tp * move trust checks into Verify function * add more comments * more docs * started writing tests * unbonding period failures * tests are green * export ErrNewHeaderTooFarIntoFuture * make golangci happy * test for non-adjusted headers * more precision * providers and stores * VerifyHeader and VerifyHeaderAtHeight funcs * fix compile errors * remove lastVerifiedHeight, persist new trusted header * sequential verification * remove TrustedStore option * started writing tests for light client * cover basic cases for linear verification * bisection tests PASS * rename BisectingVerification to SkippingVerification * refactor the code * add TrustedHeader method * consolidate sequential verification tests * consolidate skipping verification tests * rename trustedVals to trustedNextVals * start writing docs * ValidateTrustLevel func and ErrOldHeaderExpired error * AutoClient and example tests * fix errors * update doc * remove ErrNewHeaderTooFarIntoFuture This check is unnecessary given existing a) ErrOldHeaderExpired b) h2.Time > now checks. * return an error if we're at more recent height * add comments * add LastSignedHeaderHeight method to Store I think it's fine if Store tracks last height * copy over proxy from old lite package * make TrustedHeader return latest if height=0 * modify LastSignedHeaderHeight to return an error if no headers exist * copy over proxy impl * refactor proxy and start http lite client * Tx and BlockchainInfo methods * Block method * commit method * code compiles again * lite client compiles * extract updateLiteClientIfNeededTo func * move final parts * add placeholder for tests * force usage of lite http client in proxy * comment out query tests for now * explicitly mention tp: trusting period * verify nextVals in VerifyHeader * refactor bisection * move the NextValidatorsHash check into updateTrustedHeaderAndVals + update the comment * add ConsensusParams method to RPC client * add ConsensusParams to rpc/mock/client * change trustLevel type to a new cmn.Fraction type + update SkippingVerification comment * stress out trustLevel is only used for non-adjusted headers * fixes after Fede's review Co-authored-by: Federico Kunze <31522760+fedekunze@users.noreply.github.com> * compare newHeader with a header from an alternative provider * save pivot header Refs https://github.com/tendermint/tendermint/pull/3989#discussion_r349122824 * check header can still be trusted in TrustedHeader Refs https://github.com/tendermint/tendermint/pull/3989#discussion_r349101424 * lite: update Validators and Block endpoints - Block no longer contains BlockMeta - Validators now accept two additional params: page and perPage * make linter happy
104 lines
2.2 KiB
Go
104 lines
2.2 KiB
Go
package http
|
|
|
|
import (
|
|
"fmt"
|
|
|
|
"github.com/tendermint/tendermint/lite2/provider"
|
|
rpcclient "github.com/tendermint/tendermint/rpc/client"
|
|
"github.com/tendermint/tendermint/types"
|
|
)
|
|
|
|
// SignStatusClient combines a SignClient and StatusClient.
|
|
type SignStatusClient interface {
|
|
rpcclient.SignClient
|
|
rpcclient.StatusClient
|
|
}
|
|
|
|
// http provider uses an RPC client (or SignStatusClient more generally) to
|
|
// obtain the necessary information.
|
|
type http struct {
|
|
chainID string
|
|
client SignStatusClient
|
|
}
|
|
|
|
// New creates a HTTP provider, which is using the rpcclient.HTTP
|
|
// client under the hood.
|
|
func New(chainID, remote string) provider.Provider {
|
|
return NewWithClient(chainID, rpcclient.NewHTTP(remote, "/websocket"))
|
|
}
|
|
|
|
// NewWithClient allows you to provide custom SignStatusClient.
|
|
func NewWithClient(chainID string, client SignStatusClient) provider.Provider {
|
|
return &http{
|
|
chainID: chainID,
|
|
client: client,
|
|
}
|
|
}
|
|
|
|
func (p *http) ChainID() string {
|
|
return p.chainID
|
|
}
|
|
|
|
func (p *http) SignedHeader(height int64) (*types.SignedHeader, error) {
|
|
h, err := validateHeight(height)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
commit, err := p.client.Commit(h)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
// Verify we're still on the same chain.
|
|
if p.chainID != commit.Header.ChainID {
|
|
return nil, fmt.Errorf("expected chainID %s, got %s", p.chainID, commit.Header.ChainID)
|
|
}
|
|
|
|
return &commit.SignedHeader, nil
|
|
}
|
|
|
|
func (p *http) ValidatorSet(height int64) (*types.ValidatorSet, error) {
|
|
h, err := validateHeight(height)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
const maxPerPage = 100
|
|
res, err := p.client.Validators(h, 0, maxPerPage)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
|
|
var (
|
|
vals = res.Validators
|
|
page = 1
|
|
)
|
|
|
|
// Check if there are more validators.
|
|
for len(res.Validators) == maxPerPage {
|
|
res, err = p.client.Validators(h, page, maxPerPage)
|
|
if err != nil {
|
|
return nil, err
|
|
}
|
|
if len(res.Validators) > 0 {
|
|
vals = append(vals, res.Validators...)
|
|
}
|
|
page++
|
|
}
|
|
|
|
return types.NewValidatorSet(vals), nil
|
|
}
|
|
|
|
func validateHeight(height int64) (*int64, error) {
|
|
if height < 0 {
|
|
return nil, fmt.Errorf("expected height >= 0, got height %d", height)
|
|
}
|
|
|
|
h := &height
|
|
if height == 0 {
|
|
h = nil
|
|
}
|
|
return h, nil
|
|
}
|