openvidu-server: ParticipantSummary simplified

pull/370/head
pabloFuente 2019-10-08 09:36:48 +02:00
parent d3270ca2a1
commit 97ff8426ab
3 changed files with 6 additions and 13 deletions

View File

@ -27,8 +27,8 @@ public class CDREventParticipant extends CDREventEnd {
private Participant participant;
// participantJoined
public CDREventParticipant(String sessionId, Participant participant) {
super(CDREventName.participantJoined, sessionId, participant.getCreatedAt());
public CDREventParticipant(Participant participant) {
super(CDREventName.participantJoined, participant.getSessionId(), participant.getCreatedAt());
this.participant = participant;
}

View File

@ -30,28 +30,21 @@ import io.openvidu.server.utils.GeoLocation;
public class FinalUser {
private String id;
private String sessionId;
private GeoLocation location;
private String platform;
private Map<String, ParticipantSummary> connections = new ConcurrentHashMap<>();
public FinalUser(String id, String sessionId, Participant firstConnection) {
this.id = id;
this.sessionId = sessionId;
this.location = firstConnection.getLocation();
this.platform = firstConnection.getPlatform();
this.connections.put(firstConnection.getParticipantPublicId(),
new ParticipantSummary(this.sessionId, firstConnection));
this.connections.put(firstConnection.getParticipantPublicId(), new ParticipantSummary(firstConnection));
}
public String getId() {
return id;
}
public String getSessionId() {
return sessionId;
}
public GeoLocation getLocation() {
return location;
}
@ -65,7 +58,7 @@ public class FinalUser {
}
public void addConnectionIfAbsent(Participant participant) {
this.connections.putIfAbsent(participant.getParticipantPublicId(), new ParticipantSummary(this.sessionId, participant));
this.connections.putIfAbsent(participant.getParticipantPublicId(), new ParticipantSummary(participant));
}
public void setConnection(CDREventParticipant event) {

View File

@ -33,8 +33,8 @@ public class ParticipantSummary {
private Map<String, CDREventWebrtcConnection> publishers = new ConcurrentHashMap<>();
private Map<String, CDREventWebrtcConnection> subscribers = new ConcurrentHashMap<>();
public ParticipantSummary(String sessionId, Participant participant) {
this.eventParticipantEnd = new CDREventParticipant(sessionId, participant);
public ParticipantSummary(Participant participant) {
this.eventParticipantEnd = new CDREventParticipant(participant);
}
public ParticipantSummary(CDREventParticipant event, ParticipantSummary oldSummary) {