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

openvidu-testapp: update test-scenarios component

pull/744/merge
pabloFuente 2024-03-07 11:52:25 +01:00
parent b92548c504
commit 49e2e87f69
1 changed files with 5 additions and 14 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
openvidu-testapp/src/app/components/test-scenarios/test-scenarios.component.ts
View File

@ -213,16 +213,7 @@ export class TestScenariosComponent implements OnInit, OnDestroy {
this.testFeedService.pushNewEvent({ user: 0, event });
const subscriber = session.subscribe(event.stream, undefined, (error) => {
const subAux = this.subscribers
.find(s => s.connectionId === session.connection.connectionId).subs
.find(s => s.streamManager.stream.connection.connectionId === subscriber.stream.connection.connectionId);
if (!!error) {
subAux.state['errorConnecting'] = (Date.now() - startTimeForUser);
} else {
subAux.state['connected'] = (Date.now() - startTimeForUser);
}
});
const subscriber = session.subscribe(event.stream, undefined);
const sub = this.subscribers.find(s => s.connectionId === session.connection.connectionId);
if (!sub) {
@ -232,7 +223,7 @@ export class TestScenariosComponent implements OnInit, OnDestroy {
startTime: startTimeForUser,
connectionId: session.connection.connectionId,
streamManager: subscriber,
state: { 'connecting': (Date.now() - startTimeForUser) }
state: { 'connected': (Date.now() - startTimeForUser) }
}]
});
} else {
@ -240,7 +231,7 @@ export class TestScenariosComponent implements OnInit, OnDestroy {
startTime: startTimeForUser,
connectionId: session.connection.connectionId,
streamManager: subscriber,
state: { 'connecting': (Date.now() - startTimeForUser) }
state: { 'connected': (Date.now() - startTimeForUser) }
});
}
@ -294,8 +285,8 @@ export class TestScenariosComponent implements OnInit, OnDestroy {
this.sessionProperties.customSessionId = this.fixedSessionId;
}
return this.OV_NodeClient.createSession(this.sessionProperties)
.then(session_NodeClient => {
return session_NodeClient.generateToken();
.then(async (session_NodeClient) => {
return (await session_NodeClient.createConnection()).token;
});
}