WIP: Add x/msg_authorization module

x/msg_authorization/alias.go

@@ -0,0 +1,44 @@
+// nolint
+// autogenerated code using github.com/rigelrozanski/multitool
+// aliases generated for the following subdirectories:
+// ALIASGEN: github.com/cosmos/cosmos-sdk/x/msg_authorization/internal/types/
+// ALIASGEN: github.com/cosmos/cosmos-sdk/x/msg_authorization/internal/keeper/
+package msg_authorization
+
+import (
+	"github.com/cosmos/cosmos-sdk/x/msg_authorization/internal/keeper"
+	"github.com/cosmos/cosmos-sdk/x/msg_authorization/internal/types"
+)
+
+const (
+	ModuleName   = types.ModuleName
+	StoreKey     = types.StoreKey
+	RouterKey    = types.RouterKey
+	QuerierRoute = types.QuerierRoute
+)
+
+var (
+	// functions aliases
+	RegisterCodec             = types.RegisterCodec
+	ErrInvalidGranter         = types.ErrInvalidGranter
+	ErrInvalidGrantee         = types.ErrInvalidGrantee
+	ErrInvalidExpirationTime  = types.ErrInvalidExpirationTime
+	NewMsgGrantAuthorization  = types.NewMsgGrantAuthorization
+	NewMsgRevokeAuthorization = types.NewMsgRevokeAuthorization
+	NewMsgExecAuthorized      = types.NewMsgExecAuthorized
+	NewKeeper                 = keeper.NewKeeper
+
+	// variable aliases
+	ModuleCdc = types.ModuleCdc
+)
+
+type (
+	Authorization          = types.Authorization
+	SendAuthorization      = types.SendAuthorization
+	AuthorizationGrant     = types.AuthorizationGrant
+	GenericAuthorization   = types.GenericAuthorization
+	MsgGrantAuthorization  = types.MsgGrantAuthorization
+	MsgRevokeAuthorization = types.MsgRevokeAuthorization
+	MsgExecAuthorized      = types.MsgExecAuthorized
+	Keeper                 = keeper.Keeper
+)

x/msg_authorization/client/cli/flags.go

@@ -0,0 +1,3 @@
+package cli
+
+const FlagExpiration = "expiration"

x/msg_authorization/client/cli/query.go

@@ -0,0 +1,74 @@
+package cli
+
+import (
+	"fmt"
+
+	"github.com/cosmos/cosmos-sdk/client"
+	"github.com/cosmos/cosmos-sdk/client/context"
+	"github.com/cosmos/cosmos-sdk/client/flags"
+	"github.com/cosmos/cosmos-sdk/codec"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/cosmos/cosmos-sdk/x/msg_authorization/internal/types"
+	"github.com/spf13/cobra"
+)
+
+// GetQueryCmd returns the cli query commands for this module
+func GetQueryCmd(queryRoute string, cdc *codec.Codec) *cobra.Command {
+	authorizationQueryCmd := &cobra.Command{
+		Use:                        types.ModuleName,
+		Short:                      "Querying commands for the msg authorization module",
+		Long:                       "",
+		DisableFlagParsing:         true,
+		SuggestionsMinimumDistance: 2,
+		RunE:                       client.ValidateCmd,
+	}
+
+	authorizationQueryCmd.AddCommand(flags.GetCommands(
+		GetCmdQueryAuthorization(queryRoute, cdc),
+	)...)
+
+	return authorizationQueryCmd
+}
+
+// GetCmdQueryAuthorization implements the query authorizations command.
+func GetCmdQueryAuthorization(storeName string, cdc *codec.Codec) *cobra.Command {
+	//TODO update description
+	return &cobra.Command{
+		Use:   "authorization",
+		Args:  cobra.ExactArgs(3),
+		Short: "query authorization for a granter-grantee pair",
+		Long:  "query authorization for a granter-grantee pair",
+		RunE: func(cmd *cobra.Command, args []string) error {
+			cliCtx := context.NewCLIContext().WithCodec(cdc)
+
+			granterAddr, err := sdk.AccAddressFromBech32(args[0])
+			if err != nil {
+				return err
+			}
+
+			granteeAddr, err := sdk.AccAddressFromBech32(args[1])
+			if err != nil {
+				return err
+			}
+
+			msgAuthorized := args[2]
+
+			res, _, err := cliCtx.QueryStore(types.GetActorAuthorizationKey(granteeAddr, granterAddr, msgAuthorized), storeName)
+			if err != nil {
+				return err
+			}
+
+			if len(res) == 0 {
+				return fmt.Errorf("no authorization found for given address pair ")
+			}
+
+			var grant types.AuthorizationGrant
+			err = cdc.UnmarshalBinaryBare(res, &grant)
+			if err != nil {
+				return err
+			}
+
+			return cliCtx.PrintOutput(grant)
+		},
+	}
+}

