Method run

src/commands/load.ts:29–216

()

  static args = Command.args

  async run(): Promise<void> {
    const {
      argv,
      // flags: { debug, dev: devMode },
    } = await this.parse(Load)
    const { dataDir } = this.config
    const storageEngine = await this.getStorageEngine()
    const storageRunning = await storageEngine.healthCheck()
    if (!storageRunning) {
      this.logger.error(
        `Storage engine check at ${storageEngine.host} FAILED canceling LOAD`
      )
      this.exit()
    }
    // const opts: Opts = { logger: this.logger, debug, devMode }
    let allProviders = argv
    // if (!provider) {
    //   provider = await this.getProvider()
    // }

    /**
     * Handle 2 methods of scanning, either for explicitly passed providers OR
     * try to scan for all providers found within the config file
     * if we still have 0 providers, fail and exit.
     */
    if (allProviders.length >= 1) {
      this.logger.info(
        `Loading data to Dgraph for providers: ${allProviders.join(' | ')}`
      )
    } else {
      this.logger.info('Searching config for initialized providers')
      const config = this.getCGConfig()
      allProviders = Object.keys(config).filter(
        (val: string) => val !== 'cloudGraph'
      )
      // TODO: keep this log?
      this.logger.info(
        `Found providers ${allProviders.join(' | ')} in cloud-graph config`
      )
      if (allProviders.length === 0) {
        this.logger.error(
          'Error, there are no providers configured and none were passed to load, try "cg init" to set some up!'
        )
        this.exit()
      }
    }

    /**
     * loop through providers and attempt to scan each of them
     */
    const schema: any[] = []
    for (const provider of allProviders) {
      this.logger.info(
        `Beginning ${chalk.italic.green('LOAD')} for ${provider}`
      )
      const { client: providerClient, schemasMap: schemaMap } =
        await this.getProviderClient(provider)
      if (!providerClient) {