fiatjaf · October 12, 2016 22:21
diff --git a/README.md b/README.md
diff --git a/app.js b/app.js
 var config = {'iceServers': []}
 var peer = new RTCPeerConnection(config)

 var me
 var other

 var channel

 peer.ondatachannel = function (e) {
  channel = e.channel
  channel.onopen = e => console.log('channel opened', e)
  channel.onclose = e => console.log('channel closed', e)
  channel.onmessage = e => console.log('got message', e)
 }

 peer.onicecandidate = function (e) {
  if (!e.candidate) return
  console.log('got ice candidate', e)
  ws.send(JSON.stringify({
    action: 'candidate',
    to: other,
    data: e.candidate
  }))
 }

 var ws = new WebSocket('ws://ws-server:8088')
 ws.onopen = e => console.log('websocket opened')
 ws.onclose = e => console.log('websocket closed')
 ws.onmessage = e => {
  console.log('websocket message', e.data)
  var data = JSON.parse(e.data)
  if (data.to === me) {
    switch (data.action) {
      case 'candidate':
        peer.addIceCandidate(new RTCIceCandidate(data.data))
          .then(() => console.log('added ice candidate'))
          .catch(e => console.log('add ice error', e))
        break
      case 'offer':
        peer.setRemoteDescription(new RTCSessionDescription(data.data))
          .then(() => peer.createAnswer())
          .then(sdp => {
            ws.send(JSON.stringify({
              action: 'answer',
              to: other,
              data: sdp
            }))
            peer.setLocalDescription(sdp)
          })
          .then(() => console.log('offer handled'))
          .catch(e => console.log('error handling offer', e))
        break
      case 'answer':
        peer.setRemoteDescription(new RTCSessionDescription(data.data))
          .then(() => console.log('answer handled'))
          .catch(e => console.log('error handling answer', e))
        break
    }
  }
 }

 // trigger connection
 function connect () {
  channel = peer.createDataChannel('main-channel')
  channel.onopen = e => console.log('channel opened', e)
  channel.onclose = e => console.log('channel closed', e)
  channel.onmessage = e => console.log('got message', e)

  peer.createOffer()
    .then(sdp => {
      peer.setLocalDescription(sdp)
      ws.send(JSON.stringify({
        action: 'offer',
        to: other,
        data: sdp
      }))
    })
    .catch(e => console.log('error creating and sending offer', e))
 }
diff --git a/index.html b/index.html
 <!doctype html>

 <script src="https://webrtc.github.io/adapter/adapter-latest.js"></script>
 <script src="app.js"></script>
diff --git a/ws-server.js b/ws-server.js
 var WebSocketServer = require('ws').Server
 var wss = new WebSocketServer({port: 8088})

 var wsList = []

 wss.on('connection', function (ws) { 
  console.log('WS connection established!')
  wsList.push(ws)

  ws.on('close', function () { 
    wsList.splice(wsList.indexOf(ws), 1)
    console.log('WS closed!')
  })

  ws.on('message', function (message) { 
    console.log('got ws message: ' + message)
    // send to everybody on the site
    wsList.forEach(function (ws) { 
      ws.send(message)
    })
  })
 })
	var config = {'iceServers': []}
	var peer = new RTCPeerConnection(config)

	var me
	var other

	var channel

	peer.ondatachannel = function (e) {
	channel = e.channel
	channel.onopen = e => console.log('channel opened', e)
	channel.onclose = e => console.log('channel closed', e)
	channel.onmessage = e => console.log('got message', e)
	}

	peer.onicecandidate = function (e) {
	if (!e.candidate) return
	console.log('got ice candidate', e)
	ws.send(JSON.stringify({
	action: 'candidate',
	to: other,
	data: e.candidate
	}))
	}

	var ws = new WebSocket('ws://ws-server:8088')
	ws.onopen = e => console.log('websocket opened')
	ws.onclose = e => console.log('websocket closed')
	ws.onmessage = e => {
	console.log('websocket message', e.data)
	var data = JSON.parse(e.data)
	if (data.to === me) {
	switch (data.action) {
	case 'candidate':
	peer.addIceCandidate(new RTCIceCandidate(data.data))
	.then(() => console.log('added ice candidate'))
	.catch(e => console.log('add ice error', e))
	break
	case 'offer':
	peer.setRemoteDescription(new RTCSessionDescription(data.data))
	.then(() => peer.createAnswer())
	.then(sdp => {
	ws.send(JSON.stringify({
	action: 'answer',
	to: other,
	data: sdp
	}))
	peer.setLocalDescription(sdp)
	})
	.then(() => console.log('offer handled'))
	.catch(e => console.log('error handling offer', e))
	break
	case 'answer':
	peer.setRemoteDescription(new RTCSessionDescription(data.data))
	.then(() => console.log('answer handled'))
	.catch(e => console.log('error handling answer', e))
	break
	}
	}
	}

	// trigger connection
	function connect () {
	channel = peer.createDataChannel('main-channel')
	channel.onopen = e => console.log('channel opened', e)
	channel.onclose = e => console.log('channel closed', e)
	channel.onmessage = e => console.log('got message', e)

	peer.createOffer()
	.then(sdp => {
	peer.setLocalDescription(sdp)
	ws.send(JSON.stringify({
	action: 'offer',
	to: other,
	data: sdp
	}))
	})
	.catch(e => console.log('error creating and sending offer', e))
	}
	<!doctype html>

	<script src="https://webrtc.github.io/adapter/adapter-latest.js"></script>
	<script src="app.js"></script>
	var WebSocketServer = require('ws').Server
	var wss = new WebSocketServer({port: 8088})

	var wsList = []

	wss.on('connection', function (ws) {
	console.log('WS connection established!')
	wsList.push(ws)

	ws.on('close', function () {
	wsList.splice(wsList.indexOf(ws), 1)
	console.log('WS closed!')
	})

	ws.on('message', function (message) {
	console.log('got ws message: ' + message)
	// send to everybody on the site
	wsList.forEach(function (ws) {
	ws.send(message)
	})
	})
	})