[core] Protocol Upgrades

app/client/cli/gov.go

@@ -2,6 +2,7 @@ package cli
 
 import (
 	"fmt"
+	"strconv"
 
 	"github.com/spf13/cobra"
 	"google.golang.org/protobuf/types/known/anypb"
@@ -46,8 +47,8 @@ func govCommands() []*cobra.Command {
 				key := args[1]
 				value := args[2]
 
-				// TODO(deblasis): implement RPC client, route and handler
-				fmt.Printf("changing parameter %s owned by %s to %s\n", args[1], args[0], args[2])
+				// TODO(0xbigboss): implement RPC client, route and handler
+				fmt.Printf("changing parameter %s owned by %s to %s\n", key, fromAddrHex, value)
 
 				kb, err := keybaseForCLI()
 				if err != nil {
@@ -87,13 +88,88 @@ func govCommands() []*cobra.Command {
 				if err != nil {
 					return err
 				}
-				// DISCUSS(#310): define UX for return values - should we return the raw response or a parsed/human readable response? For now, I am simply printing to stdout
+
+				if resp.StatusCode() != 200 {
+					return fmt.Errorf("HTTP status code: %d\n", resp.StatusCode())
+				}
+
+				fmt.Printf("Successfully sent change parameter %s owned by %s to %s\n", key, fromAddrHex, value)
+				fmt.Printf("HTTP status code: %d\n", resp.StatusCode())
+				fmt.Println(string(resp.Body))
+
+				return nil
+			},
+		},
+		{
+			Use:     "Upgrade <owner> <version> <height>",
+			Short:   "Upgrade ",
+			Long:    "Schedules an upgrade to the specified version at the specified height",
+			Aliases: []string{"upgrade"},
+			Args:    cobra.ExactArgs(3),
+			RunE: func(cmd *cobra.Command, args []string) error {
+				// Unpack CLI arguments
+				fromAddrHex := args[0]
+				version := args[1]
+				heightArg := args[2]
+
+				fmt.Printf("submitting upgrade for version %s at height %s.\n", version, heightArg)
+
+				kb, err := keybaseForCLI()
+				if err != nil {
+					return err
+				}
+
+				if !flags.NonInteractive {
+					pwd = readPassphrase(pwd)
+				}
+
+				pk, err := kb.GetPrivKey(fromAddrHex, pwd)
+				if err != nil {
+					return err
+				}
+				if err := kb.Stop(); err != nil {
+					return err
+				}
+
+				height, err := strconv.ParseInt(heightArg, 10, 64)
+				if err != nil {
+					return err
+				}
+
+				msg := &types.MessageUpgrade{
+					Signer:  pk.Address(),
+					Version: version,
+					Height:  height,
+				}
+
+				err = msg.ValidateBasic()
+				if err != nil {
+					cmd.PrintErrf("invalid message: %s\n", err)
+					return err
+				}
+
+				tx, err := prepareTxBytes(msg, pk)
+				if err != nil {
+					return err
+				}
+
+				resp, err := postRawTx(cmd.Context(), pk, tx)
+				if err != nil {
+					return err
+				}
+
+				if resp.StatusCode() != 200 {
+					return fmt.Errorf("HTTP status code: %d\n", resp.StatusCode())
+				}
+
+				fmt.Printf("Successfully submitted upgrade for version %s at height %s.\n", version, heightArg)
 				fmt.Printf("HTTP status code: %d\n", resp.StatusCode())
 				fmt.Println(string(resp.Body))
 
 				return nil
 			},
 		},
+		// TODO: 0xbigboss MessageCancelUpgrade
 	}
 	return cmds
 }

app/client/cli/query.go

