List view

A

net_drivers\webrtc\js\standalone\signaling_client.js

• 14 Complexity
• 1.27 Complexity / M
• 0 Duplication
• 5 Churn
• 86 Lines
• 61 Lines of Code
• 11 Methods
• 5.55 LOC / Method

const loggerFactory = require('../logger.js')

function SignalingClient(protocol_id, options) {
    this.protocol = protocol_id.toString()
    this.logger = loggerFactory.createLogger('StandaloneSignalingClient')
    this.connected = false
    this.options = options
}

SignalingClient.prototype.connect = function(host, port) {
    return new Promise((resolve, reject) => {
        const uri = this.options['https'] ? `wss://${host}:${port}` : `ws://${host}:${port}`

        this.logger.info(this.options['https'])
        this.logger.info(`Connecting to ${uri}...`)

        const WebSocket = require('websocket').w3cwebsocket

        this.ws = new WebSocket(uri)

        this.ws.onclose = (ev) => {
            if (this.connected) {
                this.logger.error('Connection closed')

                this.connected = false

                this.onClosed()
            } else {
                this.logger.error('Connection failed')

                reject()
            }
        }

        this.ws.onopen = () => {
            this.logger.info('Connected')

            this.connected = true
            
            clearTimeout(timeoutId)
            resolve()
        }

        this.ws.onmessage = (ev) => {
            this.logger.info('Received signaling data: %s', ev.data)

            this.onDataReceived(JSON.parse(ev.data))
        }

        const timeoutId = setTimeout(() => {
            this.logger.error('Connection timeout')

            reject()
        }, 3000)
    })
}

SignalingClient.prototype.send = function(data) {
    this.logger.info('Send signaling data: %s', data)

    this.ws.send(JSON.stringify(data))
}

SignalingClient.prototype.close = function() {
    this.logger.info('Closing...')

    const WebSocket = require('websocket').w3cwebsocket

    return new Promise((resolve, reject) => {
        if (this.ws.readyState != WebSocket.OPEN) {
            this.logger.warn('Not opened')

            reject()
        } else {
            this.ws.onclose = (_) => {
                this.logger.info('Closed')

                resolve()
            }

            this.ws.close()
        }
    })
}

module.exports = SignalingClient