mirror of
				https://github.com/0glabs/0g-chain.git
				synced 2025-11-04 00:27:41 +00:00 
			
		
		
		
	- Upgrade cosmos-sdk to v0.44.5 from v0.39.2 - Add Legacy Tx Endpoint for backwards compatibility - Add IBC v1.2.3 Support Co-authored-by: DracoLi <draco@dracoli.com> Co-authored-by: drklee3 <derrick@dlee.dev> Co-authored-by: denalimarsh <denalimarsh@gmail.com> Co-authored-by: Draco Li <draco@kava.io> Co-authored-by: Nick DeLuca <nickdeluca08@gmail.com> Co-authored-by: Kevin Davis <karzak@users.noreply.github.com> Co-authored-by: Denali Marsh <denali@kava.io>
		
			
				
	
	
		
			161 lines
		
	
	
		
			5.0 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
			
		
		
	
	
			161 lines
		
	
	
		
			5.0 KiB
		
	
	
	
		
			Go
		
	
	
	
	
	
package common
 | 
						|
 | 
						|
import (
 | 
						|
	"context"
 | 
						|
	"fmt"
 | 
						|
	"strings"
 | 
						|
	"time"
 | 
						|
 | 
						|
	"github.com/cosmos/cosmos-sdk/client"
 | 
						|
	"github.com/cosmos/cosmos-sdk/codec"
 | 
						|
	sdk "github.com/cosmos/cosmos-sdk/types"
 | 
						|
	sdkerrors "github.com/cosmos/cosmos-sdk/types/errors"
 | 
						|
	authtx "github.com/cosmos/cosmos-sdk/x/auth/tx"
 | 
						|
 | 
						|
	"github.com/kava-labs/kava/x/committee/types"
 | 
						|
)
 | 
						|
 | 
						|
// Note: QueryProposer is copied in from the gov module
 | 
						|
 | 
						|
const (
 | 
						|
	defaultPage  = 1
 | 
						|
	defaultLimit = 30 // should be consistent with tendermint/tendermint/rpc/core/pipe.go:19
 | 
						|
)
 | 
						|
 | 
						|
// Proposer contains metadata of a governance proposal used for querying a proposer.
 | 
						|
type Proposer struct {
 | 
						|
	ProposalID uint64 `json:"proposal_id" yaml:"proposal_id"`
 | 
						|
	Proposer   string `json:"proposer" yaml:"proposer"`
 | 
						|
}
 | 
						|
 | 
						|
// NewProposer returns a new Proposer given id and proposer
 | 
						|
func NewProposer(proposalID uint64, proposer string) Proposer {
 | 
						|
	return Proposer{proposalID, proposer}
 | 
						|
}
 | 
						|
 | 
						|
func (p Proposer) String() string {
 | 
						|
	return fmt.Sprintf("Proposal with ID %d was proposed by %s", p.ProposalID, p.Proposer)
 | 
						|
}
 | 
						|
 | 
						|
// QueryProposer will query for a proposer of a governance proposal by ID.
 | 
						|
func QueryProposer(cliCtx client.Context, proposalID uint64) (Proposer, error) {
 | 
						|
	events := []string{
 | 
						|
		fmt.Sprintf("%s.%s='%s'", sdk.EventTypeMessage, sdk.AttributeKeyAction, types.TypeMsgSubmitProposal),
 | 
						|
		fmt.Sprintf("%s.%s='%s'", types.EventTypeProposalSubmit, types.AttributeKeyProposalID, []byte(fmt.Sprintf("%d", proposalID))),
 | 
						|
	}
 | 
						|
 | 
						|
	// NOTE: SearchTxs is used to facilitate the txs query which does not currently
 | 
						|
	// support configurable pagination.
 | 
						|
	searchResult, err := authtx.QueryTxsByEvents(cliCtx, events, defaultPage, defaultLimit, "")
 | 
						|
	if err != nil {
 | 
						|
		return Proposer{}, err
 | 
						|
	}
 | 
						|
 | 
						|
	for _, info := range searchResult.Txs {
 | 
						|
		for _, msg := range info.GetTx().GetMsgs() {
 | 
						|
			// there should only be a single proposal under the given conditions
 | 
						|
			if subMsg, ok := msg.(*types.MsgSubmitProposal); ok {
 | 
						|
				return NewProposer(proposalID, subMsg.Proposer), nil
 | 
						|
			}
 | 
						|
		}
 | 
						|
	}
 | 
						|
 | 
						|
	return Proposer{}, fmt.Errorf("failed to find the proposer for proposalID %d", proposalID)
 | 
						|
}
 | 
						|
 | 
						|
// QueryProposalByID returns a proposal from state if present or fallbacks to searching old blocks
 | 
						|