@@ -379,7 +379,7 @@ func queryHeightCommands() []*cobra.Command {
 			Use:     "Upgrade [--height]",
 			Short:   "Get the upgrade version",
 			Long:    "Queries the node RPC to obtain the upgrade version for the given (or latest if unspecified) height",
-			Aliases: []string{"param"},
+			Aliases: []string{"upgrade"},
 			Args:    cobra.ExactArgs(0),
 			RunE: func(cmd *cobra.Command, args []string) error {
 				client, err := rpc.NewClientWithResponses(flags.RemoteCLIURL)

app/client/cli/utils.go

@@ -316,12 +316,12 @@ func keybaseForCLI() (keybase.Keybase, error) {
 
 func unableToConnectToRpc(err error) error {
 	fmt.Printf("❌ Unable to connect to the RPC @ %s\n\nError: %s", boldText(flags.RemoteCLIURL), err)
-	return nil
+	return fmt.Errorf("unable to connect to the RPC @ %s", flags.RemoteCLIURL)
 }
 
 func rpcResponseCodeUnhealthy(statusCode int, response []byte) error {
 	fmt.Printf("❌ RPC reporting unhealthy status HTTP %d @ %s\n\n%s", statusCode, boldText(flags.RemoteCLIURL), response)
-	return nil
+	return fmt.Errorf("RPC reporting unhealthy status HTTP %d @ %s", statusCode, flags.RemoteCLIURL)
 }
 
 func boldText[T string | []byte](s T) string {

build/Dockerfile.client

@@ -1,17 +1,12 @@
-ARG GOLANG_IMAGE_VERSION=golang:1.20-alpine3.16
+ARG GOLANG_IMAGE_VERSION=golang:1.20-bookworm
 
 FROM ${GOLANG_IMAGE_VERSION} AS builder
 
 ENV POCKET_ROOT=/go/src/github.com/pocket-network
 
 WORKDIR $POCKET_ROOT
 
-COPY . .
-
-# Install bash
-RUN apk add --no-cache bash
-
-# Hot reloading
-RUN go install github.com/cespare/reflex@latest
-
-CMD ["/bin/bash"]
+RUN apt-get update && apt-get install -y procps bash-completion jq
+RUN echo "source /etc/bash_completion" >> ~/.bashrc
+# tail -n +2 removes the first line of the completion script since the CLI spits out some logs
+RUN echo "source <($POCKET_ROOT/bin/p1 completion bash | tail -n +2)" >> ~/.bashrc

build/Dockerfile.localdev

@@ -12,16 +12,10 @@ ENV POCKET_ROOT=/go/src/github.com/pocket-network/
 # Source code
 WORKDIR $POCKET_ROOT
 
-COPY . .
+RUN apk update && apk add --no-cache build-base gcc musl-dev
 
 # Hot reloading
 RUN go install github.com/cespare/reflex@latest
 
-RUN apk add build-base
-
 # Debugging
 RUN go install github.com/go-delve/delve/cmd/dlv@latest
-
-# Needed to make `go install dlv` and `dlv debug` work...
-RUN apk update && apk add --no-cache gcc musl-dev
-RUN go get github.com/go-delve/delve/cmd/dlv@latest

build/config/genesis.json

@@ -1583,15 +1583,17 @@
     {
       "address": "099044a5282c4089976c6b13ab13e5423dae55ce",
       "amount": "100000000000000"
+    },
+    {
+      "address": "da034209758b78eaea06dd99c07909ab54c99b45",
+      "amount": "100000000000000"
     }
   ],
   "applications": [
     {
       "actor_type": 1,
       "address": "00101f2ff54811e84df2d767c661f57a06349b7e",
-      "chains": [
-        "0001"
-      ],
+      "chains": ["0001"],
       "output": "00101f2ff54811e84df2d767c661f57a06349b7e",
       "paused_height": -1,
       "public_key": "bb851ac31120a4c8848738582f358599abbc3d84638f8fa79f74aeafad1eede0",
@@ -1604,9 +1606,7 @@
     {
       "actor_type": 3,
       "address": "0010336c3a2cc1ec71fecc45c360214f757194aa",
-      "chains": [
-        "0001"
-      ],
+      "chains": ["0001"],
       "output": "0010336c3a2cc1ec71fecc45c360214f757194aa",
       "paused_height": -1,
       "public_key": "d913a05a6f4bde35413bdcc6343238960cfc7d8aff425fb712dcaa52f1476dbf",
@@ -1652,6 +1652,8 @@
     "fisherman_unstaking_blocks_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
     "message_change_parameter_fee": "10000",
     "message_change_parameter_fee_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
+    "message_upgrade_fee": "10000",
+    "message_upgrade_fee_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
     "message_double_sign_fee": "10000",
     "message_double_sign_fee_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
     "message_edit_stake_app_fee": "10000",
@@ -1761,9 +1763,7 @@
     {
       "actor_type": 2,
       "address": "00104055c00bed7c983a48aac7dc6335d7c607a7",
-      "chains": [
-        "0001"
-      ],
+      "chains": ["0001"],
       "output": "00104055c00bed7c983a48aac7dc6335d7c607a7",
       "paused_height": -1,
       "public_key": "dfe357de55649e6d2ce889acf15eb77e94ab3c5756fe46d3c7538d37f27f115e",
@@ -1774,9 +1774,7 @@
     {
       "actor_type": 2,
       "address": "001022b138896c4c5466ac86b24a9bbe249905c2",
-      "chains": [
-        "0001"
-      ],
+      "chains": ["0001"],
       "output": "001022b138896c4c5466ac86b24a9bbe249905c2",
       "paused_height": -1,
       "public_key": "56915c1270bc8d9280a633e0be51647f62388a851318381614877ef2ed84a495",

build/config/genesis_localhost.json

@@ -27,6 +27,10 @@
     {
       "address": "88a792b7aca673620132ef01f50e62caa58eca83",
       "amount": "100000000000000"
+    },
+    {
+      "address": "da034209758b78eaea06dd99c07909ab54c99b45",
+      "amount": "100000000000000"
     }
   ],
   "pools": [
@@ -195,6 +199,7 @@
     "message_pause_servicer_fee": "10000",
     "message_unpause_servicer_fee": "10000",
     "message_change_parameter_fee": "10000",
+    "message_upgrade_fee": "10000",
     "acl_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
     "blocks_per_session_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
     "app_minimum_stake_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
@@ -250,7 +255,8 @@
     "message_unstake_servicer_fee_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
     "message_pause_servicer_fee_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
     "message_unpause_servicer_fee_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
-    "message_change_parameter_fee_owner": "da034209758b78eaea06dd99c07909ab54c99b45"
+    "message_change_parameter_fee_owner": "da034209758b78eaea06dd99c07909ab54c99b45",
+    "message_upgrade_fee_owner": "da034209758b78eaea06dd99c07909ab54c99b45"
   },
   "genesis_time": {
     "seconds": 1663610702,