90 lines
2.6 KiB
JavaScript
90 lines
2.6 KiB
JavaScript
/*
|
|
Copyright 2018 New Vector Ltd
|
|
|
|
Licensed under the Apache License, Version 2.0 (the "License");
|
|
you may not use this file except in compliance with the License.
|
|
You may obtain a copy of the License at
|
|
|
|
http://www.apache.org/licenses/LICENSE-2.0
|
|
|
|
Unless required by applicable law or agreed to in writing, software
|
|
distributed under the License is distributed on an "AS IS" BASIS,
|
|
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
|
|
See the License for the specific language governing permissions and
|
|
limitations under the License.
|
|
*/
|
|
|
|
const request = require('request-promise-native');
|
|
const RestRoom = require('./room');
|
|
const {approveConsent} = require('./consent');
|
|
const Logger = require('../logger');
|
|
|
|
module.exports = class RestMultiSession {
|
|
constructor(sessions, groupName) {
|
|
this.log = new Logger(groupName);
|
|
this.sessions = sessions;
|
|
}
|
|
|
|
slice(groupName, start, end) {
|
|
return new RestMultiSession(this.sessions.slice(start, end), groupName);
|
|
}
|
|
|
|
pop(userName) {
|
|
const idx = this.sessions.findIndex((s) => s.userName() === userName);
|
|
if(idx === -1) {
|
|
throw new Error(`user ${userName} not found`);
|
|
}
|
|
const session = this.sessions.splice(idx, 1)[0];
|
|
return session;
|
|
}
|
|
|
|
async setDisplayName(fn) {
|
|
this.log.step("set their display name")
|
|
await Promise.all(this.sessions.map(async (s) => {
|
|
s.log.mute();
|
|
await s.setDisplayName(fn(s));
|
|
s.log.unmute();
|
|
}));
|
|
this.log.done();
|
|
}
|
|
|
|
async join(roomIdOrAlias) {
|
|
this.log.step(`join ${roomIdOrAlias}`)
|
|
const rooms = await Promise.all(this.sessions.map(async (s) => {
|
|
s.log.mute();
|
|
const room = await s.join(roomIdOrAlias);
|
|
s.log.unmute();
|
|
return room;
|
|
}));
|
|
this.log.done();
|
|
return new RestMultiRoom(rooms, roomIdOrAlias, this.log);
|
|
}
|
|
}
|
|
|
|
class RestMultiRoom {
|
|
constructor(rooms, roomIdOrAlias, log) {
|
|
this.rooms = rooms;
|
|
this.roomIdOrAlias = roomIdOrAlias;
|
|
this.log = log;
|
|
}
|
|
|
|
async talk(message) {
|
|
this.log.step(`say "${message}" in ${this.roomIdOrAlias}`)
|
|
await Promise.all(this.rooms.map(async (r) => {
|
|
r.log.mute();
|
|
await r.talk(message);
|
|
r.log.unmute();
|
|
}));
|
|
this.log.done();
|
|
}
|
|
|
|
async leave() {
|
|
this.log.step(`leave ${this.roomIdOrAlias}`)
|
|
await Promise.all(this.rooms.map(async (r) => {
|
|
r.log.mute();
|
|
await r.leave(message);
|
|
r.log.unmute();
|
|
}));
|
|
this.log.done();
|
|
}
|
|
}
|