polkadot-js/client

// Copyright 2017-2019 @polkadot/client-cli authors & contributors
// This software may be modified and distributed under the terms
// of the Apache-2.0 license. See the LICENSE file for details.

import { Config, ConfigKeys } from '@polkadot/client/types';

import wrtc from 'wrtc';
import Client from '@polkadot/client';
import { logger } from '@polkadot/util';

import getArgv from './argv';
import getExternalIp from './getExternalIp';
import keyToCamel from './keyToCamel';

const l = logger('client/cli');

function cli (params?: string): Config {
  const argv = getArgv(params);

  return Object
    .keys(argv)
    .reduce((config: any, key): Config => {
      if (/^(db|dev|p2p|rpc|signal|telemetry|wasm)-/.test(key)) {
        const section = key.substr(0, key.indexOf('-')) as ConfigKeys;
        const name = keyToCamel(key, 1);

        config[section] = config[section] || {};
        // ummm... no index, not Map-ing this one
        config[section][name] = (argv as any)[key];
      } else if (!/^(db|dev|p2p|rpc|signal|telemetry|wasm)[A-Z]/.test(key)) {
        const name = keyToCamel(key) as ConfigKeys;

        // ummm... no index, not Map-ing this one
        config[name] = (argv as any)[key];
      }

      return config as Config;
    }, { p2p: { wrtc } });
}

// FIXME Catch the uncaught errors that weren't wrapped in a domain or try catch statement
// This was added due to exceptions from p2p streams, for which no pass-through handler exists
// and none can be added. As it stands, not a bad idea since it shows where stuff breaks
// instead of just exiting, however we should _never_ have these - and we have a couple that
// puts the app into an unknown state
// process.on('uncaughtException', (err: Error) => {
//   l.error('Uncaught exception', err);
// });

const config = cli();
const client = new Client();

getExternalIp()
  .then((externalIp): Promise<void> => client.start({ ...config, externalIp }))
  .catch((error): void => {
    l.error('Failed to start client', error);

    process.exit(-1);
  });

// eslint-disable-next-line @typescript-eslint/no-misused-promises
process.on('SIGINT', async (): Promise<void> => {
  l.log('Caught interrupt signal, shutting down');

  await client.stop();

  process.exit(0);
});