iridium/neko-custom
Archived
2
0
Fork 0
Code Pull Requests Activity

use async / await.

Browse Source
This commit is contained in:
Miroslav Šedivý
2021-08-31 17:58:32 +02:00
parent aae55ea585
commit b808530f0c
7 changed files with 96 additions and 99 deletions
Download Patch File Download Diff File Expand all files Collapse all files

33
client/src/neko/base.ts
View File

@ -52,10 +52,6 @@ export abstract class BaseClient extends EventEmitter<BaseEvents> {
return
}
if (displayname === '') {
throw new Error('Display Name cannot be empty.')
}
this._displayname = displayname
this[EVENT.CONNECTING]()
@ -184,7 +180,7 @@ export abstract class BaseClient extends EventEmitter<BaseEvents> {
this._ws!.send(JSON.stringify({ event, ...payload }))
}
public createPeer(sdp: string, lite: boolean, servers: RTCIceServer[]) {
public async createPeer(sdp: string, lite: boolean, servers: RTCIceServer[]) {
this.emit('debug', `creating peer`)
if (!this.socketOpen) {
this.emit(
@ -262,19 +258,20 @@ export abstract class BaseClient extends EventEmitter<BaseEvents> {
}
this._candidates = []
this._peer
.createAnswer()
.then((d) => {
this._peer!.setLocalDescription(d)
this._ws!.send(
JSON.stringify({
event: EVENT.SIGNAL.ANSWER,
sdp: d.sdp,
displayname: this._displayname,
}),
)
})
.catch((err) => this.emit('error', err))
try {
const d = await this._peer.createAnswer()
this._peer!.setLocalDescription(d)
this._ws!.send(
JSON.stringify({
event: EVENT.SIGNAL.ANSWER,
sdp: d.sdp,
displayname: this._displayname,
}),
)
} catch (err) {
this.emit('error', err)
}
}
private onMessage(e: MessageEvent) {