Moved everything into component

Need help with server side

1 files changed, 298 insertions, 298 deletions

diff --git a/src/client/views/webcam/DashWebRTC.ts b/src/client/views/webcam/DashWebRTC.ts
index 7d798754f..ef5ecf0fc 100644
--- a/src/client/views/webcam/DashWebRTC.ts
+++ b/src/client/views/webcam/DashWebRTC.ts
@@ -1,314 +1,314 @@
-import { DocServer } from '../../DocServer';
-import { Utils } from '../../../Utils';
-import { MessageStore } from '../../../server/Message';
-
-
-
-/**
- * This namespace will have the code required to have functionality code for the usage of webRTC.
- */
-export class DashWebRTC {
-
-
-    private isChannelReady = false;
-    private isInitiator = false;
-    private isStarted = false;
-    localStream: MediaStream | undefined;
-    private pc: any;
-    remoteStream: MediaStream | undefined;
-    private turnReady: boolean | undefined;
-    localVideo: HTMLVideoElement | undefined;
-    remoteVideo: HTMLVideoElement | undefined;
-    curRoom: string = "";
-
-
-    private pcConfig: any;
-    private sdpConstraints: any;
-
-    constructor() {
-        this.pcConfig = {
-            'iceServers': [{
-                'urls': 'stun:stun.l.google.com:19302'
-            }]
-        };
+// import { DocServer } from '../../DocServer';
+// import { Utils } from '../../../Utils';
+// import { MessageStore } from '../../../server/Message';
+
+
+
+// /**
+//  * This namespace will have the code required to have functionality code for the usage of webRTC.
+//  */
+// export class DashWebRTC {
+
+
+//     private isChannelReady = false;
+//     private isInitiator = false;
+//     private isStarted = false;
+//     localStream: MediaStream | undefined;
+//     private pc: any;
+//     remoteStream: MediaStream | undefined;
+//     private turnReady: boolean | undefined;
+//     localVideo: HTMLVideoElement | undefined;
+//     remoteVideo: HTMLVideoElement | undefined;
+//     curRoom: string = "";
+
+
+//     private pcConfig: any;
+//     private sdpConstraints: any;
+
+//     constructor() {
+//         this.pcConfig = {
+//             'iceServers': [{
+//                 'urls': 'stun:stun.l.google.com:19302'
+//             }]
+//         };
 
-        // Set up audio and video regardless of what devices are present.
-        this.sdpConstraints = {
-            offerToReceiveAudio: true,
-            offerToReceiveVideo: true
-        };
-    }
+//         // Set up audio and video regardless of what devices are present.
+//         this.sdpConstraints = {
+//             offerToReceiveAudio: true,
+//             offerToReceiveVideo: true
+//         };
+//     }
 
 
 
-    init(room: string) {
+//     init(room: string) {
 
-        this.curRoom = room;
-        let self = this;
+//         this.curRoom = room;
+//         let self = this;
 
-        if (room !== '') {
-            DocServer._socket.emit('create or join', room);
-            console.log('Attempted to create or  join room', room);
+//         if (room !== '') {
+//             DocServer._socket.emit('create or join', room);
+//             console.log('Attempted to create or  join room', room);
 
-        }
+//         }
 
-        DocServer._socket.on('created', function (room: string) {
-            console.log('Created room ' + room);
-            self.isInitiator = true;
-        });
+//         DocServer._socket.on('created', function (room: string) {
+//             console.log('Created room ' + room);
+//             self.isInitiator = true;
+//         });
 
-        DocServer._socket.on('full', function (room: string) {
-            console.log('Room ' + room + ' is full');
-        });
+//         DocServer._socket.on('full', function (room: string) {
+//             console.log('Room ' + room + ' is full');
+//         });
 
-        DocServer._socket.on('join', function (room: string) {
-            console.log('Another peer made a request to join room ' + room);
-            console.log('This peer is the initiator of room ' + room + '!');
-            self.isChannelReady = true;
-        });
+//         DocServer._socket.on('join', function (room: string) {
+//             console.log('Another peer made a request to join room ' + room);
+//             console.log('This peer is the initiator of room ' + room + '!');
+//             self.isChannelReady = true;
+//         });
 
 
-        DocServer._socket.on('joined', function (room: string) {
-            console.log('joined: ' + room);
-            self.isChannelReady = true;
-        });
+//         DocServer._socket.on('joined', function (room: string) {
+//             console.log('joined: ' + room);
+//             self.isChannelReady = true;
+//         });
 
 
-        DocServer._socket.on('log', function (array: any) {
-            console.log.apply(console, array);
-        });
+//         DocServer._socket.on('log', function (array: any) {
+//             console.log.apply(console, array);
+//         });
 
-        // This client receives a message
-        DocServer._socket.on('message', function (message: any) {
-            console.log('Client received message:', message);
-            if (message.message === 'got user media') {
-                self.maybeStart();
-            } else if (message.message.type === 'offer') {
-                if (!self.isInitiator && !self.isStarted) {
-                    self.maybeStart();
-                }
-                self.pc.setRemoteDescription(new RTCSessionDescription(message.message));
-                self.doAnswer();
-            } else if (message.message.type === 'answer' && self.isStarted) {
-                self.pc.setRemoteDescription(new RTCSessionDescription(message.message));
-            } else if (message.message.type === 'candidate' && self.isStarted) {
-                let candidate = new RTCIceCandidate({
-                    sdpMLineIndex: message.message.label,
-                    candidate: message.message.candidate
-                });
-                self.pc.addIceCandidate(candidate);
-            } else if (message === 'bye' && self.isStarted) {
-                self.handleRemoteHangup();
-            }
-        });
+//         // This client receives a message
+//         DocServer._socket.on('message', function (message: any) {
+//             console.log('Client received message:', message);
+//             if (message.message === 'got user media') {
+//                 self.maybeStart();
+//             } else if (message.message.type === 'offer') {
+//                 if (!self.isInitiator && !self.isStarted) {
+//                     self.maybeStart();
+//                 }
+//                 self.pc.setRemoteDescription(new RTCSessionDescription(message.message));
+//                 self.doAnswer();
+//             } else if (message.message.type === 'answer' && self.isStarted) {
+//                 self.pc.setRemoteDescription(new RTCSessionDescription(message.message));
+//             } else if (message.message.type === 'candidate' && self.isStarted) {
+//                 let candidate = new RTCIceCandidate({
+//                     sdpMLineIndex: message.message.label,
+//                     candidate: message.message.candidate
+//                 });
+//                 self.pc.addIceCandidate(candidate);
+//             } else if (message === 'bye' && self.isStarted) {
+//                 self.handleRemoteHangup();
+//             }
+//         });
 
-        navigator.mediaDevices.getUserMedia({
-            audio: false,
-            video: true
-        })
-            .then(this.gotStream)
-            .catch(function (e) {
-                alert('getUserMedia() error: ' + e.name);
-            });
-
-        //Trying this one out!!!
-        console.log('Getting user media with constraints', this.constraints);
-
-        if (location.hostname !== 'localhost') {
-            this.requestTurn(
-                'https://computeengineondemand.appspot.com/turn?username=41784574&key=4080218913'
-            );
-        }
-
-
-    }
-
-
-    sendMessage(message: any) {
-        console.log('Client sending message: ', message);
-        Utils.Emit(DocServer._socket, MessageStore.NotifyRoommates, { message: message, room: this.curRoom });
-        //DocServer._socket.emit('message', message);
-    }
-
-
-
-
-
-    setVideoObjects(localVideo: HTMLVideoElement, remoteVideo: HTMLVideoElement) {
-        localVideo = localVideo;
-        remoteVideo = remoteVideo;
-    }
-
-    setLocalVideoObject(localVideoRef: HTMLVideoElement) {
-        this.localVideo = localVideoRef;
-    }
-
-    setRemoteVideoObject(remoteVideoRef: HTMLVideoElement) {
-        this.remoteVideo = remoteVideoRef;
-    }
-
-
-
-
-    gotStream(stream: any) {
-        console.log('Adding local stream.');
-        this.localStream = stream;
-        this.localVideo!.srcObject = stream;
-        this.sendMessage('got user media');
-        if (this.isInitiator) {
-            this.maybeStart();
-        }
-    }
-
-    constraints = {
-        video: true,
-        audio: true
-    };
-
-
-
-
-
-    maybeStart() {
-        console.log('>>>>>>> maybeStart() ', this.isStarted, this.localStream, this.isChannelReady);
-        if (!this.isStarted && typeof this.localStream !== 'undefined' && this.isChannelReady) {
-            console.log('>>>>>> creating peer connection');
-            this.createPeerConnection();
-            this.pc.addStream(this.localStream);
-            this.isStarted = true;
-            console.log('isInitiator', this.isInitiator);
-            if (this.isInitiator) {
-                this.doCall();
-            }
-        }
-    }
-
-
-    // //this will need to be changed to our version of hangUp
-    // window.onbeforeunload = function () {
-    //     sendMessage('bye');
-    // };
-
-    createPeerConnection() {
-        try {
-            this.pc = new RTCPeerConnection(undefined);
-            this.pc.onicecandidate = this.handleIceCandidate;
-            this.pc.onaddstream = this.handleRemoteStreamAdded;
-            this.pc.onremovestream = this.handleRemoteStreamRemoved;
-            console.log('Created RTCPeerConnnection');
-        } catch (e) {
-            console.log('Failed to create PeerConnection, exception: ' + e.message);
-            alert('Cannot create RTCPeerConnection object.');
-            return;
-        }
-    }
-
-    handleIceCandidate(event: any) {
-        console.log('icecandidate event: ', event);
-        if (event.candidate) {
-            this.sendMessage({
-                type: 'candidate',
-                label: event.candidate.sdpMLineIndex,
-                id: event.candidate.sdpMid,
-                candidate: event.candidate.candidate
-            });
-        } else {
-            console.log('End of candidates.');
-        }
-    }
-
-    handleCreateOfferError(event: any) {
-        console.log('createOffer() error: ', event);
-    }
-
-    doCall() {
-        console.log('Sending offer to peer');
-        this.pc.createOffer(this.setLocalAndSendMessage, this.handleCreateOfferError);
-    }
-
-    doAnswer() {
-        console.log('Sending answer to peer.');
-        this.pc.createAnswer().then(
-            this.setLocalAndSendMessage,
-            this.onCreateSessionDescriptionError
-        );
-    }
-
-    setLocalAndSendMessage(sessionDescription: any) {
-        this.pc.setLocalDescription(sessionDescription);
-        console.log('setLocalAndSendMessage sending message', sessionDescription);
-        this.sendMessage(sessionDescription);
-    }
-
-    onCreateSessionDescriptionError(error: any) {
-        console.log('Failed to create session description: ' + error.toString());
-    }
-
-
-    requestTurn(turnURL: any) {
-        var turnExists = false;
-        let self = this;
-        for (var i in this.pcConfig.iceServers) {
-            if (this.pcConfig.iceServers[i].urls.substr(0, 5) === 'turn:') {
-                turnExists = true;
-                this.turnReady = true;
-                break;
-            }
-        }
-        if (!turnExists) {
-            console.log('Getting TURN server from ', turnURL);
-            // No TURN server. Get one from computeengineondemand.appspot.com:
-            var xhr = new XMLHttpRequest();
-            xhr.onreadystatechange = function () {
-                if (xhr.readyState === 4 && xhr.status === 200) {
-                    var turnServer = JSON.parse(xhr.responseText);
-                    console.log('Got TURN server: ', turnServer);
-                    self.pcConfig.iceServers.push({
-                        'urls': 'turn:' + turnServer.username + '@' + turnServer.turn,
-                        //'credential': turnServer.password
-                    });
-                    self.turnReady = true;
-                }
-            };
-            xhr.open('GET', turnURL, true);
-            xhr.send();
-        }
-    }
-
-    handleRemoteStreamAdded(event: MediaStreamEvent) {
-        console.log('Remote stream added.');
-        this.remoteStream = event.stream!;
-        this.remoteVideo!.srcObject = this.remoteStream;
-    }
-
-    handleRemoteStreamRemoved(event: MediaStreamEvent) {
-        console.log('Remote stream removed. Event: ', event);
-    }
-
-    hangup() {
-        console.log('Hanging up.');
-        if (this.pc) {
-            stop();
-            this.sendMessage('bye');
-        }
-
-        if (this.localStream) {
-            this.localStream.getTracks().forEach(track => track.stop());
-        }
-
-    }
-
-    handleRemoteHangup() {
-        console.log('Session terminated.');
-        stop();
-        this.isInitiator = false;
-    }
-
-    stop() {
-        this.isStarted = false;
-        this.pc.close();
-        this.pc = null;
-    }
-
-
-}
\ No newline at end of file
+//         navigator.mediaDevices.getUserMedia({
+//             audio: false,
+//             video: true
+//         })
+//             .then(this.gotStream)
+//             .catch(function (e) {
+//                 alert('getUserMedia() error: ' + e.name);
+//             });
+
+//         //Trying this one out!!!
+//         console.log('Getting user media with constraints', this.constraints);
+
+//         if (location.hostname !== 'localhost') {
+//             this.requestTurn(
+//                 'https://computeengineondemand.appspot.com/turn?username=41784574&key=4080218913'
+//             );
+//         }
+
+
+//     }
+
+
+//     sendMessage(message: any) {
+//         console.log('Client sending message: ', message);
+//         Utils.Emit(DocServer._socket, MessageStore.NotifyRoommates, { message: message, room: this.curRoom });
+//         //DocServer._socket.emit('message', message);
+//     }
+
+
+
+
+
+//     setVideoObjects(localVideo: HTMLVideoElement, remoteVideo: HTMLVideoElement) {
+//         this.localVideo = localVideo;
+//         this.remoteVideo = remoteVideo;
+//     }
+
+//     setLocalVideoObject(localVideoRef: HTMLVideoElement) {
+//         this.localVideo = localVideoRef;
+//     }
+
+//     setRemoteVideoObject(remoteVideoRef: HTMLVideoElement) {
+//         this.remoteVideo = remoteVideoRef;
+//     }
+
+
+
+
+//     gotStream(stream: any) {
+//         console.log('Adding local stream.');
+//         this.localStream = stream;
+//         this.localVideo!.srcObject = stream;
+//         this.sendMessage('got user media');
+//         if (this.isInitiator) {
+//             this.maybeStart();
+//         }
+//     }
+
+//     constraints = {
+//         video: true,
+//         audio: true
+//     };
+
+
+
+
+
+//     maybeStart() {
+//         console.log('>>>>>>> maybeStart() ', this.isStarted, this.localStream, this.isChannelReady);
+//         if (!this.isStarted && typeof this.localStream !== 'undefined' && this.isChannelReady) {
+//             console.log('>>>>>> creating peer connection');
+//             this.createPeerConnection();
+//             this.pc.addStream(this.localStream);
+//             this.isStarted = true;
+//             console.log('isInitiator', this.isInitiator);
+//             if (this.isInitiator) {
+//                 this.doCall();
+//             }
+//         }
+//     }
+
+
+//     // //this will need to be changed to our version of hangUp
+//     // window.onbeforeunload = function () {
+//     //     sendMessage('bye');
+//     // };
+
+//     createPeerConnection() {
+//         try {
+//             this.pc = new RTCPeerConnection(undefined);
+//             this.pc.onicecandidate = this.handleIceCandidate;
+//             this.pc.onaddstream = this.handleRemoteStreamAdded;
+//             this.pc.onremovestream = this.handleRemoteStreamRemoved;
+//             console.log('Created RTCPeerConnnection');
+//         } catch (e) {
+//             console.log('Failed to create PeerConnection, exception: ' + e.message);
+//             alert('Cannot create RTCPeerConnection object.');
+//             return;
+//         }
+//     }
+
+//     handleIceCandidate(event: any) {
+//         console.log('icecandidate event: ', event);
+//         if (event.candidate) {
+//             this.sendMessage({
+//                 type: 'candidate',
+//                 label: event.candidate.sdpMLineIndex,
+//                 id: event.candidate.sdpMid,
+//                 candidate: event.candidate.candidate
+//             });
+//         } else {
+//             console.log('End of candidates.');
+//         }
+//     }
+
+//     handleCreateOfferError(event: any) {
+//         console.log('createOffer() error: ', event);
+//     }
+
+//     doCall() {
+//         console.log('Sending offer to peer');
+//         this.pc.createOffer(this.setLocalAndSendMessage, this.handleCreateOfferError);
+//     }
+
+//     doAnswer() {
+//         console.log('Sending answer to peer.');
+//         this.pc.createAnswer().then(
+//             this.setLocalAndSendMessage,
+//             this.onCreateSessionDescriptionError
+//         );
+//     }
+
+//     setLocalAndSendMessage(sessionDescription: any) {
+//         this.pc.setLocalDescription(sessionDescription);
+//         console.log('setLocalAndSendMessage sending message', sessionDescription);
+//         this.sendMessage(sessionDescription);
+//     }
+
+//     onCreateSessionDescriptionError(error: any) {
+//         console.log('Failed to create session description: ' + error.toString());
+//     }
+
+
+//     requestTurn(turnURL: any) {
+//         var turnExists = false;
+//         let self = this;
+//         for (var i in this.pcConfig.iceServers) {
+//             if (this.pcConfig.iceServers[i].urls.substr(0, 5) === 'turn:') {
+//                 turnExists = true;
+//                 this.turnReady = true;
+//                 break;
+//             }
+//         }
+//         if (!turnExists) {
+//             console.log('Getting TURN server from ', turnURL);
+//             // No TURN server. Get one from computeengineondemand.appspot.com:
+//             var xhr = new XMLHttpRequest();
+//             xhr.onreadystatechange = function () {
+//                 if (xhr.readyState === 4 && xhr.status === 200) {
+//                     var turnServer = JSON.parse(xhr.responseText);
+//                     console.log('Got TURN server: ', turnServer);
+//                     self.pcConfig.iceServers.push({
+//                         'urls': 'turn:' + turnServer.username + '@' + turnServer.turn,
+//                         //'credential': turnServer.password
+//                     });
+//                     self.turnReady = true;
+//                 }
+//             };
+//             xhr.open('GET', turnURL, true);
+//             xhr.send();
+//         }
+//     }
+
+//     handleRemoteStreamAdded(event: MediaStreamEvent) {
+//         console.log('Remote stream added.');
+//         this.remoteStream = event.stream!;
+//         this.remoteVideo!.srcObject = this.remoteStream;
+//     }
+
+//     handleRemoteStreamRemoved(event: MediaStreamEvent) {
+//         console.log('Remote stream removed. Event: ', event);
+//     }
+
+//     hangup() {
+//         console.log('Hanging up.');
+//         if (this.pc) {
+//             stop();
+//             this.sendMessage('bye');
+//         }
+
+//         if (this.localStream) {
+//             this.localStream.getTracks().forEach(track => track.stop());
+//         }
+
+//     }
+
+//     handleRemoteHangup() {
+//         console.log('Session terminated.');
+//         stop();
+//         this.isInitiator = false;
+//     }
+
+//     stop() {
+//         this.isStarted = false;
+//         this.pc.close();
+//         this.pc = null;
+//     }
+
+
+// }
\ No newline at end of file