f7ec12aa8d
Previously we used webworkify-webpack to make web-workers work. We now use the worker-loader webpack plugin which is available since webpack 4 to handle workers. It still doesn't want to connect to the server, but all JS errors in the dev console are gone. Progress.
379 строки
9,4 КиБ
JavaScript
379 строки
9,4 КиБ
JavaScript
import MumbleClient from 'mumble-client'
|
|
import Promise from 'promise'
|
|
import EventEmitter from 'events'
|
|
import { Writable, PassThrough } from 'stream'
|
|
import toArrayBuffer from 'to-arraybuffer'
|
|
import ByteBuffer from 'bytebuffer'
|
|
//import work from 'webworkify-webpack'
|
|
//import worker from './worker'
|
|
import Worker from './worker'
|
|
|
|
/**
|
|
* Creates proxy MumbleClients to a real ones running on a web worker.
|
|
* Only stuff which we need in mumble-web is proxied, i.e. this is not a generic solution.
|
|
*/
|
|
class WorkerBasedMumbleConnector {
|
|
constructor () {
|
|
this._worker = new Worker() //work(require.resolve('./worker'))
|
|
this._worker.addEventListener('message', this._onMessage.bind(this))
|
|
this._reqId = 1
|
|
this._requests = {}
|
|
this._clients = {}
|
|
this._nextVoiceId = 1
|
|
this._voiceStreams = {}
|
|
}
|
|
|
|
setSampleRate (sampleRate) {
|
|
this._postMessage({
|
|
method: '_init',
|
|
sampleRate: sampleRate
|
|
})
|
|
}
|
|
|
|
_postMessage (msg, transfer) {
|
|
try {
|
|
this._worker.postMessage(msg, transfer)
|
|
} catch (err) {
|
|
console.error('Failed to postMessage', msg)
|
|
throw err
|
|
}
|
|
}
|
|
|
|
_call (id, method, payload, transfer) {
|
|
let reqId = this._reqId++
|
|
console.debug(method, id, payload)
|
|
this._postMessage({
|
|
clientId: id.client,
|
|
channelId: id.channel,
|
|
userId: id.user,
|
|
method: method,
|
|
reqId: reqId,
|
|
payload: payload
|
|
}, transfer)
|
|
return reqId
|
|
}
|
|
|
|
_query (id, method, payload, transfer) {
|
|
let reqId = this._call(id, method, payload, transfer)
|
|
return new Promise((resolve, reject) => {
|
|
this._requests[reqId] = [resolve, reject]
|
|
})
|
|
}
|
|
|
|
_addCall (proxy, name, id) {
|
|
let self = this
|
|
proxy[name] = function () {
|
|
self._call(id, name, Array.from(arguments))
|
|
}
|
|
}
|
|
|
|
connect (host, args) {
|
|
return this._query({}, '_connect', { host: host, args: args })
|
|
.then(id => this._client(id))
|
|
}
|
|
|
|
_client (id) {
|
|
let client = this._clients[id]
|
|
if (!client) {
|
|
client = new WorkerBasedMumbleClient(this, id)
|
|
this._clients[id] = client
|
|
}
|
|
return client
|
|
}
|
|
|
|
_onMessage (ev) {
|
|
let data = ev.data
|
|
if (data.reqId != null) {
|
|
console.debug(data)
|
|
let { reqId, result, error } = data
|
|
let [ resolve, reject ] = this._requests[reqId]
|
|
delete this._requests[reqId]
|
|
if (result) {
|
|
resolve(result)
|
|
} else {
|
|
reject(error)
|
|
}
|
|
} else if (data.clientId != null) {
|
|
console.debug(data)
|
|
let client = this._client(data.clientId)
|
|
|
|
let target
|
|
if (data.userId != null) {
|
|
target = client._user(data.userId)
|
|
} else if (data.channelId != null) {
|
|
target = client._channel(data.channelId)
|
|
} else {
|
|
target = client
|
|
}
|
|
|
|
if (data.event) {
|
|
target._dispatchEvent(data.event, data.value)
|
|
} else if (data.prop) {
|
|
target._setProp(data.prop, data.value)
|
|
}
|
|
} else if (data.voiceId != null) {
|
|
let stream = this._voiceStreams[data.voiceId]
|
|
let buffer = data.buffer
|
|
if (buffer) {
|
|
stream.write({
|
|
target: data.target,
|
|
buffer: Buffer.from(buffer)
|
|
})
|
|
} else {
|
|
delete this._voiceStreams[data.voiceId]
|
|
stream.end()
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
class WorkerBasedMumbleClient extends EventEmitter {
|
|
constructor (connector, clientId) {
|
|
super()
|
|
this._connector = connector
|
|
this._id = clientId
|
|
this._users = {}
|
|
this._channels = {}
|
|
|
|
let id = { client: clientId }
|
|
connector._addCall(this, 'setSelfDeaf', id)
|
|
connector._addCall(this, 'setSelfMute', id)
|
|
connector._addCall(this, 'setSelfTexture', id)
|
|
connector._addCall(this, 'setAudioQuality', id)
|
|
|
|
connector._addCall(this, 'disconnect', id)
|
|
let _disconnect = this.disconnect
|
|
this.disconnect = () => {
|
|
_disconnect.apply(this)
|
|
delete connector._clients[id]
|
|
}
|
|
|
|
connector._addCall(this, 'createVoiceStream', id)
|
|
let _createVoiceStream = this.createVoiceStream
|
|
this.createVoiceStream = function () {
|
|
let voiceId = connector._nextVoiceId++
|
|
|
|
let args = Array.from(arguments)
|
|
args.unshift(voiceId)
|
|
_createVoiceStream.apply(this, args)
|
|
|
|
return new Writable({
|
|
write (chunk, encoding, callback) {
|
|
chunk = toArrayBuffer(chunk)
|
|
connector._postMessage({
|
|
voiceId: voiceId,
|
|
chunk: chunk
|
|
})
|
|
callback()
|
|
},
|
|
final (callback) {
|
|
connector._postMessage({
|
|
voiceId: voiceId
|
|
})
|
|
callback()
|
|
}
|
|
})
|
|
}
|
|
|
|
// Dummy client used for bandwidth calculations
|
|
this._dummyClient = new MumbleClient({ username: 'dummy' })
|
|
let defineDummyMethod = (name) => {
|
|
this[name] = function () {
|
|
return this._dummyClient[name].apply(this._dummyClient, arguments)
|
|
}
|
|
}
|
|
defineDummyMethod('getMaxBitrate')
|
|
defineDummyMethod('getActualBitrate')
|
|
let _setAudioQuality = this.setAudioQuality
|
|
this.setAudioQuality = function () {
|
|
this._dummyClient.setAudioQuality.apply(this._dummyClient, arguments)
|
|
_setAudioQuality.apply(this, arguments)
|
|
}
|
|
}
|
|
|
|
_user (id) {
|
|
let user = this._users[id]
|
|
if (!user) {
|
|
user = new WorkerBasedMumbleUser(this._connector, this, id)
|
|
this._users[id] = user
|
|
}
|
|
return user
|
|
}
|
|
|
|
_channel (id) {
|
|
let channel = this._channels[id]
|
|
if (!channel) {
|
|
channel = new WorkerBasedMumbleChannel(this._connector, this, id)
|
|
this._channels[id] = channel
|
|
}
|
|
return channel
|
|
}
|
|
|
|
_dispatchEvent (name, args) {
|
|
if (name === 'newChannel') {
|
|
args[0] = this._channel(args[0])
|
|
} else if (name === 'newUser') {
|
|
args[0] = this._user(args[0])
|
|
} else if (name === 'message') {
|
|
args[0] = this._user(args[0])
|
|
args[2] = args[2].map((id) => this._user(id))
|
|
args[3] = args[3].map((id) => this._channel(id))
|
|
args[4] = args[4].map((id) => this._channel(id))
|
|
}
|
|
args.unshift(name)
|
|
this.emit.apply(this, args)
|
|
}
|
|
|
|
_setProp (name, value) {
|
|
if (name === 'root') {
|
|
name = '_rootId'
|
|
}
|
|
if (name === 'self') {
|
|
name = '_selfId'
|
|
}
|
|
if (name === 'maxBandwidth') {
|
|
this._dummyClient.maxBandwidth = value
|
|
}
|
|
this[name] = value
|
|
}
|
|
|
|
get root () {
|
|
return this._channel(this._rootId)
|
|
}
|
|
|
|
get channels () {
|
|
return Object.values(this._channels)
|
|
}
|
|
|
|
get users () {
|
|
return Object.values(this._users)
|
|
}
|
|
|
|
get self () {
|
|
return this._user(this._selfId)
|
|
}
|
|
}
|
|
|
|
class WorkerBasedMumbleChannel extends EventEmitter {
|
|
constructor (connector, client, channelId) {
|
|
super()
|
|
this._connector = connector
|
|
this._client = client
|
|
this._id = channelId
|
|
|
|
let id = { client: client._id, channel: channelId }
|
|
connector._addCall(this, 'sendMessage', id)
|
|
}
|
|
|
|
_dispatchEvent (name, args) {
|
|
if (name === 'update') {
|
|
let [actor, props] = args
|
|
Object.entries(props).forEach((entry) => {
|
|
this._setProp(entry[0], entry[1])
|
|
})
|
|
if (props.parent != null) {
|
|
props.parent = this.parent
|
|
}
|
|
if (props.links != null) {
|
|
props.links = this.links
|
|
}
|
|
args = [
|
|
this._client._user(actor),
|
|
props
|
|
]
|
|
} else if (name === 'remove') {
|
|
delete this._client._channels[this._id]
|
|
}
|
|
args.unshift(name)
|
|
this.emit.apply(this, args)
|
|
}
|
|
|
|
_setProp (name, value) {
|
|
if (name === 'parent') {
|
|
name = '_parentId'
|
|
}
|
|
if (name === 'links') {
|
|
value = value.map((id) => this._client._channel(id))
|
|
}
|
|
this[name] = value
|
|
}
|
|
|
|
get parent () {
|
|
if (this._parentId != null) {
|
|
return this._client._channel(this._parentId)
|
|
}
|
|
}
|
|
|
|
get children () {
|
|
return Object.values(this._client._channels).filter((it) => it.parent === this)
|
|
}
|
|
}
|
|
|
|
class WorkerBasedMumbleUser extends EventEmitter {
|
|
constructor (connector, client, userId) {
|
|
super()
|
|
this._connector = connector
|
|
this._client = client
|
|
this._id = userId
|
|
|
|
let id = { client: client._id, user: userId }
|
|
connector._addCall(this, 'requestTexture', id)
|
|
connector._addCall(this, 'clearTexture', id)
|
|
connector._addCall(this, 'setMute', id)
|
|
connector._addCall(this, 'setDeaf', id)
|
|
connector._addCall(this, 'sendMessage', id)
|
|
this.setChannel = (channel) => {
|
|
connector._call(id, 'setChannel', channel._id)
|
|
}
|
|
}
|
|
|
|
_dispatchEvent (name, args) {
|
|
if (name === 'update') {
|
|
let [actor, props] = args
|
|
Object.entries(props).forEach((entry) => {
|
|
this._setProp(entry[0], entry[1])
|
|
})
|
|
if (props.channel != null) {
|
|
props.channel = this.channel
|
|
}
|
|
if (props.texture != null) {
|
|
props.texture = this.texture
|
|
}
|
|
args = [
|
|
this._client._user(actor),
|
|
props
|
|
]
|
|
} else if (name === 'voice') {
|
|
let [id] = args
|
|
let stream = new PassThrough({
|
|
objectMode: true
|
|
})
|
|
this._connector._voiceStreams[id] = stream
|
|
args = [stream]
|
|
} else if (name === 'remove') {
|
|
delete this._client._users[this._id]
|
|
}
|
|
args.unshift(name)
|
|
this.emit.apply(this, args)
|
|
}
|
|
|
|
_setProp (name, value) {
|
|
if (name === 'channel') {
|
|
name = '_channelId'
|
|
}
|
|
if (name === 'texture') {
|
|
if (value) {
|
|
let buf = ByteBuffer.wrap(value.buffer)
|
|
buf.offset = value.offset
|
|
buf.limit = value.limit
|
|
value = buf
|
|
}
|
|
}
|
|
this[name] = value
|
|
}
|
|
|
|
get channel () {
|
|
return this._client._channels[this._channelId]
|
|
}
|
|
}
|
|
export default WorkerBasedMumbleConnector
|