Source: components/bridge-context.js

  1. const Promise = require("bluebird");
  3. const MatrixUser = require("../models/users/matrix");
  4. const MatrixRoom = require("../models/rooms/matrix");
  6. /**
  7.  * Bridge context.
  8.  *
  9.  * @property {Object} senders Data models on senders of this event
  10.  * @property {MatrixUser} senders.matrix The sender of this event
  11.  * @property {?RemoteUser} senders.remote The first linked remote sender: remotes[0]
  12.  * @property {RemoteUser[]} senders.remotes The linked remote senders
  13.  * @property {Object} targets Data models on targets (e.g. state_key in
  14.  * m.room.member) of this event.
  15.  * @property {?MatrixUser} targets.matrix The target of this event if applicable.
  16.  * @property {?RemoteUser} targets.remote The first linked remote target: remotes[0]
  17.  * @property {RemoteUser[]} targets.remotes The linked remote targets
  18.  * @property {Object} rooms Data models on rooms concerning this event.
  19.  * @property {MatrixRoom} rooms.matrix The room for this event.
  20.  * @property {?RemoteRoom} rooms.remote The first linked remote room: remotes[0]
  21.  * @property {RemoteRoom[]} rooms.remotes The linked remote rooms for this event
  22.  */
  23. class BridgeContext {
  24.     /**
  25.      * @param {Object} ctx Event related data
  26.      * @param {string} ctx.sender Matrix user ID of the sender.
  27.      * @param {string=} ctx.target Matrix user ID of the target.
  28.      * @param {string} ctx.room Matrix room ID.
  29.      */
  30.     constructor(ctx) {
  31.         this._ctx = ctx;
  32.         this.senders = {
  33.             matrix: new MatrixUser(ctx.sender),
  34.             remote: null,
  35.             remotes: [],
  36.         };
  37.         this.targets = {
  38.             matrix: ctx.target ? new MatrixUser(ctx.target) : null,
  39.             remote: null,
  40.             remotes: [],
  41.         };
  42.         this.rooms = {
  43.             matrix: new MatrixRoom(ctx.room),
  44.             remote: null,
  45.             remotes: [],
  46.         };
  47.     }
  49.     /**
  50.      * Returns this instance after its initialization.
  51.      *
  52.      * @param {RoomBridgeStore} roomStore
  53.      * @param {UserBridgeStore} userStore
  54.      * @returns {Promise<BridgeContext>}
  55.      */
  56.     async get(roomStore, userStore) {
  57.         return Promise.try(() => {
  58.             return [
  59.                 roomStore.getLinkedRemoteRooms(this._ctx.room),
  60.                 userStore.getRemoteUsersFromMatrixId(this._ctx.sender),
  61.                 (this._ctx.target ?
  62.                     userStore.getRemoteUsersFromMatrixId(this._ctx.target) :
  63.                     Promise.resolve([])
  64.                 ),
  65.                 roomStore.getMatrixRoom(this._ctx.room),
  66.                 userStore.getMatrixUser(this._ctx.sender)
  67.             ];
  68.         }).spread((remoteRooms, remoteSenders, remoteTargets, mxRoom, mxSender) => {
  69.             if (remoteRooms.length) {
  70.                 this.rooms.remotes = remoteRooms;
  71.                 this.rooms.remote = remoteRooms[0];
  72.             }
  73.             if (remoteSenders.length) {
  74.                 this.senders.remotes = remoteSenders;
  75.                 this.senders.remote = remoteSenders[0];
  76.             }
  77.             if (remoteTargets.length) {
  78.                 this.targets.remotes = remoteTargets;
  79.                 this.targets.remote = remoteTargets[0];
  80.             }
  81.             if (mxRoom) {
  82.                 this.rooms.matrix = mxRoom;
  83.             }
  84.             if (mxSender) {
  85.                 this.senders.matrix = mxSender;
  86.             }
  87.         }).catch(e => {throw wrap(e, Error, "Could not retrieve bridge context");})
  88.         .return(this);
  89.     }
  90. }
  92. module.exports = BridgeContext;