MyCrypto/common/vendor/trezor-connect.js

/* prettier-ignore */
/* eslint-ignore */

/**
 * (C) 2017 SatoshiLabs
 *
 * GPLv3
 */
var VERSION = 3;

if (!Array.isArray) {
  Array.isArray = function(arg) {
    return Object.prototype.toString.call(arg) === '[object Array]';
  };
}

var HD_HARDENED = 0x80000000;

// react sometimes adds some other parameters that should not be there
function _fwStrFix(obj, fw) {
  if (typeof fw === 'string') {
    obj.requiredFirmware = fw;
  }
  return obj;
}

('use strict');

var chrome = window.chrome;
var IS_CHROME_APP = chrome && chrome.app && chrome.app.window;

var ERR_TIMED_OUT = 'Loading timed out';
var ERR_WINDOW_CLOSED = 'Window closed';
var ERR_WINDOW_BLOCKED = 'Window blocked';
var ERR_ALREADY_WAITING = 'Already waiting for a response';
var ERR_CHROME_NOT_CONNECTED = 'Internal Chrome popup is not responding.';

var DISABLE_LOGIN_BUTTONS = window.TREZOR_DISABLE_LOGIN_BUTTONS || false;
var CHROME_URL = window.TREZOR_CHROME_URL || './chrome/wrapper.html';
var POPUP_URL =
  window.TREZOR_POPUP_URL || 'https://connect.trezor.io/' + VERSION + '/popup/popup.html';
var POPUP_PATH = window.TREZOR_POPUP_PATH || 'https://connect.trezor.io/' + VERSION;
var POPUP_ORIGIN = window.TREZOR_POPUP_ORIGIN || 'https://connect.trezor.io';

var INSIGHT_URLS = window.TREZOR_INSIGHT_URLS || [
  'https://btc-bitcore1.trezor.io/api/',
  'https://btc-bitcore3.trezor.io/api/'
];

var POPUP_INIT_TIMEOUT = 15000;

/**
 * Public API.
 */

class TrezorConnect {
  constructor() {
    this.manager = new PopupManager();
    this.LOGIN_CSS = '<style>@import url("@connect_path@/login_buttons.css")</style>';
    this.LOGIN_ONCLICK =
      'TrezorConnect.requestLogin(' +
      "'@hosticon@','@challenge_hidden@','@challenge_visual@','@callback@'" +
      ')';
    this.LOGIN_HTML =
      '<div id="trezorconnect-wrapper">' +
      '  <a id="trezorconnect-button" onclick="' +
      this.LOGIN_ONCLICK +
      '">' +
      '    <span id="trezorconnect-icon"></span>' +
      '    <span id="trezorconnect-text">@text@</span>' +
      '  </a>' +
      '  <span id="trezorconnect-info">' +
      '    <a id="trezorconnect-infolink" href="https://www.buytrezor.com/"' +
      '       target="_blank">What is TREZOR?</a>' +
      '  </span>' +
      '</div>';
  }

  /**
   * Open the popup for further communication. All API functions open the
   * popup automatically, but if you need to generate some parameters
   * asynchronously, use `open` first to avoid popup blockers.
   * @param {function(?Error)} callback
   */
  open(callback) {
    var onchannel = function(result) {
      if (result instanceof Error) {
        callback(result);
      } else {
        callback();
      }
    };
    this.manager.waitForChannel(onchannel);
  }

  /**
   * Close the opened popup, if any.
   */
  close() {
    this.manager.close();
  }

  /**
   * Enable or disable closing the opened popup after a successful call.
   * @param {boolean} value
   */
  closeAfterSuccess(value) {
    this.manager.closeAfterSuccess = value;
  }

  /**
   * Enable or disable closing the opened popup after a failed call.
   * @param {boolean} value
   */
  closeAfterFailure(value) {
    this.manager.closeAfterFailure = value;
  }

  /**
   * Set bitcore server
   * @param {string|Array<string>} value
   */
  setBitcoreURLS(value) {
    if (typeof value === 'string') {
      this.manager.bitcoreURLS = [value];
    } else if (value instanceof Array) {
      this.manager.bitcoreURLS = value;
    }
  }

  /**
   * Set max. limit for account discovery
   * @param {number} value
   */
  setAccountDiscoveryLimit(value) {
    if (!isNaN(value)) this.manager.accountDiscoveryLimit = value;
  }

