modules/matrix-bridge/index.js

   1 'use strict';
   2
   3 const env = require('gitter-web-env');
   4 const logger = env.logger;
   5 const config = env.config;
   6 const errorReporter = env.errorReporter;
   7 const obfuscateToken = require('gitter-web-github').obfuscateToken;
   8
   9 const matrixBridge = require('./lib/matrix-bridge');
  10 const GitterBridge = require('./lib/gitter-bridge');
  11 const MatrixUtils = require('./lib/matrix-utils');
  12
  13 const bridgePortFromConfig = config.get('matrix:bridge:applicationServicePort');
  14 const hsToken = config.get('matrix:bridge:hsToken');
  15 const asToken = config.get('matrix:bridge:asToken');
  16
  17 // Ensures the bridge bot user is registered and updates its profile info.
  18 async function ensureCorrectMatrixBridgeUserProfile() {
  19   try {
  20     const matrixUtils = new MatrixUtils(matrixBridge);
  21     await matrixUtils.ensureCorrectMatrixBridgeUserProfile();
  22   } catch (err) {
  23     logger.error(`Failed to update the bridge user profile`, {
  24       exception: err
  25     });
  26     errorReporter(err, { operation: 'matrixBridge.install' }, { module: 'matrix-bridge-install' });
  27   }
  28 }
  29
  30 const gitterBridge = new GitterBridge(matrixBridge);
  31
  32 async function install(bridgePort = bridgePortFromConfig) {
  33   if (!bridgePort || !hsToken || !asToken) {
  34     logger.error(
  35       `No (bridgePort=${bridgePort}, hsToken=${obfuscateToken(hsToken)}, asToken=${obfuscateToken(
  36         asToken
  37       )}) specified for Matrix bridge so we won't start it up`
  38     );
  39     return;
  40   }
  41
  42   await matrixBridge.run(bridgePort);
  43   logger.info(`Matrix bridge listening on port ${bridgePort}`);
  44
  45   await gitterBridge.start();
  46
  47   // Fire and forget this (no need to hold up the process by awaiting it)
  48   ensureCorrectMatrixBridgeUserProfile();
  49
  50   return async function stop() {
  51     await matrixBridge.close();
  52     await gitterBridge.stop();
  53   };
  54 }
  55
  56 module.exports = install;