x/msg_authorization/client/cli/tx.go

@@ -0,0 +1,152 @@
+package cli
+
+import (
+	"bufio"
+	"io/ioutil"
+	"time"
+
+	"github.com/spf13/cobra"
+	"github.com/spf13/viper"
+
+	"github.com/cosmos/cosmos-sdk/client"
+	"github.com/cosmos/cosmos-sdk/client/context"
+	"github.com/cosmos/cosmos-sdk/client/flags"
+	"github.com/cosmos/cosmos-sdk/codec"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/cosmos/cosmos-sdk/x/auth"
+	authclient "github.com/cosmos/cosmos-sdk/x/auth/client"
+	"github.com/cosmos/cosmos-sdk/x/msg_authorization/internal/types"
+)
+
+// GetTxCmd returns the transaction commands for this module
+func GetTxCmd(storeKey string, cdc *codec.Codec) *cobra.Command {
+	AuthorizationTxCmd := &cobra.Command{
+		Use:                        types.ModuleName,
+		Short:                      "Authorization transactions subcommands",
+		Long:                       "Authorize and revoke access to execute transactions on behalf of your address",
+		DisableFlagParsing:         true,
+		SuggestionsMinimumDistance: 2,
+		RunE:                       client.ValidateCmd,
+	}
+
+	AuthorizationTxCmd.AddCommand(flags.PostCommands(
+		GetCmdGrantAuthorization(cdc),
+		GetCmdRevokeAuthorization(cdc),
+		GetCmdSendAs(cdc),
+	)...)
+
+	return AuthorizationTxCmd
+}
+
+func GetCmdGrantAuthorization(cdc *codec.Codec) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "grant [grantee_address] [authorization] --from [granter_address_or_key]",
+		Short: "Grant authorization to an address",
+		Long:  "Grant authorization to an address to execute a transaction on your behalf",
+		Args:  cobra.ExactArgs(2),
+		RunE: func(cmd *cobra.Command, args []string) error {
+			inBuf := bufio.NewReader(cmd.InOrStdin())
+			txBldr := auth.NewTxBuilderFromCLI(inBuf).WithTxEncoder(authclient.GetTxEncoder(cdc))
+			cliCtx := context.NewCLIContextWithInput(inBuf).WithCodec(cdc)
+
+			granter := cliCtx.FromAddress
+			grantee, err := sdk.AccAddressFromBech32(args[0])
+			if err != nil {
+				return err
+			}
+
+			bz, err := ioutil.ReadFile(args[1])
+			if err != nil {
+				return err
+			}
+
+			var authorization types.Authorization
+			err = cdc.UnmarshalJSON(bz, &authorization)
+			if err != nil {
+				return err
+			}
+			expirationString := viper.GetString(FlagExpiration)
+			expiration, err := time.Parse(time.RFC3339, expirationString)
+			if err != nil {
+				return err
+			}
+
+			msg := types.NewMsgGrantAuthorization(granter, grantee, authorization, expiration)
+			if err := msg.ValidateBasic(); err != nil {
+				return err
+			}
+
+			return authclient.CompleteAndBroadcastTxCLI(txBldr, cliCtx, []sdk.Msg{msg})
+
+		},
+	}
+	cmd.Flags().String(FlagExpiration, "9999-12-31T23:59:59.52Z", "The time upto which the authorization is active for the user")
+
+	return cmd
+}
+
+func GetCmdRevokeAuthorization(cdc *codec.Codec) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "revoke [grantee_address] [msg_type] --from [granter]",
+		Short: "revoke authorization",
+		Long:  "revoke authorization from an address for a transaction",
+		Args:  cobra.ExactArgs(2),
+		RunE: func(cmd *cobra.Command, args []string) error {
+			inBuf := bufio.NewReader(cmd.InOrStdin())
+			txBldr := auth.NewTxBuilderFromCLI(inBuf).WithTxEncoder(authclient.GetTxEncoder(cdc))
+			cliCtx := context.NewCLIContextWithInput(inBuf).WithCodec(cdc)
+
+			granter := cliCtx.FromAddress
+			grantee, err := sdk.AccAddressFromBech32(args[0])
+			if err != nil {
+				return err
+			}
+
+			msgAuthorized := args[1]
+
+			msg := types.NewMsgRevokeAuthorization(granter, grantee, msgAuthorized)
+			if err := msg.ValidateBasic(); err != nil {
+				return err
+			}
+
+			return authclient.CompleteAndBroadcastTxCLI(txBldr, cliCtx, []sdk.Msg{msg})
+		},
+	}
+	return cmd
+}
+
+func GetCmdSendAs(cdc *codec.Codec) *cobra.Command {
+	cmd := &cobra.Command{
+		Use:   "send-as [grantee] [msg_tx_json] --from [grantee]",
+		Short: "execute tx on behalf of granter account",
+		Long:  "execute tx on behalf of granter account",
+		Args:  cobra.ExactArgs(2),
+		RunE: func(cmd *cobra.Command, args []string) error {
+			inBuf := bufio.NewReader(cmd.InOrStdin())
+			txBldr := auth.NewTxBuilderFromCLI(inBuf).WithTxEncoder(authclient.GetTxEncoder(cdc))
+			cliCtx := context.NewCLIContextWithInput(inBuf).WithCodec(cdc)
+
+			grantee := cliCtx.FromAddress
+
+			var stdTx auth.StdTx
+			bz, err := ioutil.ReadFile(args[1])
+			if err != nil {
+				return err
+			}
+
+			err = cdc.UnmarshalJSON(bz, &stdTx)
+			if err != nil {
+				return err
+			}
+
+			msg := types.NewMsgExecAuthorized(grantee, stdTx.Msgs)
+
+			if err := msg.ValidateBasic(); err != nil {
+				return err
+			}
+
+			return authclient.GenerateOrBroadcastMsgs(cliCtx, txBldr, []sdk.Msg{msg})
+		},
+	}
+	return cmd
+}