  /**
   * Set max. gap for account discovery
   * @param {number} value
   */
  setAccountDiscoveryGapLength(value) {
    if (!isNaN(value)) this.manager.accountDiscoveryGapLength = value;
  }

  /**
   * Set discovery BIP44 coin type
   * @param {number} value
   */
  setAccountDiscoveryBip44CoinType(value) {
    if (!isNaN(value)) this.manager.accountDiscoveryBip44CoinType = value;
  }

  /**
   * @typedef XPubKeyResult
   * @param {boolean} success
   * @param {?string} error
   * @param {?string} xpubkey  serialized extended public key
   * @param {?string} path     BIP32 serializd path of the key
   */

  /**
   * Load BIP32 extended public key by path.
   *
   * Path can be specified either in the string form ("m/44'/1/0") or as
   * raw integer array. In case you omit the path, user is asked to select
   * a BIP32 account to export, and the result contains m/44'/0'/x' node
   * of the account.
   *
   * @param {?(string|array<number>)} path
   * @param {function(XPubKeyResult)} callback
   * @param {?(string|array<number>)} requiredFirmware
   */
  getXPubKey(path, callback, requiredFirmware) {
    if (typeof path === 'string') {
      path = parseHDPath(path);
    }
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'xpubkey',
          path: path
        },
        requiredFirmware
      ),
      callback
    );
  }

  getFreshAddress(callback, requiredFirmware) {
    var wrapperCallback = function(result) {
      if (result.success) {
        callback({ success: true, address: result.freshAddress });
      } else {
        callback(result);
      }
    };

    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'accountinfo'
        },
        requiredFirmware
      ),
      wrapperCallback
    );
  }

  getAccountInfo(input, callback, requiredFirmware) {
    try {
      var description = parseAccountInfoInput(input);
      this.manager.sendWithChannel(
        _fwStrFix(
          {
            type: 'accountinfo',
            description: description
          },
          requiredFirmware
        ),
        callback
      );
    } catch (e) {
      callback({ success: false, error: e });
    }
  }

  getAllAccountsInfo(callback, requiredFirmware) {
    try {
      this.manager.sendWithChannel(
        _fwStrFix(
          {
            type: 'allaccountsinfo',
            description: 'all'
          },
          requiredFirmware
        ),
        callback
      );
    } catch (e) {
      callback({ success: false, error: e });
    }
  }

  getBalance(callback, requiredFirmware) {
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'accountinfo'
        },
        requiredFirmware
      ),
      callback
    );
  }

  /**
   * @typedef SignTxResult
   * @param {boolean} success
   * @param {?string} error
   * @param {?string} serialized_tx      serialized tx, in hex, including signatures
   * @param {?array<string>} signatures  array of input signatures, in hex
   */

  /**
   * Sign a transaction in the device and return both serialized
   * transaction and the signatures.
   *
   * @param {array<TxInputType>} inputs
   * @param {array<TxOutputType>} outputs
   * @param {function(SignTxResult)} callback
   * @param {?(string|array<number>)} requiredFirmware
   *
   * @see https://github.com/trezor/trezor-common/blob/master/protob/types.proto
   */
  signTx(inputs, outputs, callback, requiredFirmware, coin) {
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'signtx',
          inputs: inputs,
          outputs: outputs,
          coin: coin
        },
        requiredFirmware
      ),
      callback
    );
  }

  // new implementation with ethereum at beginnig
  ethereumSignTx() {
    this.signEthereumTx.apply(this, arguments);
  }

  // old fallback
  signEthereumTx(
    address_n,
    nonce,
    gas_price,
    gas_limit,
    to,
    value,
    data,
    chain_id,
    callback,
    requiredFirmware
  ) {
    if (requiredFirmware == null) {
      requiredFirmware = '1.4.0'; // first firmware that supports ethereum
    }
    if (typeof address_n === 'string') {
      address_n = parseHDPath(address_n);
    }
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'signethtx',
          address_n: address_n,
          nonce: nonce,
          gas_price: gas_price,
          gas_limit: gas_limit,
          to: to,
          value: value,
          data: data,
          chain_id: chain_id
        },
        requiredFirmware
      ),
      callback
    );
  }

  /**
   * @typedef TxRecipient
   * @param {number} amount   the amount to send, in satoshis
   * @param {string} address  the address of the recipient
   */

  /**
   * Compose a transaction by doing BIP-0044 discovery, letting the user
   * select an account, and picking UTXO by internal preferences.
   * Transaction is then signed and returned in the same format as
   * `signTx`.  Only supports BIP-0044 accounts (single-signature).
   *
   * @param {array<TxRecipient>} recipients
   * @param {function(SignTxResult)} callback
   * @param {?(string|array<number>)} requiredFirmware
   */
  composeAndSignTx(recipients, callback, requiredFirmware) {
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'composetx',
          recipients: recipients
        },
        requiredFirmware
      ),
      callback
    );
  }

  /**
   * @typedef RequestLoginResult
   * @param {boolean} success
   * @param {?string} error
   * @param {?string} public_key  public key used for signing, in hex
   * @param {?string} signature   signature, in hex
   */

  /**
   * Sign a login challenge for active origin.
   *
   * @param {?string} hosticon
   * @param {string} challenge_hidden
   * @param {string} challenge_visual
   * @param {string|function(RequestLoginResult)} callback
   * @param {?(string|array<number>)} requiredFirmware
   *
   * @see https://github.com/trezor/trezor-common/blob/master/protob/messages.proto
   */
  requestLogin(hosticon, challenge_hidden, challenge_visual, callback, requiredFirmware) {
    if (typeof callback === 'string') {
      // special case for a login through <trezor:login> button.
      // `callback` is name of global var
      callback = window[callback];
    }
    if (!callback) {
      throw new TypeError('TrezorConnect: login callback not found');
    }
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'login',
          icon: hosticon,
          challenge_hidden: challenge_hidden,
          challenge_visual: challenge_visual
        },
        requiredFirmware
      ),
      callback
    );
  }

  /**
   * @typedef SignMessageResult
   * @param {boolean} success
   * @param {?string} error
   * @param {?string} address address (in base58check)
   * @param {?string} signature   signature, in base64
   */

  /**
   * Sign a message
   *
   * @param {string|array} path
   * @param {string} message to sign (ascii)
   * @param {string|function(SignMessageResult)} callback
   * @param {?string} opt_coin - (optional) name of coin (default Bitcoin)
   * @param {?(string|array<number>)} requiredFirmware
   *
   */
  signMessage(path, message, callback, opt_coin, requiredFirmware) {
    if (typeof path === 'string') {
      path = parseHDPath(path);
    }
    if (!opt_coin) {
      opt_coin = 'Bitcoin';
    }
    if (!callback) {
      throw new TypeError('TrezorConnect: callback not found');
    }
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'signmsg',
          path: path,
          message: message,
          coin: { coin_name: opt_coin }
        },
        requiredFirmware
      ),
      callback
    );
  }

  /**
   * Sign an Ethereum message
   *
   * @param {string|array} path
   * @param {string} message to sign (ascii)
   * @param {string|function(SignMessageResult)} callback
   * @param {?(string|array<number>)} requiredFirmware
   *
   */
  ethereumSignMessage(path, message, callback, requiredFirmware) {
    if (typeof path === 'string') {
      path = parseHDPath(path);
    }
    if (!callback) {
      throw new TypeError('TrezorConnect: callback not found');
    }
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'signethmsg',
          path: path,
          message: message
        },
        requiredFirmware
      ),
      callback
    );
  }

  /**
   * Verify message
   *
   * @param {string} address
   * @param {string} signature (base64)
   * @param {string} message (string)
   * @param {string|function()} callback
   * @param {?string} opt_coin - (optional) name of coin (default Bitcoin)
   * @param {?(string|array<number>)} requiredFirmware
   *
   */
  verifyMessage(address, signature, message, callback, opt_coin, requiredFirmware) {
    if (!opt_coin) {
      opt_coin = 'Bitcoin';
    }
    if (!callback) {
      throw new TypeError('TrezorConnect: callback not found');
    }
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'verifymsg',
          address: address,
          signature: signature,
          message: message,
          coin: { coin_name: opt_coin }
        },
        requiredFirmware
      ),
      callback
    );
  }

  /**
   * Verify ethereum message
   *
   * @param {string} address
   * @param {string} signature (base64)
   * @param {string} message (string)
   * @param {string|function()} callback
   * @param {?(string|array<number>)} requiredFirmware
   *
   */
  ethereumVerifyMessage(address, signature, message, callback, requiredFirmware) {
    if (!callback) {
      throw new TypeError('TrezorConnect: callback not found');
    }
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'verifyethmsg',
          address: address,
          signature: signature,
          message: message
        },
        requiredFirmware
      ),
      callback
    );
  }

  /**
   * Symmetric key-value encryption
   *
   * @param {string|array} path
   * @param {string} key to show on device display
   * @param {string} value hexadecimal value, length a multiple of 16 bytes
   * @param {boolean} encrypt / decrypt direction
   * @param {boolean} ask_on_encrypt (should user confirm on encrypt?)
   * @param {boolean} ask_on_decrypt (should user confirm on decrypt?)
   * @param {string|function()} callback
   * @param {?(string|array<number>)} requiredFirmware
   *
   */
  cipherKeyValue(
    path,
    key,
    value,
    encrypt,
    ask_on_encrypt,
    ask_on_decrypt,
    callback,
    requiredFirmware
  ) {
    if (typeof path === 'string') {
      path = parseHDPath(path);
    }
    if (typeof value !== 'string') {
      throw new TypeError('TrezorConnect: Value must be a string');
    }
    if (!/^[0-9A-Fa-f]*$/.test(value)) {
      throw new TypeError('TrezorConnect: Value must be hexadecimal');
    }
    if (value.length % 32 !== 0) {
      // 1 byte == 2 hex strings
      throw new TypeError('TrezorConnect: Value length must be multiple of 16 bytes');
    }
    if (!callback) {
      throw new TypeError('TrezorConnect: callback not found');
    }
    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'cipherkeyvalue',
          path: path,
          key: key,
          value: value,
          encrypt: !!encrypt,
          ask_on_encrypt: !!ask_on_encrypt,
          ask_on_decrypt: !!ask_on_decrypt
        },
        requiredFirmware
      ),
      callback
    );
  }

  pushTransaction(rawTx, callback) {
    if (!/^[0-9A-Fa-f]*$/.test(rawTx)) {
      throw new TypeError('TrezorConnect: Transaction must be hexadecimal');
    }
    if (!callback) {
      throw new TypeError('TrezorConnect: callback not found');
    }

    var tryUrl = function(i) {
      var insight_url = INSIGHT_URLS[i];
      var xhr = new XMLHttpRequest();
      var method = 'POST';
      var url = insight_url + '/tx/send';
      var data = {
        rawtx: rawTx
      };

      xhr.open(method, url, true);
      xhr.setRequestHeader('Content-Type', 'application/json');
      xhr.onreadystatechange = function() {
        if (xhr.readyState === XMLHttpRequest.DONE) {
          if (xhr.status === 200) {
            var txid = JSON.parse(xhr.responseText).txid;
            callback({ success: true, txid: txid });
          } else {
            if (i === INSIGHT_URLS.length - 1) {
              callback({ error: new Error(xhr.responseText) });
            } else {
              tryUrl(i + 1);
            }
          }
        }
      };
      xhr.send(JSON.stringify(data));
    };

    tryUrl(0);
  }

  /**
   * Display address on device
   *
   * @param {array} address
   * @param {string} coin
   * @param {boolean} segwit
   * @param {?(string|array<number>)} requiredFirmware
   *
   */
  getAddress(address, coin, segwit, callback, requiredFirmware) {
    if (typeof address === 'string') {
      address = parseHDPath(address);
    }

    this.manager.sendWithChannel(
      _fwStrFix(
        {
          type: 'getaddress',
          address_n: address,
          coin: coin,
          segwit: segwit
        },
        requiredFirmware
      ),
      callback
    );
  }

  /**
   * Display ethereum address on device
   *
   * @param {string|array} address
   * @param {string|array<number>} requiredFirmware
   * @param {function()} callback
   *
   */
  ethereumGetAddress(address, requiredFirmware = undefined) {
    if (typeof address === 'string') {
      address = parseHDPath(address);
    }
    return new Promise((resolve, reject) => {
      this.manager.sendWithChannel(
        _fwStrFix(
          {
            type: 'ethgetaddress',
            address_n: address
          },
          requiredFirmware
        ),
        response => {
          if (response.error) {
            reject(response.error.message);
          } else {
            resolve(response);
          }
        }
      );
    });
  }

  /**
   * Find <trezor:login> elements and replace them with login buttons.
   * It's not required to use these special elements, feel free to call
   * `TrezorConnect.requestLogin` directly.
   */
  renderLoginButtons() {
    var elements = document.getElementsByTagName('trezor:login');

    for (var i = 0; i < elements.length; i++) {
      var e = elements[i];
      var text = e.getAttribute('text') || 'Sign in with TREZOR';
      var callback = e.getAttribute('callback') || '';
      var hosticon = e.getAttribute('icon') || '';
      var challenge_hidden = e.getAttribute('challenge_hidden') || '';
      var challenge_visual = e.getAttribute('challenge_visual') || '';

      // it's not valid to put markup into attributes, so let users
      // supply a raw text and make TREZOR bold
      text = text.replace('TREZOR', '<strong>TREZOR</strong>');
      e.outerHTML = (this.LOGIN_CSS + this.LOGIN_HTML)
        .replace('@text@', text)
        .replace('@callback@', callback)
        .replace('@hosticon@', hosticon)
        .replace('@challenge_hidden@', challenge_hidden)
        .replace('@challenge_visual@', challenge_visual)
        .replace('@connect_path@', POPUP_PATH);
    }
  }
}

