/*!
 * plugin.js - wallet plugin for bcoin
 * Copyright (c) 2014-2017, Christopher Jeffrey (MIT License).
 * https://github.com/bcoin-org/bcoin
 */

'use strict';

const EventEmitter = require('events');
const WalletDB = require('./walletdb');
const NodeClient = require('./nodeclient');
const HTTP = require('./http');
const RPC = require('./rpc');

/**
 * @exports wallet/plugin
 */

const plugin = exports;

/**
 * Plugin
 * @extends EventEmitter
 */

class Plugin extends EventEmitter {
  /**
   * Create a plugin.
   * @constructor
   * @param {Node} node
   */

  constructor(node) {
    super();

    const config = node.config;

    this.network = node.network;
    this.logger = node.logger;

    this.client = new NodeClient(node);

    this.wdb = new WalletDB({
      network: node.network,
      logger: node.logger,
      workers: node.workers,
      client: this.client,
      prefix: config.prefix,
      memory: config.bool(['wallet-memory', 'memory']),
      maxFiles: config.uint('wallet-max-files'),
      cacheSize: config.mb('wallet-cache-size'),
      witness: config.bool('wallet-witness'),
      checkpoints: config.bool('wallet-checkpoints'),
      wipeNoReally: config.bool('wallet-wipe-no-really'),
      spv: node.spv
    });

    this.rpc = new RPC(this);

    this.http = new HTTP({
      network: node.network,
      logger: node.logger,
      node: this,
      ssl: config.bool(['wallet-ssl', 'ssl']),
      keyFile: config.path(['wallet-ssl-key', 'ssl-key']),
      certFile: config.path(['wallet-ssl-cert', 'ssl-cert']),
      host: config.str(['wallet-http-host', 'http-host']),
      port: config.uint(['wallet-http-port', 'http-port']),
      apiKey: config.str(['wallet-api-key', 'api-key']),
      walletAuth: config.bool('wallet-auth'),
      noAuth: config.bool(['wallet-no-auth', 'no-auth'])
    });

    this.init();
  }

  init() {
    this.wdb.on('error', err => this.emit('error', err));
    this.http.on('error', err => this.emit('error', err));
  }

  async open() {
    await this.wdb.open();
    this.rpc.wallet = this.wdb.primary;
    await this.http.open();
  }

  async close() {
    await this.http.close();
    this.rpc.wallet = null;
    await this.wdb.close();
  }
}

/**
 * Plugin name.
 * @const {String}
 */

plugin.id = 'walletdb';

/**
 * Plugin initialization.
 * @param {Node} node
 * @returns {WalletDB}
 */

plugin.init = function init(node) {
  return new Plugin(node);
};