From e20db3f5031a48c63f0a55111376e27be7cc2753 Mon Sep 17 00:00:00 2001
From: csantosm <4a.santos@gmail.com>
Date: Thu, 15 Oct 2020 16:46:53 +0200
Subject: [PATCH] openvidu-server: Added publishedAt property to participant

---
 .../main/java/io/openvidu/server/core/Participant.java   | 9 +++++++++
 .../server/kurento/core/KurentoSessionManager.java       | 2 ++
 2 files changed, 11 insertions(+)

diff --git a/openvidu-server/src/main/java/io/openvidu/server/core/Participant.java b/openvidu-server/src/main/java/io/openvidu/server/core/Participant.java
index 55678da1..ddf1e76a 100644
--- a/openvidu-server/src/main/java/io/openvidu/server/core/Participant.java
+++ b/openvidu-server/src/main/java/io/openvidu/server/core/Participant.java
@@ -63,6 +63,7 @@ public class Participant {
 	protected Integer videoHeight = 0;
 	protected Boolean videoActive = false;
 	protected Boolean audioActive = false;
+	protected Long publishedAt = null; // Timestamp when this participant was published
 
 	protected boolean streaming = false;
 	protected volatile boolean closed = false;
@@ -196,6 +197,14 @@ public class Participant {
 		return audioActive;
 	}
 
+	public void setPublishedAt(Long publishedAt) {
+		this.publishedAt = publishedAt;
+	}
+	
+	public Long getPublishedAt() {
+		return publishedAt;
+	}
+
 	public void setAudioActive(Boolean audioActive) {
 		this.audioActive = audioActive;
 	}
diff --git a/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java b/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java
index 81032cfb..8823a2db 100644
--- a/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java
+++ b/openvidu-server/src/main/java/io/openvidu/server/kurento/core/KurentoSessionManager.java
@@ -21,6 +21,7 @@ import java.io.IOException;
 import java.net.InetAddress;
 import java.net.MalformedURLException;
 import java.net.URL;
+import java.sql.Timestamp;
 import java.util.Arrays;
 import java.util.Collections;
 import java.util.HashSet;
@@ -467,6 +468,7 @@ public class KurentoSessionManager extends SessionManager {
 
 		}
 
+		participant.setPublishedAt(new Timestamp(System.currentTimeMillis()).getTime());
 		kSession.newPublisher(participant);
 
 		participants = kParticipant.getSession().getParticipants();