/*
  * `getXPubKey()`
  */

function parseHDPath(string) {
  return string
    .toLowerCase()
    .split('/')
    .filter(function(p) {
      return p !== 'm';
    })
    .map(function(p) {
      var hardened = false;
      if (p[p.length - 1] === "'") {
        hardened = true;
        p = p.substr(0, p.length - 1);
      }
      if (isNaN(p)) {
        throw new Error('Not a valid path.');
      }
      var n = parseInt(p);
      if (hardened) {
        // hardened index
        n = (n | 0x80000000) >>> 0;
      }
      return n;
    });
}

function getIdFromPath(path) {
  if (path.length !== 3) {
    throw new Error();
  }
  if (path[0] >>> 0 !== (44 | HD_HARDENED) >>> 0) {
    throw new Error();
  }
  if (path[1] >>> 0 !== (0 | HD_HARDENED) >>> 0) {
    throw new Error();
  }
  return (path[2] & ~HD_HARDENED) >>> 0;
}

// parses first argument from getAccountInfo
function parseAccountInfoInput(input) {
  if (input == null) {
    return null;
  }

  if (typeof input === 'string') {
    if (input.substr(0, 4) === 'xpub') {
      return input;
    }
    if (isNaN(input)) {
      var parsedPath = parseHDPath(input);
      return getIdFromPath(parsedPath);
    } else {
      return parseInt(input);
    }
  } else if (Array.isArray(input)) {
    return getIdFromPath(input);
  } else if (typeof input === 'number') {
    return input;
  }
  throw new Error('Unknown input format.');
}

