feat: Support publishing source bundles to chain and installing hash bundles to Zoe

golang/cosmos/proto/agoric/swingset/msgs.proto

@@ -7,6 +7,8 @@ option go_package = "github.com/Agoric/agoric-sdk/golang/cosmos/x/swingset/types
 
 // Transactions.
 service Msg {
+  // Install a JavaScript sources bundle on the chain's SwingSet controller.
+  rpc InstallBundle(MsgInstallBundle) returns (MsgInstallBundleResponse);
   // Send inbound messages.
   rpc DeliverInbound(MsgDeliverInbound) returns (MsgDeliverInboundResponse);
   // Perform a low-privilege wallet action.
@@ -108,3 +110,20 @@ message MsgProvision {
 
 // MsgProvisionResponse is an empty reply.
 message MsgProvisionResponse {}
+
+// MsgInstallBundle carries a signed bundle to SwingSet.
+message MsgInstallBundle {
+    string bundle = 1 [
+        (gogoproto.jsontag)    = "bundle",
+        (gogoproto.moretags)   = "yaml:\"bundle\""
+    ];
+    bytes submitter = 2 [
+        (gogoproto.casttype)   = "github.com/cosmos/cosmos-sdk/types.AccAddress",
+        (gogoproto.jsontag)    = "submitter",
+        (gogoproto.moretags)   = "yaml:\"submitter\""
+    ];
+}
+
+// MsgInstallBundleResponse is an empty acknowledgement that an install bundle
+// message has been queued for the SwingSet kernel's consideration.
+message MsgInstallBundleResponse {}

golang/cosmos/x/swingset/client/cli/tx.go

@@ -34,6 +34,7 @@ func GetTxCmd(storeKey string) *cobra.Command {
 	swingsetTxCmd.AddCommand(
 		GetCmdDeliver(),
 		GetCmdProvisionOne(),
+		GetCmdInstallBundle(),
 	)
 
 	return swingsetTxCmd
@@ -85,6 +86,48 @@ func GetCmdDeliver() *cobra.Command {
 	return cmd
 }
 
+// GetCmdInstallBundle is the CLI command for constructing or sending an
+// InstallBundle message in a transaction.
+func GetCmdInstallBundle() *cobra.Command {
+	cmd := &cobra.Command{
+		Use:  "install-bundle <JSON>/@<FILE>/-",
+		Args: cobra.ExactArgs(1),
+
+		RunE: func(cmd *cobra.Command, args []string) error {
+			cctx, err := client.GetClientTxContext(cmd)
+			if err != nil {
+				return err
+			}
+
+			jsonIn := args[0]
+			if jsonIn[0] == '@' {
+				fname := args[0][1:]
+				if fname == "-" {
+					// Reading from stdin.
+					if _, err := fmt.Scanln(&jsonIn); err != nil {
+						return err
+					}
+				} else {
+					jsonBytes, err := ioutil.ReadFile(fname)
+					if err != nil {
+						return err
+					}
+					jsonIn = string(jsonBytes)
+				}
+			}
+
+			msg := types.NewMsgInstallBundle(jsonIn, cctx.GetFromAddress())
+			if err := msg.ValidateBasic(); err != nil {
+				return err
+			}
+
+			return tx.GenerateOrBroadcastTxCLI(cctx, cmd.Flags(), msg)
+		},
+	}
+	flags.AddTxFlagsToCmd(cmd)
+	return cmd
+}
+
 // GetCmdProvision is the CLI command for sending a Provision transaction
 func GetCmdProvisionOne() *cobra.Command {
 	cmd := &cobra.Command{

golang/cosmos/x/swingset/keeper/msg_server.go

@@ -155,3 +155,29 @@ func (keeper msgServer) Provision(goCtx context.Context, msg *types.MsgProvision
 
 	return &types.MsgProvisionResponse{}, nil
 }
+
+type installBundleAction struct {
+	*types.MsgInstallBundle
+	Type        string `json:"type"` // INSTALL_BUNDLE
+	BlockHeight int64  `json:"blockHeight"`
+	BlockTime   int64  `json:"blockTime"`
+}
+
+func (keeper msgServer) InstallBundle(goCtx context.Context, msg *types.MsgInstallBundle) (*types.MsgInstallBundleResponse, error) {
+	ctx := sdk.UnwrapSDKContext(goCtx)
+
+	action := &installBundleAction{
+		MsgInstallBundle: msg,
+		Type:             "INSTALL_BUNDLE",
+		BlockHeight:      ctx.BlockHeight(),
+		BlockTime:        ctx.BlockTime().Unix(),
+	}
+
+	err := keeper.PushAction(ctx, action)
+	// fmt.Fprintln(os.Stderr, "Returned from SwingSet", out, err)
+	if err != nil {
+		return nil, err
+	}
+
+	return &types.MsgInstallBundleResponse{}, nil
+}

golang/cosmos/x/swingset/types/msgs.go

@@ -14,6 +14,7 @@ const RouterKey = ModuleName // this was defined in your key.go file
 var (
 	_ sdk.Msg = &MsgDeliverInbound{}
 	_ sdk.Msg = &MsgProvision{}
+	_ sdk.Msg = &MsgInstallBundle{}
 	_ sdk.Msg = &MsgWalletAction{}
 	_ sdk.Msg = &MsgWalletSpendAction{}
 
@@ -183,3 +184,32 @@ func (msg MsgProvision) GetSignBytes() []byte {
 func (msg MsgProvision) GetSigners() []sdk.AccAddress {
 	return []sdk.AccAddress{msg.Submitter}
 }
+
+func NewMsgInstallBundle(bundleJson string, submitter sdk.AccAddress) *MsgInstallBundle {
+	return &MsgInstallBundle{
+		Bundle:    bundleJson,
+		Submitter: submitter,
+	}
+}
+
+// Route should return the name of the module
+func (msg MsgInstallBundle) Route() string { return RouterKey }
+
+// Type should return the action
+func (msg MsgInstallBundle) Type() string { return "installBundle" }
+
+// ValidateBasic runs stateless checks on the message
+func (msg MsgInstallBundle) ValidateBasic() error {
+	if msg.Submitter.Empty() {
+		return sdkerrors.Wrap(sdkerrors.ErrInvalidAddress, "Submitter address cannot be empty")
+	}
+	if len(msg.Bundle) == 0 {
+		return sdkerrors.Wrap(sdkerrors.ErrUnknownRequest, "Bundle cannot be empty")
+	}
+	return nil
+}
+
+// GetSigners defines whose signature is required
+func (msg MsgInstallBundle) GetSigners() []sdk.AccAddress {
+	return []sdk.AccAddress{msg.Submitter}
+}