All files / src/chainManagement setRootChainManifest.js

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
 
 
 
 
 
 
 
 
 
2x
 
2x
 
 
 
 
 
 
 
 
2x
1x
 
1x
 
 
 
1x
1x
2x
 
1x
1x
1x
1x
 
 
1x
1x
1x
1x
 
 
 
 
 
 
 
 
 
 
 
 
 
 
 
2x
1x
1x
1x
1x
1x
1x
1x
1x
 
 
 
 
2x
 
const {
  rootCovenant: { actionCreators },
  manifest: {
    selectors: { getChainIdByAlias }
  },
  config: {
    selectors: { getChains }
  },
  constants: { ROOT_CHAIN_ALIAS }
} = require('interbit-covenant-tools')
 
const log = require('../log')
 
/**
 * Sets the root chain manifest by dispatching the manifest file
 * to the root chain for inclusion in root chain state.
 * @param {Object} cli - The cli of the node containing the root chain.
 * @param {Object} manifest - The manifest file to set.
 * @param {Object} config - The chain configuration file as JSON.
 */
const setRootChainManifest = (cli, manifest, config) => {
  log.info('UPDATING ROOT CHAIN WITH DEPLOYMENT INFO')
 
  const setManifestAction = actionCreators.setManifest(manifest)
 
  // NOTE: This is a tmp kludge - cascading manifest updates in a future release
  // will only do the root chain (then root will manage setting other chains)
  const chainEntries = Object.entries(getChains(config))
  chainEntries
    .filter(([, chainConfig]) => chainConfig.applyInterbuffer)
    .forEach(([chainAlias]) => {
      const chainId = getChainIdByAlias(chainAlias, manifest)
      const chainInterface = cli.getChain(chainId)
      log.info(`Updating manifest on ${chainAlias}`)
      waitForBlockToDispatch(chainInterface, setManifestAction)
    })
 
  const rootChainId = getChainIdByAlias(ROOT_CHAIN_ALIAS, manifest)
  Eif (!rootChainId) {
    log.error(`No root chain was configured for this deployment`)
    return
  }
 
  const rootChainInterface = cli.getChain(rootChainId)
  if (!rootChainInterface) {
    log.error(
      `No root chain was found for this deployment at chain ID: ${rootChainId}`
    )
    return
  }
 
  log.info(`Updating root manifest on ${ROOT_CHAIN_ALIAS}`)
  waitForBlockToDispatch(rootChainInterface, setManifestAction)
}
 
// Wait for chain to init and make it's first block before setting manifest
const waitForBlockToDispatch = (chainInterface, action) => {
  let unsubscribe = () => {}
  let count = 0
  unsubscribe = chainInterface.blockSubscribe(() => {
    Eif (count === 0) {
      log.action(action)
      chainInterface.dispatch(action)
      unsubscribe()
      count += 1
    }
  })
}
 
module.exports = setRootChainManifest