/*
  * Popup management
  */

function ChromePopup(url, name, width, height) {
  var left = (screen.width - width) / 2;
  var top = (screen.height - height) / 2;
  var opts = {
    id: name,
    innerBounds: {
      width: width,
      height: height,
      left: left,
      top: top
    }
  };

  var closed = function() {
    if (this.onclose) {
      this.onclose(false); // never report as blocked
    }
  }.bind(this);

  var opened = function(w) {
    this.window = w;
    this.window.onClosed.addListener(closed);
  }.bind(this);

  chrome.app.window.create(url, opts, opened);

  this.name = name;
  this.window = null;
  this.onclose = null;
}

function ChromeChannel(popup, waiting) {
  var port = null;

  var respond = function(data) {
    if (waiting) {
      var w = waiting;
      waiting = null;
      w(data);
    }
  };

  var setup = function(p) {
    if (p.name === popup.name) {
      port = p;
      port.onMessage.addListener(respond);
      chrome.runtime.onConnect.removeListener(setup);
    }
  };

  chrome.runtime.onConnect.addListener(setup);

  this.respond = respond;

  this.close = function() {
    chrome.runtime.onConnect.removeListener(setup);
    port.onMessage.removeListener(respond);
    port.disconnect();
    port = null;
  };

  this.send = function(value, callback) {
    if (waiting === null) {
      waiting = callback;

      if (port) {
        port.postMessage(value);
      } else {
        throw new Error(ERR_CHROME_NOT_CONNECTED);
      }
    } else {
      throw new Error(ERR_ALREADY_WAITING);
    }
  };
}

