aullman/opentok-meet

const OpenTok = require('opentok');

module.exports = (redis, ot) => {
  const roomStore = {
    isP2P(room) {
      return room.toLowerCase().indexOf('p2p') >= 0;
    },
    getRooms(callback) {
      redis.hkeys('rooms', callback);
    },
    getRoom(room, apiKey, secret) {
      console.log(`getRoom: ${room} ${apiKey} ${secret}`);
      const goToRoom = arguments[arguments.length - 1]; // eslint-disable-line
      // Lookup the mapping of rooms to sessionIds
      redis.hget('rooms', room, (err, sid) => {
        let sessionId = sid;
        if (!sessionId) {
          const props = {
            mediaMode: 'routed',
          };
          if (roomStore.isP2P(room)) {
            props.mediaMode = 'relayed';
          }
          let otSDK = ot;
          // If there's a custom apiKey and secret use that
          if (apiKey && secret) {
            otSDK = new OpenTok(apiKey, secret);
          }
          // Create the session
          otSDK.createSession(props, (createErr, session) => {
            if (createErr) {
              goToRoom(createErr);
            } else {
              ({ sessionId } = session);
              // Store the room to sessionId mapping
              redis.hset('rooms', room, sessionId, (setErr) => {
                if (setErr) {
                  console.error('Failed to set room', setErr);
                  goToRoom(setErr);
                } else if (apiKey && secret) {
                  // If there's a custom apiKey and secret store that
                  redis.hset(
                    'apiKeys', room, JSON.stringify({
                      apiKey,
                      secret,
                    }),
                    (apiKeyErr) => {
                      if (apiKeyErr) {
                        console.error('Failed to set apiKey', apiKeyErr);
                        goToRoom(apiKeyErr);
                      } else {
                        goToRoom(null, sessionId, apiKey, secret);
                      }
                    }
                  );
                } else {
                  goToRoom(null, sessionId);
                }
              });
            }
          });
        } else {
          // Lookup if there's a custom apiKey for this room
          redis.hget('apiKeys', room, (getErr, apiKeySecret) => {
            if (getErr || !apiKeySecret) {
              goToRoom(null, sessionId);
            } else {
              const parsedApiKeySecret = JSON.parse(apiKeySecret);
              goToRoom(null, sessionId, parsedApiKeySecret.apiKey, parsedApiKeySecret.secret);
            }
          });
        }
      });
    },
  };
  return roomStore;
};