cyclon.p2p-rtc-comms/lib/Builder.js

"use strict";
Object.defineProperty(exports, "__esModule", { value: true });
var WebRTCComms_1 = require("./WebRTCComms");
var ShuffleStateFactory_1 = require("./ShuffleStateFactory");
var cyclon_p2p_common_1 = require("cyclon.p2p-common");
var cyclon_p2p_rtc_client_1 = require("cyclon.p2p-rtc-client");
var SignallingServerBootstrap_1 = require("./SignallingServerBootstrap");
var Defaults_1 = require("./Defaults");
var Builder = /** @class */ (function () {
    function Builder() {
    }
    Builder.prototype.withLogger = function (logger) {
        this.logger = logger;
        return this;
    };
    Builder.prototype.withSignallingServers = function (signallingServerSpecs) {
        this.signallingServers = signallingServerSpecs;
        return this;
    };
    Builder.prototype.withStorage = function (storage) {
        this.storage = storage;
        return this;
    };
    Builder.prototype.withSignallingServerReconnectDelay = function (reconnectDelayInMillis) {
        this.reconnectDelayInMillis = reconnectDelayInMillis;
        return this;
    };
    Builder.prototype.withChannelStateChangeTimeout = function (channelStateTimeoutMillis) {
        this.channelStateTimeoutMillis = channelStateTimeoutMillis;
        return this;
    };
    Builder.prototype.withIceServers = function (iceServers) {
        this.iceServers = iceServers;
        return this;
    };
    Builder.prototype.joiningRooms = function (roomsToJoin) {
        this.roomsToJoin = roomsToJoin;
        return this;
    };
    Builder.prototype.build = function () {
        if (!this.result) {
            this.result = this.doBuild();
        }
        return this.result;
    };
    Builder.prototype.doBuild = function () {
        var rtcBuilderResult = cyclon_p2p_rtc_client_1.rtcBuilder()
            .withLogger(this.getLogger())
            .withStorage(this.getStorage())
            .withSignallingServers(this.getSignallingServers())
            .withIceServers(this.getIceServers())
            .withChannelStateChangeTimeout(this.getChannelStateTimeout())
            .withSignallingServerReconnectDelay(this.getReconnectDelay())
            .build();
        var shuffleStateFactory = new ShuffleStateFactory_1.ShuffleStateFactory(this.getLogger(), cyclon_p2p_common_1.asyncExecService());
        var roomsToJoin = this.getRoomsToJoin();
        return {
            comms: new WebRTCComms_1.WebRTCComms(rtcBuilderResult.rtc, shuffleStateFactory, this.getLogger(), roomsToJoin),
            bootstrap: new SignallingServerBootstrap_1.SignallingServerBootstrap(rtcBuilderResult.signallingSocket, new cyclon_p2p_rtc_client_1.HttpRequestService(), roomsToJoin)
        };
    };
    Builder.prototype.getRoomsToJoin = function () {
        return this.roomsToJoin === undefined ? Defaults_1.DEFAULT_ROOMS_TO_JOIN : this.roomsToJoin;
    };
    Builder.prototype.getIceServers = function () {
        return this.iceServers === undefined ? cyclon_p2p_rtc_client_1.DEFAULT_ICE_SERVERS : this.iceServers;
    };
    Builder.prototype.getChannelStateTimeout = function () {
        return this.channelStateTimeoutMillis === undefined ? cyclon_p2p_rtc_client_1.DEFAULT_CHANNEL_STATE_TIMEOUT_MS : this.channelStateTimeoutMillis;
    };
    Builder.prototype.getReconnectDelay = function () {
        return this.reconnectDelayInMillis === undefined ? cyclon_p2p_rtc_client_1.DEFAULT_SIGNALLING_SERVER_RECONNECT_DELAY_MS : this.reconnectDelayInMillis;
    };
    Builder.prototype.getLogger = function () {
        return this.logger || cyclon_p2p_common_1.consoleLogger();
    };
    Builder.prototype.getStorage = function () {
        if (!this.storage) {
            this.storage = cyclon_p2p_common_1.newInMemoryStorage();
        }
        return this.storage;
    };
    Builder.prototype.getSignallingServers = function () {
        return this.signallingServers === undefined ? JSON.parse(JSON.stringify(cyclon_p2p_rtc_client_1.DEFAULT_SIGNALLING_SERVERS)) : this.signallingServers;
    };
    return Builder;
}());
exports.Builder = Builder;
//# sourceMappingURL=Builder.js.map