-
Notifications
You must be signed in to change notification settings - Fork 815
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Add confidential transfer queries to seid (#1931)
* update codec * cleanup and queryies * enable in module * add other query * fix bug * fix lint * add decryption query * cleanup * validate address * comments * rectify test failures * speed up withdraw test * make other tests slightly faster
- Loading branch information
Showing
13 changed files
with
687 additions
and
104 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,180 @@ | ||
| package cli | ||
|
|
||
| import ( | ||
| "fmt" | ||
|
|
||
| "github.com/cosmos/cosmos-sdk/client" | ||
| "github.com/cosmos/cosmos-sdk/client/flags" | ||
| sdk "github.com/cosmos/cosmos-sdk/types" | ||
| "github.com/sei-protocol/sei-chain/x/confidentialtransfers/types" | ||
| "github.com/sei-protocol/sei-cryptography/pkg/encryption" | ||
| "github.com/sei-protocol/sei-cryptography/pkg/encryption/elgamal" | ||
| "github.com/spf13/cobra" | ||
| ) | ||
|
|
||
| const decryptAvailableBalanceFlag = "decrypt-available-balance" | ||
|
|
||
| // GetQueryCmd returns the cli query commands for the minting module. | ||
| func GetQueryCmd() *cobra.Command { | ||
| confidentialTransfersQueryCmd := &cobra.Command{ | ||
| Use: types.ModuleName, | ||
| Short: "Querying commands for the confidential transfer module", | ||
| DisableFlagParsing: true, | ||
| SuggestionsMinimumDistance: 2, | ||
| RunE: client.ValidateCmd, | ||
| } | ||
|
|
||
| confidentialTransfersQueryCmd.AddCommand( | ||
| GetCmdQueryAccount(), | ||
| GetCmdQueryAllAccount(), | ||
| ) | ||
|
|
||
| return confidentialTransfersQueryCmd | ||
| } | ||
|
|
||
| // GetCmdQueryAccount implements a command to return an account asssociated with the address and denom | ||
| func GetCmdQueryAccount() *cobra.Command { | ||
| cmd := &cobra.Command{ | ||
| Use: "account [denom] [address] [flags]", | ||
| Short: "Query the account state", | ||
| Long: "Queries the account state associated with the address and denom." + | ||
| "Pass the --from flag to decrypt the account" + | ||
| "Pass the --decrypt-available-balance flag to attempt to decrypt the available balance.", | ||
| Args: cobra.ExactArgs(2), | ||
| RunE: queryAccount, | ||
| } | ||
|
|
||
| flags.AddQueryFlagsToCmd(cmd) | ||
| cmd.Flags().String(flags.FlagFrom, "", "Name or address of private key to decrypt the account") | ||
| cmd.Flags().Bool(decryptAvailableBalanceFlag, false, "Set this to attempt to decrypt the available balance") | ||
| return cmd | ||
| } | ||
|
|
||
| func queryAccount(cmd *cobra.Command, args []string) error { | ||
| clientCtx, err := client.GetClientQueryContext(cmd) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| queryClient := types.NewQueryClient(clientCtx) | ||
|
|
||
| denom := args[0] | ||
|
|
||
| // Validate denom | ||
| err = sdk.ValidateDenom(denom) | ||
| if err != nil { | ||
| return fmt.Errorf("invalid denom: %v", err) | ||
| } | ||
|
|
||
| address := args[1] | ||
| // Validate address | ||
| _, err = sdk.AccAddressFromBech32(address) | ||
| if err != nil { | ||
| return fmt.Errorf("invalid address: %v", err) | ||
| } | ||
|
|
||
| from, err := cmd.Flags().GetString(flags.FlagFrom) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| fromAddr, _, _, err := client.GetFromFields(clientCtx, clientCtx.Keyring, from) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| res, err := queryClient.GetCtAccount(cmd.Context(), &types.GetCtAccountRequest{ | ||
| Address: address, | ||
| Denom: denom, | ||
| }) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| // If the --from flag passed matches the queried address, attempt to decrypt the contents | ||
| if fromAddr.String() == address { | ||
| account, err := res.Account.FromProto() | ||
| if err != nil { | ||
| return err | ||
| } | ||
| privateKey, err := getPrivateKey(cmd) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| aesKey, err := encryption.GetAESKey(*privateKey, denom) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| decryptor := elgamal.NewTwistedElgamal() | ||
| keyPair, err := decryptor.KeyGen(*privateKey, denom) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| decryptAvailableBalance, err := cmd.Flags().GetBool(decryptAvailableBalanceFlag) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| decryptedAccount, err := account.Decrypt(decryptor, keyPair, aesKey, decryptAvailableBalance) | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| return clientCtx.PrintProto(decryptedAccount) | ||
|
|
||
| } else { | ||
| return clientCtx.PrintProto(res.Account) | ||
| } | ||
| } | ||
|
|
||
| // GetCmdQueryAccount implements a command to return an account asssociated with the address and denom | ||
| func GetCmdQueryAllAccount() *cobra.Command { | ||
| cmd := &cobra.Command{ | ||
| Use: "accounts [address]", | ||
| Short: "Query all the confidential token accounts associated with the address", | ||
| Args: cobra.ExactArgs(1), | ||
| RunE: queryAllAccounts, | ||
| } | ||
|
|
||
| flags.AddQueryFlagsToCmd(cmd) | ||
|
|
||
| return cmd | ||
| } | ||
|
|
||
| func queryAllAccounts(cmd *cobra.Command, args []string) error { | ||
| clientCtx, err := client.GetClientQueryContext(cmd) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| queryClient := types.NewQueryClient(clientCtx) | ||
|
|
||
| address := args[0] | ||
| // Validate address | ||
| _, err = sdk.AccAddressFromBech32(address) | ||
| if err != nil { | ||
| return fmt.Errorf("invalid address: %v", err) | ||
| } | ||
|
|
||
| res, err := queryClient.GetAllCtAccounts(cmd.Context(), &types.GetAllCtAccountsRequest{ | ||
| Address: args[0], | ||
| }) | ||
|
|
||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| for i := range res.Accounts { | ||
| err = clientCtx.PrintString("\n") | ||
| if err != nil { | ||
| return err | ||
| } | ||
|
|
||
| err = clientCtx.PrintProto(&res.Accounts[i]) | ||
| if err != nil { | ||
| return err | ||
| } | ||
| } | ||
|
|
||
| return nil | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.