gecko-dev/remote/sessions/Session.jsm

/* This Source Code Form is subject to the terms of the Mozilla Public
 * License, v. 2.0. If a copy of the MPL was not distributed with this
 * file, You can obtain one at http://mozilla.org/MPL/2.0/. */

"use strict";

var EXPORTED_SYMBOLS = ["Session"];

const {ParentProcessDomains} = ChromeUtils.import("chrome://remote/content/domains/ParentProcessDomains.jsm");
const {Domains} = ChromeUtils.import("chrome://remote/content/domains/Domains.jsm");
const {RemoteAgentError} = ChromeUtils.import("chrome://remote/content/Error.jsm");

/**
 * A session represents exactly one client WebSocket connection.
 *
 * Every new WebSocket connections is associated with one session that
 * deals with dispatching incoming command requests to the right
 * target, sending back responses, and propagating events originating
 * from domains.
 * Then, some subsequent Sessions may be created over a single WebSocket
 * connection. In this case, the subsequent session will have an `id`
 * being passed to their constructor and each packet of these sessions
 * will have a `sessionId` attribute in order to filter the packets
 * by session both on client and server side.
 */
class Session {
  /**
   * @param Connection connection
   *        The connection used to communicate with the server.
   * @param Target target
   *        The target to which this session communicates with.
   * @param Number id (optional)
   *        If this session isn't the default one used for the HTTP endpoint we
   *        connected to, the session requires an id to distinguish it from the default
   *        one. This id is used to filter our request, responses and events between
   *        all active sessions.
   */
  constructor(connection, target, id) {
    this.connection = connection;
    this.target = target;
    this.id = id;

    this.destructor = this.destructor.bind(this);

    this.connection.registerSession(this);
    this.connection.transport.on("close", this.destructor);

    this.domains = new Domains(this, ParentProcessDomains);
  }

  destructor() {
    this.domains.clear();
  }

  async onMessage({id, method, params}) {
    try {
      if (typeof id == "undefined") {
        throw new TypeError("Message missing 'id' field");
      }
      if (typeof method == "undefined") {
        throw new TypeError("Message missing 'method' field");
      }

      const {domain, command} = Domains.splitMethod(method);
      await this.execute(id, domain, command, params);
    } catch (e) {
      this.onError(id, e);
    }
  }

  async execute(id, domain, command, params) {
    const inst = this.domains.get(domain);
    const result = await inst[command](params);
    this.onResult(id, result);
  }

  onResult(id, result) {
    this.connection.send({
      id,
      sessionId: this.id,
      result,
    });
  }

  onError(id, error) {
    this.connection.send({
      id,
      sessionId: this.id,
      error: {
        message: RemoteAgentError.format(error, {stack: true}),
      },
    });
  }

  // Domain event listener

  onEvent(eventName, params) {
    this.connection.send({
      sessionId: this.id,
      method: eventName,
      params,
    });
  }

  toString() {
    return `[object ${this.constructor.name} ${this.connection.id}]`;
  }
}