Release/release distribution exchange examples

.coderabbit.yaml

@@ -0,0 +1,8 @@
+reviews:
+    auto_review:
+        base_branches:
+            - "master"
+            - "dev"
+            - "feat/.*"
+chat:
+    auto_reply: true

auth_vote/authz_vote.go

@@ -0,0 +1,104 @@
+package main
+
+import (
+	"encoding/json"
+	"fmt"
+	"os"
+
+	"github.com/InjectiveLabs/sdk-go/client"
+	chainclient "github.com/InjectiveLabs/sdk-go/client/chain"
+	"github.com/InjectiveLabs/sdk-go/client/common"
+	rpchttp "github.com/cometbft/cometbft/rpc/client/http"
+	codectypes "github.com/cosmos/cosmos-sdk/codec/types"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	authztypes "github.com/cosmos/cosmos-sdk/x/authz"
+	"github.com/cosmos/cosmos-sdk/x/gov/types/v1beta1"
+)
+
+func main() {
+	network := common.LoadNetwork("testnet", "lb")
+	tmClient, err := rpchttp.New(network.TmEndpoint, "/websocket")
+	if err != nil {
+		panic(err)
+	}
+
+	if err != nil {
+		panic(err)
+	}
+
+	senderAddress, cosmosKeyring, err := chainclient.InitCosmosKeyring(
+		os.Getenv("HOME")+"/.injectived",
+		"injectived",
+		"file",
+		"gov_account",
+		"",
+		"", // keyring will be used if pk not provided
+		false,
+	)
+
+	if err != nil {
+		panic(err)
+	}
+
+	clientCtx, err := chainclient.NewClientContext(
+		network.ChainId,
+		senderAddress.String(),
+		cosmosKeyring,
+	)
+
+	if err != nil {
+		panic(err)
+	}
+
+	clientCtx = clientCtx.WithNodeURI(network.TmEndpoint).WithClient(tmClient)
+
+	txFactory := chainclient.NewTxFactory(clientCtx)
+	txFactory = txFactory.WithGasPrices(client.DefaultGasPriceWithDenom)
+	chainClient, err := chainclient.NewChainClient(
+		clientCtx,
+		network,
+		common.OptionTxFactory(&txFactory),
+	)
+
+	if err != nil {
+		panic(err)
+	}
+
+	// note that we use grantee keyring to send the msg on behalf of granter here
+	// sender, subaccount are from granter
+	validators := []string{"inj156t3yxd4udv0h9gwagfcmwnmm3quy0npqc7pks", "inj16nd8yqxe9p6ggnrz58qr7dxn5y2834yendward"}
+	grantee := senderAddress.String()
+	proposalId := uint64(375)
+	var msgs []sdk.Msg
+
+	for _, validator := range validators {
+		msgVote := v1beta1.MsgVote{
+			ProposalId: proposalId,
+			Voter:      validator,
+			Option:     v1beta1.OptionYes,
+		}
+
+		msg0Bytes, _ := msgVote.Marshal()
+		msg0Any := &codectypes.Any{}
+		msg0Any.TypeUrl = sdk.MsgTypeURL(&msgVote)
+		msg0Any.Value = msg0Bytes
+
+		msg := &authztypes.MsgExec{
+			Grantee: grantee,
+			Msgs:    []*codectypes.Any{msg0Any},
+		}
+
+		sdkMsg := sdk.Msg(msg)
+		msgs = append(msgs, sdkMsg)
+	}
+
+	//AsyncBroadcastMsg, SyncBroadcastMsg, QueueBroadcastMsg
+	response, err := chainClient.AsyncBroadcastMsg(msgs...)
+
+	if err != nil {
+		panic(err)
+	}
+
+	str, _ := json.MarshalIndent(response, "", " ")
+	fmt.Print(string(str))
+}

client/chain/chain_test_support.go

@@ -5,6 +5,8 @@
 	"errors"
 	"time"
 
+	distributiontypes "github.com/cosmos/cosmos-sdk/x/distribution/types"
+
 	tokenfactorytypes "github.com/InjectiveLabs/sdk-go/chain/tokenfactory/types"
 
 	wasmtypes "github.com/CosmWasm/wasmd/x/wasm/types"