func QueryProposalByID(cliCtx client.Context, cdc *codec.LegacyAmino, queryRoute string, proposalID uint64) (*types.Proposal, int64, error) {
 | 
						|
	bz, err := cdc.MarshalJSON(types.NewQueryProposalParams(proposalID))
 | 
						|
	if err != nil {
 | 
						|
		return nil, 0, err
 | 
						|
	}
 | 
						|
 | 
						|
	res, height, err := cliCtx.QueryWithData(fmt.Sprintf("custom/%s/%s", queryRoute, types.QueryProposal), bz)
 | 
						|
 | 
						|
	if err == nil {
 | 
						|
		var proposal types.Proposal
 | 
						|
		cdc.MustUnmarshalJSON(res, &proposal)
 | 
						|
 | 
						|
		return &proposal, height, nil
 | 
						|
	}
 | 
						|
 | 
						|
	// NOTE: !errors.Is(err, types.ErrUnknownProposal) does not work here
 | 
						|
	if err != nil && !strings.Contains(err.Error(), "proposal not found") {
 | 
						|
		return nil, 0, err
 | 
						|
	}
 | 
						|
 | 
						|
	res, height, err = cliCtx.QueryWithData(fmt.Sprintf("custom/%s/%s", queryRoute, types.QueryNextProposalID), nil)
 | 
						|
	if err != nil {
 | 
						|
		return nil, 0, err
 | 
						|
	}
 | 
						|
 | 
						|
	var nextProposalID uint64
 | 
						|
	cdc.MustUnmarshalJSON(res, &nextProposalID)
 | 
						|
 | 
						|
	if proposalID >= nextProposalID {
 | 
						|
		return nil, 0, sdkerrors.Wrapf(types.ErrUnknownProposal, "%d", proposalID)
 | 
						|
	}
 | 
						|
 | 
						|
	events := []string{
 | 
						|
		fmt.Sprintf("%s.%s='%s'", sdk.EventTypeMessage, sdk.AttributeKeyAction, types.TypeMsgSubmitProposal),
 | 
						|
		fmt.Sprintf("%s.%s='%s'", types.EventTypeProposalSubmit, types.AttributeKeyProposalID, []byte(fmt.Sprintf("%d", proposalID))),
 | 
						|
	}
 | 
						|
 | 
						|
	searchResult, err := authtx.QueryTxsByEvents(cliCtx, events, defaultPage, defaultLimit, "")
 | 
						|
	if err != nil {
 | 
						|
		return nil, 0, err
 | 
						|
	}
 | 
						|
 | 
						|
	for _, info := range searchResult.Txs {
 | 
						|
		for _, msg := range info.GetTx().GetMsgs() {
 | 
						|
			if subMsg, ok := msg.(*types.MsgSubmitProposal); ok {
 | 
						|
				deadline, err := calculateDeadline(cliCtx, cdc, queryRoute, subMsg.CommitteeID, info.Height)
 | 
						|
				if err != nil {
 | 
						|
					return nil, 0, err
 | 
						|
				}
 | 
						|
				proposal, err := types.NewProposal(subMsg.GetPubProposal(), proposalID, subMsg.CommitteeID, deadline)
 | 
						|
				if err != nil {
 | 
						|
					return nil, 0, err
 | 
						|
				}
 | 
						|
				return &proposal, height, nil
 | 
						|
			}
 | 
						|
		}
 | 
						|
	}
 | 
						|
 | 
						|
	return nil, 0, sdkerrors.Wrapf(types.ErrUnknownProposal, "%d", proposalID)
 | 
						|
}
 | 
						|
 | 
						|
// calculateDeadline returns the proposal deadline for a committee and block height
 | 
						|
func calculateDeadline(cliCtx client.Context, cdc *codec.LegacyAmino, queryRoute string, committeeID uint64, blockHeight int64) (time.Time, error) {
 | 
						|
	var deadline time.Time
 | 
						|
 | 
						|
	bz, err := cdc.MarshalJSON(types.NewQueryCommitteeParams(committeeID))
 | 
						|
	if err != nil {
 | 
						|
		return deadline, err
 | 
						|
	}
 | 
						|
 | 
						|
	res, _, err := cliCtx.QueryWithData(fmt.Sprintf("custom/%s/%s", queryRoute, types.QueryCommittee), bz)
 | 
						|
	if err != nil {
 | 
						|
		return deadline, err
 | 
						|
	}
 | 
						|
 | 
						|
	var committee types.Committee
 | 
						|
	err = cdc.UnmarshalJSON(res, &committee)
 | 
						|
	if err != nil {
 | 
						|
		return deadline, err
 | 
						|
	}
 | 
						|
 | 
						|
	node, err := cliCtx.GetNode()
 | 
						|
	if err != nil {
 | 
						|
		return deadline, err
 | 
						|
	}
 | 
						|
 | 
						|
	resultBlock, err := node.Block(context.Background(), &blockHeight)
 | 
						|
	if err != nil {
 | 
						|
		return deadline, err
 | 
						|
	}
 | 
						|
 | 
						|
	deadline = resultBlock.Block.Header.Time.Add(committee.GetProposalDuration())
 | 
						|
	return deadline, nil
 | 
						|
}
 |