function Popup(url, origin, name, width, height) {
  var left = (screen.width - width) / 2;
  var top = (screen.height - height) / 2;
  var opts =
    'width=' +
    width +
    ',height=' +
    height +
    ',left=' +
    left +
    ',top=' +
    top +
    ',menubar=no' +
    ',toolbar=no' +
    ',location=no' +
    ',personalbar=no' +
    ',status=no';
  var w = window.open(url, name, opts);

  var interval;
  var blocked = w.closed;
  var iterate = function() {
    if (w.closed) {
      clearInterval(interval);
      if (this.onclose) {
        this.onclose(blocked);
      }
    }
  }.bind(this);
  interval = setInterval(iterate, 100);

  this.window = w;
  this.origin = origin;
  this.onclose = null;
}

function Channel(popup, waiting) {
  var respond = function(data) {
    if (waiting) {
      var w = waiting;
      waiting = null;
      w(data);
    }
  };

  var receive = function(event) {
    if (event.source === popup.window && event.origin === popup.origin) {
      respond(event.data);
    }
  };

  window.addEventListener('message', receive);

  this.respond = respond;

  this.close = function() {
    window.removeEventListener('message', receive);
  };

  this.send = function(value, callback) {
    if (waiting === null) {
      waiting = callback;
      popup.window.postMessage(value, popup.origin);
    } else {
      throw new Error(ERR_ALREADY_WAITING);
    }
  };
}

