TLSServer.js

'use strict';

import { Image } from 'react-native';
import Server from './Server';
import TLSSocket from './TLSSocket';

/**
 * @typedef {object} TLSServerOptions
 * @property {any} keystore
 * @property {string} [passphrase] - Optional passphrase for keystore
 *
 * @extends {Server}
 */
export default class TLSServer extends Server {
    /**
     * @param {(socket: TLSSocket) => void} [secureConnectionListener] Automatically set as a listener for the `'secureConnection'` event.
     */
    constructor(secureConnectionListener) {
        super();
        if (secureConnectionListener) this.on('secureConnection', secureConnectionListener);
        this._registerTLSEvents();
    }

    /**
     * @param {TLSServerOptions} options TLS server options
     */
    setSecureContext(options) {
        /** @private */
        this._options = { ...options };
        this._options.keystore = Image.resolveAssetSource(this._options.keystore).uri;
    }

    /**
     * Start a server listening for connections.
     *
     * This function is asynchronous. When the server starts listening, the `'listening'` event will be emitted.
     * The last parameter `callback` will be added as a listener for the `'listening'` event.
     *
     * The `server.listen()` method can be called again if and only if there was an error during the first
     * `server.listen()` call or `server.close()` has been called. Otherwise, an `ERR_SERVER_ALREADY_LISTEN`
     * error will be thrown.
     *
     * @param {{ port: number; host: string; reuseAddress?: boolean}} options
     * @param {() => void} [callback]
     * @override
     */
    listen(options, callback) {
        const newOptions = { ...options };
        // @ts-ignore
        newOptions['tls'] = this._options;
        return super.listen(newOptions, callback);
    }

    /**
     * @private
     */
    _registerTLSEvents() {
        this._secureConnectionListener = this._eventEmitter.addListener(
            'secureConnection',
            (evt) => {
                if (evt.id !== this._id) return;
                const standardSocket = this._buildSocket(evt.info);
                standardSocket._unregisterEvents();
                const tlsSocket = new TLSSocket(standardSocket);
                this._addConnection(tlsSocket);
                this.emit('connection', standardSocket);
                this.emit('secureConnection', tlsSocket);
            }
        );
    }
}