ambiser
/
openvidu
mirror of https://github.com/OpenVidu/openvidu.git
8
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

openvidu-test-e2e: fix restApiFetchForce

pull/669/head
pabloFuente 2021-11-10 15:01:43 +01:00
parent 166ab0ba83
commit e5f87f58e8
2 changed files with 18 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
openvidu-test-e2e/src/test/java/io/openvidu/test/e2e/OpenViduTestAppE2eTest.java
View File

@ -1996,9 +1996,11 @@ public class OpenViduTestAppE2eTest extends AbstractOpenViduTestappE2eTest {
// Store connectionId and streamId // Store connectionId and streamId
String response = user.getDriver().findElement(By.id("api-response-text-area")).getAttribute("value"); String response = user.getDriver().findElement(By.id("api-response-text-area")).getAttribute("value");
JsonObject json = JsonParser.parseString(response.split("%")[1]).getAsJsonArray().get(0).getAsJsonObject(); response = response.replace("Session info fetched {", "{").replace("}. Changes: true", "}");
String connectionId = json.keySet().iterator().next(); JsonObject jsonConnection = JsonParser.parseString(response).getAsJsonObject().get("activeConnections")
String streamId = json.get(connectionId).getAsJsonArray().get(0).getAsJsonObject().get("streamId") .getAsJsonArray().get(0).getAsJsonObject();
String connectionId = jsonConnection.get("connectionId").getAsString();
String streamId = jsonConnection.get("publishers").getAsJsonArray().get(0).getAsJsonObject().get("streamId")
.getAsString(); .getAsString();
// Fetch all sessions (no change) // Fetch all sessions (no change)

16
openvidu-testapp/src/app/components/dialogs/session-api-dialog/session-api-dialog.component.ts
View File

@ -141,17 +141,27 @@ export class SessionApiDialogComponent {
this.session.fetch() this.session.fetch()
.then(anyChange => { .then(anyChange => {
const resp = { const resp = {
activeConnections: [], activeConnections: <any>[],
sessionId: this.session.sessionId, sessionId: this.session.sessionId,
createdAt: this.session.createdAt, createdAt: this.session.createdAt,
properties: this.session.properties, properties: this.session.properties,
recording: this.session.recording recording: this.session.recording
}; };
this.session.activeConnections.forEach(con => { this.session.activeConnections.forEach(con => {
resp.activeConnections[con.connectionId] = []; const publishers = <any>[];
con.publishers.forEach(pub => { con.publishers.forEach(pub => {
resp.activeConnections[con.connectionId].push(pub); publishers.push(pub);
}); });
resp.activeConnections.push({
connectionId: con.connectionId,
activeAt: con.activeAt,
clientData: con.clientData,
createdAt: con.createdAt,
ip: con.ip,
platform: con.platform,
status: con.status,
publishers
})
}); });
this.response = 'Session info fetched ' + JSON.stringify(resp) + '. Changes: ' + anyChange; this.response = 'Session info fetched ' + JSON.stringify(resp) + '. Changes: ' + anyChange;
}) })