Class QuoteSession

src/quote/session.js:57–125

 * @param {import('../client').ClientBridge} client
 */
module.exports = (client) => class QuoteSession {
  #sessionID = genSessionID('qs');

  /** Parent client */
  #client = client;

  /** @type {SymbolListeners} */
  #symbolListeners = {};

  /**
   * @typedef {Object} quoteSessionOptions Quote Session options
   * @prop {'all' | 'price'} [fields] Asked quote fields
   * @prop {quoteField[]} [customFields] List of asked quote fields
   */

  /**
   * @param {quoteSessionOptions} options Quote settings options
   */
  constructor(options = {}) {
    this.#client.sessions[this.#sessionID] = {
      type: 'quote',
      onData: (packet) => {
        if (global.TW_DEBUG) console.log('§90§30§102 QUOTE SESSION §0 DATA', packet);

        if (packet.type === 'quote_completed') {
          const symbolKey = packet.data[1];
          if (!this.#symbolListeners[symbolKey]) {
            this.#client.send('quote_remove_symbols', [this.#sessionID, symbolKey]);
            return;
          }
          this.#symbolListeners[symbolKey].forEach((h) => h(packet));
        }

        if (packet.type === 'qsd') {
          const symbolKey = packet.data[1].n;
          if (!this.#symbolListeners[symbolKey]) {
            this.#client.send('quote_remove_symbols', [this.#sessionID, symbolKey]);
            return;
          }
          this.#symbolListeners[symbolKey].forEach((h) => h(packet));
        }
      },
    };

    const fields = (options.customFields && options.customFields.length > 0
      ? options.customFields
      : getQuoteFields(options.fields)
    );

    this.#client.send('quote_create_session', [this.#sessionID]);
    this.#client.send('quote_set_fields', [this.#sessionID, ...fields]);
  }

  /** @type {QuoteSessionBridge} */
  #quoteSession = {
    sessionID: this.#sessionID,
    symbolListeners: this.#symbolListeners,
    send: (t, p) => this.#client.send(t, p),