ChatRTC/chatrtc.js at master · vedharish/ChatRTC · GitHub

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
var ChatRTC = {
  peers: {},
  dcs: {},

  initName: function(){
    localStorage.sourcePeer = $("#nameBox").val();
    ChatRTC.uiName();
    return false;
  },

  uiName: function(){
    $("#sourceName").text(localStorage.sourcePeer);
    $("#welcomePeer").removeClass("hidden");
    $("#messageContent").removeClass("hidden");
    $("#enterName").addClass("hidden");
  },

  onMessage: function(){
    var message = $("#messageBox").val();
    var elem = $("#chatlog");
    elem.append("["+localStorage.sourcePeer+"] " + message + '<br />');
    $("#messageBox").val('');
    elem.scrollTop(elem.get(0).scrollHeight);
    ChatRTC.sendToDC(message, "message");
    return false;
  },

  onMember: function(){
    var member = $("#memberBox").val();
    ChatRTC.addmember(member);
    $("#memberBox").val('');
    ChatRTC.connectToMember(member);
    return false;
  },

  addmember: function(member){
    $("#memberlog").prepend('<div style="margin: 8px auto;" id="member-'+member+'"><strong>'+member+'</strong><br/><span class="status small">Connecting</span></div>');
  },

  handlerDC: function(chan, member){
    ChatRTC.dcs[member] = chan;
    chan.onerror = function(error) {  }
    chan.onclose = function() {  }

    chan.onopen = function(evt) {
      console.log("data channel opened");
      chan.send(JSON.stringify({data: "connected", type: "message"}));
      ChatRTC.sendToDC(member, "member");
    }

    chan.onmessage = function(e) {
      console.log("data channel received message", e.data);
      var data = JSON.parse(e.data);

      switch(data.type){
        case "message":
          if(data.data == "connected")
            $("#member-" + member + ">.status").text("Connected");

          $("#chatlog").append("["+member+"] " + data.data + '<br />');
          break;

        case "member":
          if(!ChatRTC.peers[data.data] && data.data != localStorage.sourcePeer){
            ChatRTC.addmember(data.data);
            ChatRTC.connectToMember(data.data);
          }
          break;
      }
    }
  },

  sendToDC: function(message, type){
    for(var i in ChatRTC.dcs){
      ChatRTC.dcs[i].send(JSON.stringify({data: message, type: type}));
    }
  },

  connectToMember: function(member){
    var conn = new WebRTC();
    ChatRTC.peers[member] = conn;
    var dc = conn.createDC();
    ChatRTC.handlerDC(dc, member);
    conn.createOffer(function(offer){
      console.log(offer);
      ChatRTC.socket.emit('message', {connectHash: member, source: localStorage.sourcePeer, type: "offer", data: offer});
    });
  },

  receiveRequestFromMember: function(offer, member, source){
    var conn = new WebRTC();
    ChatRTC.peers[source] = conn;
    ChatRTC.addmember(source);
    conn.receiveDC(function(dc){
      ChatRTC.handlerDC(dc, source);
    });
    conn.receiveOfferAndGetAnswer(offer, function(answer){
      console.log(answer);
      ChatRTC.socket.emit('message', {connectHash: source, source: localStorage.sourcePeer, type: "answer", data: answer});
    })
  },

  receiveAnswerFromMember: function(answer, member, source){
    ChatRTC.peers[source].receiveAnswer(answer);
  },

  onSocketIOMessage: function(data){
    console.log(data);
    switch(data.sourceData.type){
      case "offer":
        ChatRTC.receiveRequestFromMember(data.sourceData.data, data.sourceData.connectHash, data.sourceData.source);
        break;

      case "answer":
        ChatRTC.receiveAnswerFromMember(data.sourceData.data, data.sourceData.connectHash, data.sourceData.source);
        break;

    }
  }
}