-
Notifications
You must be signed in to change notification settings - Fork 226
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
feat(vats): Cosmos chain core bootstrap with ag-solo client
- Loading branch information
1 parent
877f30a
commit a4ab506
Showing
10 changed files
with
307 additions
and
122 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -1,4 +1,5 @@ | ||
| // @ts-check | ||
| export * from './basic-behaviors.js'; | ||
| export * from './chain-behaviors.js'; | ||
| export * from './econ-behaviors.js'; | ||
| export * from './sim-behaviors.js'; |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,182 @@ | ||
| import { E, Far } from '@agoric/far'; | ||
| import { deeplyFulfilled } from '@agoric/marshal'; | ||
| import { | ||
| makeAsyncIterableFromNotifier, | ||
| makeNotifierKit, | ||
| makeSubscriptionKit, | ||
| observeIteration, | ||
| } from '@agoric/notifier'; | ||
|
|
||
| import { makeBridgeManager as makeBridgeManagerKit } from '../bridge.js'; | ||
|
|
||
| import { callProperties } from './utils.js'; | ||
|
|
||
| const { details: X } = assert; | ||
|
|
||
| /** | ||
| * @param {{ | ||
| * consume: { | ||
| * loadVat: ERef<VatLoader<ProvisioningVat>>, | ||
| * clientCreator: ERef<ClientCreator>, | ||
| * }, | ||
| * produce: { provisioning: Producer<unknown> }, | ||
| * vats: { comms: CommsVatRoot, vattp: VattpVat }, | ||
| * }} powers | ||
| * @typedef {ERef<ReturnType<import('../vat-provisioning.js').buildRootObject>>} ProvisioningVat | ||
| */ | ||
| export const makeProvisioner = async ({ | ||
| consume: { clientCreator, loadVat }, | ||
| vats: { comms, vattp }, | ||
| produce: { provisioning }, | ||
| }) => { | ||
| const provisionerVat = E(loadVat)('provisioning'); | ||
| await E(provisionerVat).register(clientCreator, comms, vattp); | ||
| provisioning.resolve(provisionerVat); | ||
| }; | ||
| harden(makeProvisioner); | ||
|
|
||
| /** | ||
| * @param {{ | ||
| * consume: { provisioning: ProvisioningVat, bridgeManager: ERef<OptionalBridgeManager> }, | ||
| * }} powers | ||
| */ | ||
| export const bridgeProvisioner = async ({ | ||
| consume: { provisioning, bridgeManager: bridgeManagerP }, | ||
| }) => { | ||
| const bridgeManager = await bridgeManagerP; | ||
| if (!bridgeManager) { | ||
| return; | ||
| } | ||
|
|
||
| // Register a provisioning handler over the bridge. | ||
| const handler = Far('provisioningHandler', { | ||
| async fromBridge(_srcID, obj) { | ||
| switch (obj.type) { | ||
| case 'PLEASE_PROVISION': { | ||
| const { nickname, address, powerFlags } = obj; | ||
| return E(provisioning) | ||
| .pleaseProvision(nickname, address, powerFlags) | ||
| .catch(e => | ||
| console.error(`Error provisioning ${nickname} ${address}:`, e), | ||
| ); | ||
| } | ||
| default: | ||
| assert.fail(X`Unrecognized request ${obj.type}`); | ||
| } | ||
| }, | ||
| }); | ||
| await E(bridgeManager).register('provision', handler); | ||
| }; | ||
| harden(bridgeProvisioner); | ||
|
|
||
| /** | ||
| * | ||
| * @param {{ | ||
| * produce: { client: Producer<ClientManager>, clientCreator: Producer<ClientCreator> } | ||
| * }} param0 | ||
| */ | ||
| export const makeClientManager = async ({ | ||
| produce: { client, clientCreator: clientCreatorP }, | ||
| }) => { | ||
| // Create a subscription of chain configurations. | ||
| const { subscription, publication } = makeSubscriptionKit(); | ||
|
|
||
| // Cache the latest full property maker state. | ||
| let cachedPropertyMakers = {}; | ||
|
|
||
| /** @type {ClientManager} */ | ||
| const clientManager = Far('chainClientManager', { | ||
| assignBundle: newPropertyMakers => { | ||
| // Write the property makers to the cache, and update the subscription. | ||
| cachedPropertyMakers = { ...cachedPropertyMakers, ...newPropertyMakers }; | ||
| publication.updateState(newPropertyMakers); | ||
| }, | ||
| }); | ||
|
|
||
| /** @type {ClientCreator} */ | ||
| const clientCreator = Far('clientCreator', { | ||
| createUserBundle: (nickname, clientAddress, powerFlags) => { | ||
| const c = E(clientCreator).createClientFacet( | ||
| nickname, | ||
| clientAddress, | ||
| powerFlags, | ||
| ); | ||
| return E(c).getChainBundle(); | ||
| }, | ||
| createClientFacet: async (_nickname, clientAddress, _powerFlags) => { | ||
| let clientHome = {}; | ||
|
|
||
| const makeUpdatedConfiguration = (newPropertyMakers = {}) => { | ||
| // Specialize the property makers with the client address. | ||
| const newProperties = callProperties(newPropertyMakers, clientAddress); | ||
| clientHome = { ...clientHome, ...newProperties }; | ||
| const config = harden({ clientAddress, clientHome }); | ||
| return deeplyFulfilled(config); | ||
| }; | ||
|
|
||
| // Publish new configurations. | ||
| const { notifier, updater } = makeNotifierKit( | ||
| makeUpdatedConfiguration(cachedPropertyMakers), | ||
| ); | ||
| const it = makeAsyncIterableFromNotifier(notifier); | ||
|
|
||
| /** @type {ClientFacet} */ | ||
| const clientFacet = Far('chainProvisioner', { | ||
| getChainBundle: () => clientHome, | ||
| getConfiguration: () => it, | ||
| }); | ||
|
|
||
| observeIteration(subscription, { | ||
| updateState(newPropertyMakers) { | ||
| updater.updateState(makeUpdatedConfiguration(newPropertyMakers)); | ||
| }, | ||
| }); | ||
|
|
||
| return clientFacet; | ||
| }, | ||
| }); | ||
|
|
||
| clientCreatorP.resolve(clientCreator); | ||
| client.resolve(clientManager); | ||
| }; | ||
| harden(makeClientManager); | ||
|
|
||
| /** | ||
| * @param {{ | ||
| * devices: { timer: unknown }, | ||
| * vats: { timer: TimerVat }, | ||
| * produce: { chainTimerService: Producer<ERef<TimerService>> } | ||
| * }} powers | ||
| */ | ||
| export const startTimerService = async ({ | ||
| devices: { timer: timerDevice }, | ||
| vats: { timer: timerVat }, | ||
| produce: { chainTimerService }, | ||
| }) => { | ||
| chainTimerService.resolve(E(timerVat).createTimerService(timerDevice)); | ||
| }; | ||
| harden(startTimerService); | ||
|
|
||
| /** | ||
| * TODO: Make a Powers type we pass everywhere, which has just a subset as permitted. | ||
| * | ||
| * @param {{ | ||
| * devices: { bridge: Device<import('../bridge.js').BridgeDevice> }, | ||
| * vatPowers: { D: DProxy }, | ||
| * produce: { bridgeManager: Producer<OptionalBridgeManager> }, | ||
| * }} powers | ||
| */ | ||
| export const makeBridgeManager = async ({ | ||
| devices: { bridge }, | ||
| vatPowers: { D }, | ||
| produce: { bridgeManager }, | ||
| }) => { | ||
| const myBridge = bridge ? makeBridgeManagerKit(E, D, bridge) : undefined; | ||
| if (!myBridge) { | ||
| console.warn( | ||
| 'Running without a bridge device; this is not an actual chain.', | ||
| ); | ||
| } | ||
| bridgeManager.resolve(myBridge); | ||
| }; | ||
| harden(makeBridgeManager); |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.