add logging to rest session actions

src/rest/multi.js

@@ -17,14 +17,16 @@ 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) {
+    constructor(sessions, groupName) {
+        this.log = new Logger(groupName);
         this.sessions = sessions;
     }
 
-    slice(start, end) {
-        return new RestMultiSession(this.sessions.slice(start, end));
+    slice(start, end, groupName) {
+        return new RestMultiSession(this.sessions.slice(start, end), groupName);
     }
 
     pop(userName) {
@@ -37,25 +39,52 @@ module.exports = class RestMultiSession {
     }
 
     async setDisplayName(fn) {
-        await Promise.all(this.sessions.map((s) => s.setDisplayName(fn(s))));
+        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(roomId) {
-        const rooms = await Promise.all(this.sessions.map((s) => s.join(roomId)));
-        return new RestMultiRoom(rooms);
+    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) {
+    constructor(rooms, roomIdOrAlias, log) {
         this.rooms = rooms;
+        this.roomIdOrAlias = roomIdOrAlias;
+        this.log = log;
     }
 
     async talk(message) {
-        await Promise.all(this.rooms.map((r) => r.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() {
-        await Promise.all(this.rooms.map((r) => r.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();
     }
 }