function ConnectedChannel(p) {
  var ready = function() {
    clearTimeout(this.timeout);
    this.popup.onclose = null;
    this.ready = true;
    this.onready();
  }.bind(this);

  var closed = function(blocked) {
    clearTimeout(this.timeout);
    this.channel.close();
    if (blocked) {
      this.onerror(new Error(ERR_WINDOW_BLOCKED));
    } else {
      this.onerror(new Error(ERR_WINDOW_CLOSED));
    }
  }.bind(this);

  var timedout = function() {
    this.popup.onclose = null;
    if (this.popup.window) {
      this.popup.window.close();
    }
    this.channel.close();
    this.onerror(new Error(ERR_TIMED_OUT));
  }.bind(this);

  if (IS_CHROME_APP) {
    this.popup = new ChromePopup(p.chromeUrl, p.name, p.width, p.height);
    this.channel = new ChromeChannel(this.popup, ready);
  } else {
    this.popup = new Popup(p.url, p.origin, p.name, p.width, p.height);
    this.channel = new Channel(this.popup, ready);
  }

  this.timeout = setTimeout(timedout, POPUP_INIT_TIMEOUT);

  this.popup.onclose = closed;

  this.ready = false;
  this.onready = null;
  this.onerror = null;
}

function PopupManager() {
  var cc = null;

  var closed = function() {
    cc.channel.respond(new Error(ERR_WINDOW_CLOSED));
    cc.channel.close();
    cc = null;
  };

  var open = function(callback) {
    cc = new ConnectedChannel({
      name: 'trezor-connect',
      width: 600,
      height: 500,
      origin: POPUP_ORIGIN,
      path: POPUP_PATH,
      url: POPUP_URL,
      chromeUrl: CHROME_URL
    });
    cc.onready = function() {
      cc.popup.onclose = closed;
      callback(cc.channel);
    };
    cc.onerror = function(error) {
      cc = null;
      callback(error);
    };
  }.bind(this);

  this.closeAfterSuccess = true;
  this.closeAfterFailure = true;

  this.close = function() {
    if (cc && cc.popup.window) {
      cc.popup.window.close();
    }
  };

  this.waitForChannel = function(callback) {
    if (cc) {
      if (cc.ready) {
        callback(cc.channel);
      } else {
        callback(new Error(ERR_ALREADY_WAITING));
      }
    } else {
      try {
        open(callback);
      } catch (e) {
        callback(new Error(ERR_WINDOW_BLOCKED));
      }
    }
  };

  this.sendWithChannel = function(message, callback) {
    message.bitcoreURLS = this.bitcoreURLS || null;
    message.accountDiscoveryLimit = this.accountDiscoveryLimit || null;
    message.accountDiscoveryGapLength = this.accountDiscoveryGapLength || null;
    message.accountDiscoveryBip44CoinType = this.accountDiscoveryBip44CoinType || null;

    var respond = function(response) {
      var succ = response.success && this.closeAfterSuccess;
      var fail = !response.success && this.closeAfterFailure;
      if (succ || fail) {
        this.close();
      }
      callback(response);
    }.bind(this);

    var onresponse = function(response) {
      if (response instanceof Error) {
        var error = response;
        respond({ success: false, error: error.message });
      } else {
        respond(response);
      }
    };

    var onchannel = function(channel) {
      if (channel instanceof Error) {
        var error = channel;
        respond({ success: false, error: error.message });
      } else {
        channel.send(message, onresponse);
      }
    };

    this.waitForChannel(onchannel);
  };
}

var connect = new TrezorConnect();

module.exports = connect;