@@ -286,3 +288,261 @@
 func (c *MockChainClient) FetchTokenfactoryModuleState(ctx context.Context) (*tokenfactorytypes.QueryModuleStateResponse, error) {
 	return &tokenfactorytypes.QueryModuleStateResponse{}, nil
 }
+
+// Distribution module
+func (c *MockChainClient) FetchValidatorDistributionInfo(ctx context.Context, validatorAddress string) (*distributiontypes.QueryValidatorDistributionInfoResponse, error) {
+	return &distributiontypes.QueryValidatorDistributionInfoResponse{}, nil
+}
+
+func (c *MockChainClient) FetchValidatorOutstandingRewards(ctx context.Context, validatorAddress string) (*distributiontypes.QueryValidatorOutstandingRewardsResponse, error) {
+	return &distributiontypes.QueryValidatorOutstandingRewardsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchValidatorCommission(ctx context.Context, validatorAddress string) (*distributiontypes.QueryValidatorCommissionResponse, error) {
+	return &distributiontypes.QueryValidatorCommissionResponse{}, nil
+}
+
+func (c *MockChainClient) FetchValidatorSlashes(ctx context.Context, validatorAddress string, startingHeight uint64, endingHeight uint64, pagination *query.PageRequest) (*distributiontypes.QueryValidatorSlashesResponse, error) {
+	return &distributiontypes.QueryValidatorSlashesResponse{}, nil
+}
+
+func (c *MockChainClient) FetchDelegationRewards(ctx context.Context, delegatorAddress string, validatorAddress string) (*distributiontypes.QueryDelegationRewardsResponse, error) {
+	return &distributiontypes.QueryDelegationRewardsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchDelegationTotalRewards(ctx context.Context, delegatorAddress string) (*distributiontypes.QueryDelegationTotalRewardsResponse, error) {
+	return &distributiontypes.QueryDelegationTotalRewardsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchDelegatorValidators(ctx context.Context, delegatorAddress string) (*distributiontypes.QueryDelegatorValidatorsResponse, error) {
+	return &distributiontypes.QueryDelegatorValidatorsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchDelegatorWithdrawAddress(ctx context.Context, delegatorAddress string) (*distributiontypes.QueryDelegatorWithdrawAddressResponse, error) {
+	return &distributiontypes.QueryDelegatorWithdrawAddressResponse{}, nil
+}
+
+func (c *MockChainClient) FetchCommunityPool(ctx context.Context) (*distributiontypes.QueryCommunityPoolResponse, error) {
+	return &distributiontypes.QueryCommunityPoolResponse{}, nil
+}
+
+// Chain exchange module
+func (c *MockChainClient) FetchSubaccountDeposits(ctx context.Context, subaccountId string) (*exchangetypes.QuerySubaccountDepositsResponse, error) {
+	return &exchangetypes.QuerySubaccountDepositsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchSubaccountDeposit(ctx context.Context, subaccountId string, denom string) (*exchangetypes.QuerySubaccountDepositResponse, error) {
+	return &exchangetypes.QuerySubaccountDepositResponse{}, nil
+}
+
+func (c *MockChainClient) FetchExchangeBalances(ctx context.Context) (*exchangetypes.QueryExchangeBalancesResponse, error) {
+	return &exchangetypes.QueryExchangeBalancesResponse{}, nil
+}
+
+func (c *MockChainClient) FetchAggregateVolume(ctx context.Context, account string) (*exchangetypes.QueryAggregateVolumeResponse, error) {
+	return &exchangetypes.QueryAggregateVolumeResponse{}, nil
+}
+
+func (c *MockChainClient) FetchAggregateVolumes(ctx context.Context, accounts []string, marketIds []string) (*exchangetypes.QueryAggregateVolumesResponse, error) {
+	return &exchangetypes.QueryAggregateVolumesResponse{}, nil
+}
+
+func (c *MockChainClient) FetchAggregateMarketVolume(ctx context.Context, marketId string) (*exchangetypes.QueryAggregateMarketVolumeResponse, error) {
+	return &exchangetypes.QueryAggregateMarketVolumeResponse{}, nil
+}
+
+func (c *MockChainClient) FetchAggregateMarketVolumes(ctx context.Context, marketIds []string) (*exchangetypes.QueryAggregateMarketVolumesResponse, error) {
+	return &exchangetypes.QueryAggregateMarketVolumesResponse{}, nil
+}
+
+func (c *MockChainClient) FetchDenomDecimal(ctx context.Context, denom string) (*exchangetypes.QueryDenomDecimalResponse, error) {
+	return &exchangetypes.QueryDenomDecimalResponse{}, nil
+}
+
+func (c *MockChainClient) FetchDenomDecimals(ctx context.Context, denoms []string) (*exchangetypes.QueryDenomDecimalsResponse, error) {
+	return &exchangetypes.QueryDenomDecimalsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainSpotMarkets(ctx context.Context, status string, marketIds []string) (*exchangetypes.QuerySpotMarketsResponse, error) {
+	return &exchangetypes.QuerySpotMarketsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainSpotMarket(ctx context.Context, marketId string) (*exchangetypes.QuerySpotMarketResponse, error) {
+	return &exchangetypes.QuerySpotMarketResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainFullSpotMarkets(ctx context.Context, status string, marketIds []string, withMidPriceAndTob bool) (*exchangetypes.QueryFullSpotMarketsResponse, error) {
+	return &exchangetypes.QueryFullSpotMarketsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainFullSpotMarket(ctx context.Context, marketId string, withMidPriceAndTob bool) (*exchangetypes.QueryFullSpotMarketResponse, error) {
+	return &exchangetypes.QueryFullSpotMarketResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainSpotOrderbook(ctx context.Context, marketId string, limit uint64, orderSide exchangetypes.OrderSide, limitCumulativeNotional sdk.Dec, limitCumulativeQuantity sdk.Dec) (*exchangetypes.QuerySpotOrderbookResponse, error) {
+	return &exchangetypes.QuerySpotOrderbookResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainTraderSpotOrders(ctx context.Context, marketId string, subaccountId string) (*exchangetypes.QueryTraderSpotOrdersResponse, error) {
+	return &exchangetypes.QueryTraderSpotOrdersResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainAccountAddressSpotOrders(ctx context.Context, marketId string, address string) (*exchangetypes.QueryAccountAddressSpotOrdersResponse, error) {
+	return &exchangetypes.QueryAccountAddressSpotOrdersResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainSpotOrdersByHashes(ctx context.Context, marketId string, subaccountId string, orderHashes []string) (*exchangetypes.QuerySpotOrdersByHashesResponse, error) {
+	return &exchangetypes.QuerySpotOrdersByHashesResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainSubaccountOrders(ctx context.Context, subaccountId string, marketId string) (*exchangetypes.QuerySubaccountOrdersResponse, error) {
+	return &exchangetypes.QuerySubaccountOrdersResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainTraderSpotTransientOrders(ctx context.Context, marketId string, subaccountId string) (*exchangetypes.QueryTraderSpotOrdersResponse, error) {
+	return &exchangetypes.QueryTraderSpotOrdersResponse{}, nil
+}
+
+func (c *MockChainClient) FetchSpotMidPriceAndTOB(ctx context.Context, marketId string) (*exchangetypes.QuerySpotMidPriceAndTOBResponse, error) {
+	return &exchangetypes.QuerySpotMidPriceAndTOBResponse{}, nil
+}
+
+func (c *MockChainClient) FetchDerivativeMidPriceAndTOB(ctx context.Context, marketId string) (*exchangetypes.QueryDerivativeMidPriceAndTOBResponse, error) {
+	return &exchangetypes.QueryDerivativeMidPriceAndTOBResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainDerivativeOrderbook(ctx context.Context, marketId string, limit uint64, limitCumulativeNotional sdk.Dec) (*exchangetypes.QueryDerivativeOrderbookResponse, error) {
+	return &exchangetypes.QueryDerivativeOrderbookResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainTraderDerivativeOrders(ctx context.Context, marketId string, subaccountId string) (*exchangetypes.QueryTraderDerivativeOrdersResponse, error) {
+	return &exchangetypes.QueryTraderDerivativeOrdersResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainAccountAddressDerivativeOrders(ctx context.Context, marketId string, address string) (*exchangetypes.QueryAccountAddressDerivativeOrdersResponse, error) {
+	return &exchangetypes.QueryAccountAddressDerivativeOrdersResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainDerivativeOrdersByHashes(ctx context.Context, marketId string, subaccountId string, orderHashes []string) (*exchangetypes.QueryDerivativeOrdersByHashesResponse, error) {
+	return &exchangetypes.QueryDerivativeOrdersByHashesResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainTraderDerivativeTransientOrders(ctx context.Context, marketId string, subaccountId string) (*exchangetypes.QueryTraderDerivativeOrdersResponse, error) {
+	return &exchangetypes.QueryTraderDerivativeOrdersResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainDerivativeMarkets(ctx context.Context, status string, marketIds []string, withMidPriceAndTob bool) (*exchangetypes.QueryDerivativeMarketsResponse, error) {
+	return &exchangetypes.QueryDerivativeMarketsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainDerivativeMarket(ctx context.Context, marketId string) (*exchangetypes.QueryDerivativeMarketResponse, error) {
+	return &exchangetypes.QueryDerivativeMarketResponse{}, nil
+}
+
+func (c *MockChainClient) FetchDerivativeMarketAddress(ctx context.Context, marketId string) (*exchangetypes.QueryDerivativeMarketAddressResponse, error) {
+	return &exchangetypes.QueryDerivativeMarketAddressResponse{}, nil
+}
+
+func (c *MockChainClient) FetchSubaccountTradeNonce(ctx context.Context, subaccountId string) (*exchangetypes.QuerySubaccountTradeNonceResponse, error) {
+	return &exchangetypes.QuerySubaccountTradeNonceResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainPositions(ctx context.Context) (*exchangetypes.QueryPositionsResponse, error) {
+	return &exchangetypes.QueryPositionsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainSubaccountPositions(ctx context.Context, subaccountId string) (*exchangetypes.QuerySubaccountPositionsResponse, error) {
+	return &exchangetypes.QuerySubaccountPositionsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainSubaccountPositionInMarket(ctx context.Context, subaccountId string, marketId string) (*exchangetypes.QuerySubaccountPositionInMarketResponse, error) {
+	return &exchangetypes.QuerySubaccountPositionInMarketResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainSubaccountEffectivePositionInMarket(ctx context.Context, subaccountId string, marketId string) (*exchangetypes.QuerySubaccountEffectivePositionInMarketResponse, error) {
+	return &exchangetypes.QuerySubaccountEffectivePositionInMarketResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainPerpetualMarketInfo(ctx context.Context, marketId string) (*exchangetypes.QueryPerpetualMarketInfoResponse, error) {
+	return &exchangetypes.QueryPerpetualMarketInfoResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainExpiryFuturesMarketInfo(ctx context.Context, marketId string) (*exchangetypes.QueryExpiryFuturesMarketInfoResponse, error) {
+	return &exchangetypes.QueryExpiryFuturesMarketInfoResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainPerpetualMarketFunding(ctx context.Context, marketId string) (*exchangetypes.QueryPerpetualMarketFundingResponse, error) {
+	return &exchangetypes.QueryPerpetualMarketFundingResponse{}, nil
+}
+
+func (c *MockChainClient) FetchSubaccountOrderMetadata(ctx context.Context, subaccountId string) (*exchangetypes.QuerySubaccountOrderMetadataResponse, error) {
+	return &exchangetypes.QuerySubaccountOrderMetadataResponse{}, nil
+}
+
+func (c *MockChainClient) FetchTradeRewardPoints(ctx context.Context, accounts []string) (*exchangetypes.QueryTradeRewardPointsResponse, error) {
+	return &exchangetypes.QueryTradeRewardPointsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchPendingTradeRewardPoints(ctx context.Context, accounts []string) (*exchangetypes.QueryTradeRewardPointsResponse, error) {
+	return &exchangetypes.QueryTradeRewardPointsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchTradeRewardCampaign(ctx context.Context) (*exchangetypes.QueryTradeRewardCampaignResponse, error) {
+	return &exchangetypes.QueryTradeRewardCampaignResponse{}, nil
+}
+
+func (c *MockChainClient) FetchFeeDiscountAccountInfo(ctx context.Context, account string) (*exchangetypes.QueryFeeDiscountAccountInfoResponse, error) {
+	return &exchangetypes.QueryFeeDiscountAccountInfoResponse{}, nil
+}
+
+func (c *MockChainClient) FetchFeeDiscountSchedule(ctx context.Context) (*exchangetypes.QueryFeeDiscountScheduleResponse, error) {
+	return &exchangetypes.QueryFeeDiscountScheduleResponse{}, nil
+}
+
+func (c *MockChainClient) FetchBalanceMismatches(ctx context.Context, dustFactor int64) (*exchangetypes.QueryBalanceMismatchesResponse, error) {
+	return &exchangetypes.QueryBalanceMismatchesResponse{}, nil
+}
+
+func (c *MockChainClient) FetchBalanceWithBalanceHolds(ctx context.Context) (*exchangetypes.QueryBalanceWithBalanceHoldsResponse, error) {
+	return &exchangetypes.QueryBalanceWithBalanceHoldsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchFeeDiscountTierStatistics(ctx context.Context) (*exchangetypes.QueryFeeDiscountTierStatisticsResponse, error) {
+	return &exchangetypes.QueryFeeDiscountTierStatisticsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchMitoVaultInfos(ctx context.Context) (*exchangetypes.MitoVaultInfosResponse, error) {
+	return &exchangetypes.MitoVaultInfosResponse{}, nil
+}
+
+func (c *MockChainClient) FetchMarketIDFromVault(ctx context.Context, vaultAddress string) (*exchangetypes.QueryMarketIDFromVaultResponse, error) {
+	return &exchangetypes.QueryMarketIDFromVaultResponse{}, nil
+}
+
+func (c *MockChainClient) FetchHistoricalTradeRecords(ctx context.Context, marketId string) (*exchangetypes.QueryHistoricalTradeRecordsResponse, error) {
+	return &exchangetypes.QueryHistoricalTradeRecordsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchIsOptedOutOfRewards(ctx context.Context, account string) (*exchangetypes.QueryIsOptedOutOfRewardsResponse, error) {
+	return &exchangetypes.QueryIsOptedOutOfRewardsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchOptedOutOfRewardsAccounts(ctx context.Context) (*exchangetypes.QueryOptedOutOfRewardsAccountsResponse, error) {
+	return &exchangetypes.QueryOptedOutOfRewardsAccountsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchMarketVolatility(ctx context.Context, marketId string, tradeHistoryOptions *exchangetypes.TradeHistoryOptions) (*exchangetypes.QueryMarketVolatilityResponse, error) {
+	return &exchangetypes.QueryMarketVolatilityResponse{}, nil
+}
+
+func (c *MockChainClient) FetchChainBinaryOptionsMarkets(ctx context.Context, status string) (*exchangetypes.QueryBinaryMarketsResponse, error) {
+	return &exchangetypes.QueryBinaryMarketsResponse{}, nil
+}
+
+func (c *MockChainClient) FetchTraderDerivativeConditionalOrders(ctx context.Context, subaccountId string, marketId string) (*exchangetypes.QueryTraderDerivativeConditionalOrdersResponse, error) {
+	return &exchangetypes.QueryTraderDerivativeConditionalOrdersResponse{}, nil
+}
+
+func (c *MockChainClient) FetchMarketAtomicExecutionFeeMultiplier(ctx context.Context, marketId string) (*exchangetypes.QueryMarketAtomicExecutionFeeMultiplierResponse, error) {
+	return &exchangetypes.QueryMarketAtomicExecutionFeeMultiplierResponse{}, nil
+}