feat(vats): upgrade the orchestration core

a3p-integration/proposals/e:upgrade-next/.gitignore

@@ -3,4 +3,4 @@ add-LEMONS/
 add-OLIVES/
 upgrade-bank/
 upgrade-provisionPool/
-
+upgrade-orch-core/

a3p-integration/proposals/e:upgrade-next/package.json

@@ -7,8 +7,8 @@
       "coreProposals": []
     },
     "sdk-generate": [
+      "vats/upgrade-orch-core.js upgrade-orch-core",
       "vats/test-localchain.js localchaintest-submission",
-      "vats/upgrade-bank.js upgrade-bank",
       "vats/upgrade-provisionPool.js upgrade-provisionPool",
       "testing/add-LEMONS.js add-LEMONS",
       "testing/add-OLIVES.js add-OLIVES"

golang/cosmos/app/upgrade.go

@@ -1,7 +1,6 @@
 package gaia
 
 import (
-
 	"github.com/Agoric/agoric-sdk/golang/cosmos/vm"
 	swingsetkeeper "github.com/Agoric/agoric-sdk/golang/cosmos/x/swingset/keeper"
 	sdk "github.com/cosmos/cosmos-sdk/types"
@@ -37,7 +36,10 @@ func unreleasedUpgradeHandler(app *GaiaApp, targetUpgrade string) func(sdk.Conte
 		if isFirstTimeUpgradeOfThisVersion(app, ctx) {
 			// Each CoreProposalStep runs sequentially, and can be constructed from
 			// one or more modules executing in parallel within the step.
-			CoreProposalSteps = []vm.CoreProposalStep{}
+			CoreProposalSteps = []vm.CoreProposalStep{
+				// Upgrade orch-core to the latest version.
+				vm.CoreProposalStepForModules("@agoric/builders/scripts/vats/upgrade-orch-core.js"),
+			}
 		}
 
 		app.upgradeDetails = &upgradeDetails{

packages/builders/scripts/vats/upgrade-orch-core.js

@@ -0,0 +1,23 @@
+import { makeHelpers } from '@agoric/deploy-script-support';
+
+/** @type {import('@agoric/deploy-script-support/src/externalTypes.js').CoreEvalBuilder} */
+export const defaultProposalBuilder = async ({ publishRef, install }) =>
+  harden({
+    sourceSpec: '@agoric/vats/src/proposals/upgrade-orch-core-proposal.js',
+    getManifestCall: [
+      'getManifestForUpgradingOrchCore',
+      {
+        bundleRefs: {
+          ibc: publishRef(install('@agoric/vats/src/vat-ibc.js')),
+          network: publishRef(install('@agoric/vats/src/vat-network.js')),
+          localchain: publishRef(install('@agoric/vats/src/vat-localchain.js')),
+          transfer: publishRef(install('@agoric/vats/src/vat-transfer.js')),
+        },
+      },
+    ],
+  });
+
+export default async (homeP, endowments) => {
+  const { writeCoreProposal } = await makeHelpers(homeP, endowments);
+  await writeCoreProposal('upgrade-network', defaultProposalBuilder);
+};

packages/vats/src/proposals/upgrade-orch-core-proposal.js

@@ -0,0 +1,43 @@
+import { E } from '@endo/far';
+
+/**
+ * @param {BootstrapPowers & {
+ *   consume: {
+ *     vatAdminSvc: VatAdminSvc;
+ *     vatStore: MapStore<
+ *       string,
+ *       import('@agoric/swingset-vat').CreateVatResults
+ *     >;
+ *   };
+ * }} powers
+ * @param {object} options
+ * @param {{ ibcRef: VatSourceRef; networkRef: VatSourceRef }} options.options
+ */
+export const upgradeOrchCore = async (
+  { consume: { vatAdminSvc, vatStore } },
+  options,
+) => {
+  const { bundleRefs } = options.options;
+
+  for await (const [name, ref] of Object.entries(bundleRefs)) {
+    assert(ref.bundleID, `bundleID missing for ${name}`);
+    console.log(name, `BUNDLE ID: `, ref.bundleID);
+    const bundleCap = await E(vatAdminSvc).getBundleCap(ref.bundleID);
+
+    const { adminNode } = await E(vatStore).get(name);
+    await E(adminNode).upgrade(bundleCap, {});
+  }
+};
+
+export const getManifestForUpgradingOrchCore = (_powers, { bundleRefs }) => ({
+  manifest: {
+    [upgradeOrchCore.name]: {
+      consume: {
+        vatAdminSvc: 'vatAdminSvc',
+        vatStore: 'vatStore',
+      },
+      produce: {},
+    },
+  },
+  options: { bundleRefs },
+});