const init = function() {
    let configName =  state.set(pc, session, room)getUrlParam("config") || "./config.json";
    ...
    publishState = onConnectedCurrentState(statePUBLISH);
    playState =   setStatus(state.statusId(), "ESTABLISHED", "green"CurrentState(PLAY);
    })$.on(constants.SFU_EVENT.DISCONNECTEDgetJSON(configName, function(cfg) {
        state.clear()mainConfig = cfg;
        onDisconnected(statepublishState);
        setStatus(state.statusId(), "DISCONNECTED", "green"onDisconnected(playState);
    }).on(constants.SFU_EVENT.FAILED, fail(function(e) {
        state.clear();//use default config
        onDisconnected(state);
        setStatus(state.statusId(), "FAILED", "red");console.error("Error reading configuration file " + configName + ": " + e.status + " " + e.statusText)
        setStatus(stateconsole.errInfoId(), e.status + " " + e.statusText, "red"log("Default config will be used");
        mainConfig = defaultConfig;
        onDisconnected(publishState);
    });
}

const connect = function(state) {
    //create Addpeer errorsconnection
  displaying
  pc  state.room.on(constants.SFU_ROOM_EVENT.FAILED, function(e) {
   = new RTCPeerConnection();
    //get config object for room creation
     setStatus(state.errInfoId(), e, "red"const roomConfig = getRoomConfig(mainConfig);
    }).on(constants.SFU_ROOM_EVENT.OPERATION_FAILED, function (e) {
        setStatus(state.errInfoId(), e.operation + " failed: " + e.error, "red"roomConfig.pc = pc;
    roomConfig.url = $("#url").val();
    roomConfig.roomName = $("#roomName").val();
    });
    if (state.is(PUBLISH)) {roomConfig.nickname = $("#" + state.inputId()).val();
    // clean state  publishStreamsdisplay items
    setStatus(state.statusId(), "");
    } else if setStatus(state.iserrInfoId(PLAY), "") {
        playStreams(state);;
    // connect to server and create a room if not
    }
}

const onConnected = function(state) {
    $("#" + state.buttonId()).text("Stop").off('click').click(function () {
        onStopClick(state);
    });
    ...
    // Add errors displaying
    state.room.on(constants.SFU_ROOM_EVENT.FAILED, function(e) {
        setStatus(state.errInfoId(), e, "red");
        stopStreaming(state);
    }).on(constants.SFU_ROOM_EVENT.OPERATION_FAILED, function (e) {
        setStatus(state.errInfoId(), e.operation + " failed: " + e.error, "red");
        stopStreaming(state);
    });
    startStreaming(state);
}

const publishStreams = async function(state) {
    if (state.isConnected()) {
        //create local display item to show local streams
        localDisplay = initLocalDisplay(document.getElementById("localVideo"));
        try {
            //get configured local video streams
            let streams = await getVideoStreams(mainConfig);
            let audioStreams = await getAudioStreams(mainConfig);
            if (state.isConnected() && state.isActive()) {
                //combine local video streams with audio streams
                streams.push.apply(streams, audioStreams);
                let config = {};
                //add our local streams to the room (to PeerConnection)
                streams.forEach(function (s) {
                    //add local stream to local display
                    localDisplay.add(s.stream.id, $("#" + state.inputId()).val(), s.stream);
                    //add each track to PeerConnection
                    s.stream.getTracks().forEach((track) => {
                        if (s.source === "screen") {
                            config[track.id] = s.source;
                        }
                       //get configured local video streams addTrackToPeerConnection(state.pc, s.stream, track, s.encodings);
        let    streams = await getVideoStreams(mainConfig);
        let audioStreams = await getAudioStreams(mainConfig subscribeTrackToEndedEvent(state.room, track, state.pc);
          //combine local video streams with audio streams
    });
    streams.push.apply(streams, audioStreams);
        let config = {});
        //add   our local streams to the state.room (to PeerConnection).join(config);
        streams.forEach(function (s) {
        // TODO: Use room state or promises to detect //addif localpublishing streamstarted to localenable stop displaybutton
            localDisplay.add(s.stream.id, $("#" +    state.inputIdwaitFor())document.valgetElementById("localVideo"), s.stream3000);
            //add each track to PeerConnection}
        } catch(e) {
            sconsole.stream.getTracks().forEach((track) => {
    error("Failed to capture streams: " + e);
            if setStatus(s.source === "screen") {state.errInfoId(), e.name, "red");
            state.stopWaiting();
        config[track.id] = s.source;
      if (state.isConnected()) { 
          }
      onStopClick(state);
          addTrackToPeerConnection(state.pc, s.stream, track, s.encodings); }
        }
        subscribeTrackToEndedEvent(state.room, track, state.pc);
            });}
}

const addTrackToPeerConnection = function(pc, stream, track, encodings) {
    pc.addTransceiver(track, {
        });
direction: "sendonly",
         state.room.join(config);streams: [stream],
        // TODOsendEncodings: Use room state or promises to detect if publishing started to enable stop button
        timerId = waitFor(document.getElementById("localVideo"), 3000, state);
    } catch(e) {
        console.error("Failed to capture streams: " + e);
        setStatus(state.errInfoId(), e.name, "red");
        if (timerIdencodings ? encodings : [] //passing encoding types for video simulcast tracks
    });
}

const subscribeTrackToEndedEvent = function(room, track, pc) {
    track.addEventListener("ended", function() {
        //track ended, see if we need to clearTimeout(timerId);cleanup
        let   negotiate timerId = nullfalse;
        }for (const sender of pc.getSenders()) {
        onStopClick(state);
    }
}

const playStreams = function(state) {
    if (state.isConnected() && state.isActive()) {
        //create remote display item to show remote streams
   pc.removeTrack(sender);
     remoteDisplay = initRemoteDisplay({
         //track found, set renegotiation flagdiv: document.getElementById("remoteVideo"),
            room: state.room,
    negotiate = true;
      peerConnection: state.pc
         break});
        state.room.join(state.pc);
    }
    $("#" +   }
        if (negotiatestate.buttonId()).prop('disabled', false);
}

const unPublishStreams = function(state) {
    if        //kickoff renegotiation(localDisplay) {
            room.updateStatelocalDisplay.stop();
        }
    });
};

const onStopClick = function(state) {
    $("#"        playFirstSound(document.getElementById("main"), PRELOADER_URL).then(function () {
            + state.buttonId()).prop('disabled', true);
    connectstopStreaming(state);
    if (state.isConnected()) {
        }state.session.disconnect();
    }
}

const onDisconnected   } else= function(state) {
    $("#"        connect(state);
        }
    }
}

const stopStreaming = function(state) {
    state.stopWaiting();
    if (state.is(PLAY) && publishState.session))PUBLISH)) {
        returnunPublishStreams(state);
    }
 else if  $('#url').prop('disabled', false);
(state.is(PLAY)) {
       $("#roomName").prop('disabled', false); stopStreams(state);
    }
}