x/msg_authorization/client/rest/query.go

@@ -0,0 +1,11 @@
+package rest
+
+import (
+	"github.com/cosmos/cosmos-sdk/client/context"
+	"github.com/gorilla/mux"
+)
+
+func RegisterRoutes(cliCtx context.CLIContext, r *mux.Router) {
+
+	registerTxRoutes(cliCtx, r)
+}

x/msg_authorization/client/rest/tx.go

@@ -0,0 +1,80 @@
+package rest
+
+import (
+	"net/http"
+	"time"
+
+	"github.com/gorilla/mux"
+
+	"github.com/cosmos/cosmos-sdk/client/context"
+	sdk "github.com/cosmos/cosmos-sdk/types"
+	"github.com/cosmos/cosmos-sdk/types/rest"
+	authclient "github.com/cosmos/cosmos-sdk/x/auth/client"
+	"github.com/cosmos/cosmos-sdk/x/msg_authorization/internal/types"
+)
+
+func registerTxRoutes(cliCtx context.CLIContext, r *mux.Router) {
+	r.HandleFunc("/msg_authorization/grant", grantHandler(cliCtx)).Methods("POST")
+	r.HandleFunc("/msg_authorization/revoke", revokeHandler(cliCtx)).Methods("POST")
+}
+
+type GrantRequest struct {
+	BaseReq       rest.BaseReq        `json:"base_req" yaml:"base_req"`
+	Granter       sdk.AccAddress      `json:"granter"`
+	Grantee       sdk.AccAddress      `json:"grantee"`
+	Authorization types.Authorization `json:"authorization"`
+	Expiration    time.Time           `json:"expiration"`
+}
+
+type RevokeRequest struct {
+	BaseReq              rest.BaseReq   `json:"base_req" yaml:"base_req"`
+	Granter              sdk.AccAddress `json:"granter"`
+	Grantee              sdk.AccAddress `json:"grantee"`
+	AuthorizationMsgType string         `json:"authorization_msg_type"`
+}
+
+func grantHandler(cliCtx context.CLIContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req GrantRequest
+
+		if !rest.ReadRESTReq(w, r, cliCtx.Codec, &req) {
+			return
+		}
+
+		req.BaseReq = req.BaseReq.Sanitize()
+		if !req.BaseReq.ValidateBasic(w) {
+			return
+		}
+
+		msg := types.NewMsgGrantAuthorization(req.Granter, req.Grantee, req.Authorization, req.Expiration)
+		if err := msg.ValidateBasic(); err != nil {
+			rest.WriteErrorResponse(w, http.StatusBadRequest, err.Error())
+			return
+		}
+
+		authclient.WriteGenerateStdTxResponse(w, cliCtx, req.BaseReq, []sdk.Msg{msg})
+	}
+}
+
+func revokeHandler(cliCtx context.CLIContext) http.HandlerFunc {
+	return func(w http.ResponseWriter, r *http.Request) {
+		var req RevokeRequest
+
+		if !rest.ReadRESTReq(w, r, cliCtx.Codec, &req) {
+			return
+		}
+
+		req.BaseReq = req.BaseReq.Sanitize()
+		if !req.BaseReq.ValidateBasic(w) {
+			return
+		}
+
+		msg := types.NewMsgRevokeAuthorization(req.Granter, req.Grantee, req.AuthorizationMsgType)
+		if err := msg.ValidateBasic(); err != nil {
+			rest.WriteErrorResponse(w, http.StatusBadRequest, err.Error())
+			return
+		}
+
+		authclient.WriteGenerateStdTxResponse(w, cliCtx, req.BaseReq, []sdk.Msg{msg})
+	}
+}

