feat(cosmic-swingset): Handle InstallBundle messages

Agoric · May 25, 2022 · b72d068 · b72d068
1 parent 194e89b
commit b72d068
Show file tree

Hide file tree

Showing 4 changed files with 42 additions and 0 deletions.
diff --git a/golang/cosmos/x/swingset/keeper/msg_server.go b/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
+}
diff --git a/packages/cosmic-swingset/src/action-types.js b/packages/cosmic-swingset/src/action-types.js
@@ -10,3 +10,4 @@ export const PLEASE_PROVISION = 'PLEASE_PROVISION';
 export const VBANK_BALANCE_UPDATE = 'VBANK_BALANCE_UPDATE';
 export const WALLET_ACTION = 'WALLET_ACTION';
 export const WALLET_SPEND_ACTION = 'WALLET_SPEND_ACTION';
+export const INSTALL_BUNDLE = 'INSTALL_BUNDLE';
diff --git a/packages/cosmic-swingset/src/block-manager.js b/packages/cosmic-swingset/src/block-manager.js
@@ -27,6 +27,7 @@ export default function makeBlockManager({
   saveChainState,
   saveOutsideState,
   savedHeight,
+  validateAndInstallBundle,
   verboseBlocks = false,
 }) {
   let computedHeight = savedHeight;
@@ -79,6 +80,17 @@ export default function makeBlockManager({
         break;
       }
 
+      case ActionType.INSTALL_BUNDLE: {
+        p = (async () => {
+          const bundle = JSON.parse(action.bundle);
+          harden(bundle);
+          return validateAndInstallBundle(bundle);
+        })().catch(error => {
+          console.error(error);
+        });
+        break;
+      }
+
       case ActionType.CORE_EVAL: {
         p = doBridgeInbound(BRIDGE_ID.CORE, action);
         break;

diff --git a/packages/cosmic-swingset/src/launch-chain.js b/packages/cosmic-swingset/src/launch-chain.js
@@ -320,6 +320,8 @@ export async function launch({
     kvStore.get(getHostKey('chainSends')) || '[]',
   );
 
+  const { validateAndInstallBundle } = controller;
+
   return {
     actionQueue,
     deliverInbound,
@@ -333,5 +335,6 @@ export async function launch({
     savedHeight,
     savedBlockTime,
     savedChainSends,
+    validateAndInstallBundle,
   };
 }