Add conference duration timer, get conference started timestamp (#1014)

JitsiConferenceEventManager.js

@@ -633,6 +633,11 @@ JitsiConferenceEventManager.prototype.setupXMPPListeners = function() {
 
             conference.eventEmitter.emit(JitsiConferenceEvents.STARTED_MUTED);
         });
+
+    this._addConferenceXMPPListener(XMPPEvents.CONFERENCE_TIMESTAMP_RECEIVED,
+        createdTimestamp => {
+            conference.eventEmitter.emit(JitsiConferenceEvents.CONFERENCE_CREATED_TIMESTAMP, createdTimestamp);
+        });
 };
 
 /**

JitsiConferenceEvents.js

@@ -75,6 +75,11 @@ export const DISPLAY_NAME_CHANGED = 'conference.displayNameChanged';
  */
 export const DOMINANT_SPEAKER_CHANGED = 'conference.dominantSpeaker';
 
+/**
+ * UTC conference timestamp when first participant joined.
+ */
+export const CONFERENCE_CREATED_TIMESTAMP = 'conference.createdTimestamp';
+
 /**
  * Indicates that DTMF support changed.
  */

modules/xmpp/xmpp.js

@@ -206,12 +206,19 @@ export default class XMPP extends Listenable {
                     identities.forEach(identity => {
                         if (identity.type === 'speakerstats') {
                             this.speakerStatsComponentAddress = identity.name;
+                        }
 
-                            this.connection.addHandler(
-                                this._onPrivateMessage.bind(this), null,
-                                'message', null, null);
+                        if (identity.type === 'conference_duration') {
+                            this.conferenceDurationComponentAddress = identity.name;
                         }
                     });
+
+                    if (this.speakerStatsComponentAddress
+                        || this.conferenceDurationComponentAddress) {
+                        this.connection.addHandler(
+                            this._onPrivateMessage.bind(this), null,
+                            'message', null, null);
+                    }
                 })
                 .catch(error => {
                     const errmsg = 'Feature discovery error';
@@ -713,7 +720,7 @@ export default class XMPP extends Listenable {
 
     /**
      * A private message is received, message that is not addressed to the muc.
-     * We expect private message coming from speaker stats component if it is
+     * We expect private message coming from plugins component if it is
      * enabled and running.
      *
      * @param {string} msg - The message.
@@ -721,8 +728,8 @@ export default class XMPP extends Listenable {
     _onPrivateMessage(msg) {
         const from = msg.getAttribute('from');
 
-        if (!this.speakerStatsComponentAddress
-            || from !== this.speakerStatsComponentAddress) {
+        if (!(from === this.speakerStatsComponentAddress
+            || from === this.conferenceDurationComponentAddress)) {
             return;
         }
 
@@ -737,6 +744,13 @@ export default class XMPP extends Listenable {
                 XMPPEvents.SPEAKER_STATS_RECEIVED, parsedJson.users);
         }
 
+        if (parsedJson
+            && parsedJson[JITSI_MEET_MUC_TYPE] === 'conference_duration'
+            && parsedJson.created_timestamp) {
+            this.eventEmitter.emit(
+                XMPPEvents.CONFERENCE_TIMESTAMP_RECEIVED, parsedJson.created_timestamp);
+        }
+
         return true;
     }
 }

service/xmpp/XMPPEvents.js

@@ -211,6 +211,11 @@ const XMPPEvents = {
      */
     SPEAKER_STATS_RECEIVED: 'xmpp.speaker_stats_received',
 
+    /**
+     * Event fired when conference creation timestamp is received.
+     */
+    CONFERENCE_TIMESTAMP_RECEIVED: 'xmpp.conference_timestamp_received',
+
     // Designates an event indicating that we should join the conference with
     // audio and/or video muted.
     START_MUTED_FROM_FOCUS: 'xmpp.start_muted_from_focus',