x/msg_authorization/exported/keeper.go

@@ -0,0 +1,25 @@
+package exported
+
+import (
+	"time"
+
+	"github.com/cosmos/cosmos-sdk/x/msg_authorization/internal/types"
+
+	sdk "github.com/cosmos/cosmos-sdk/types"
+)
+
+type Keeper interface {
+	//DispatchActions executes the provided messages via authorization grants from the message signer to the grantee
+	DispatchActions(ctx sdk.Context, grantee sdk.AccAddress, msgs []sdk.Msg) sdk.Result
+
+	// Grants the provided authorization to the grantee on the granter's account with the provided expiration time
+	// If there is an existing authorization grant for the same sdk.Msg type, this grant overwrites that.
+	Grant(ctx sdk.Context, grantee sdk.AccAddress, granter sdk.AccAddress, authorization types.Authorization, expiration time.Time)
+
+	//Revokes any authorization for the provided message type granted to the grantee by the granter.
+	Revoke(ctx sdk.Context, grantee sdk.AccAddress, granter sdk.AccAddress, msgType sdk.Msg)
+
+	//Returns any Authorization (or nil), with the expiration time,
+	// granted to the grantee by the granter for the provided msg type.
+	GetAuthorization(ctx sdk.Context, grantee sdk.AccAddress, granter sdk.AccAddress, msgType sdk.Msg) (cap types.Authorization, expiration time.Time)
+}