docs/reference/dsnp.js.html

<!DOCTYPE html>
<html lang="en">
<head>
    <meta charset="utf-8">
    <title>JSDoc: Source: dsnp.js</title>

    <script src="scripts/prettify/prettify.js"> </script>
    <script src="scripts/prettify/lang-css.js"> </script>
    <!--[if lt IE 9]>
      <script src="//html5shiv.googlecode.com/svn/trunk/html5.js"></script>
    <![endif]-->
    <link type="text/css" rel="stylesheet" href="styles/prettify-tomorrow.css">
    <link type="text/css" rel="stylesheet" href="styles/jsdoc-default.css">
</head>

<body>

<div id="main">

    <h1 class="page-title">Source: dsnp.js</h1>

    
    <section>
        <article>
            <pre class="prettyprint source linenums"><code>/*!
 * dsnp.js - decentralized session negotiation plugin for bcoin
 * Copyright (c) 2017, QwertyPie (MIT License).
 * https://github.com/Patrickdlg/bDSNP
 */

'use strict';

const EventEmitter = require('events');
const NodeStatic = require('node-static');
const WebSocketServer = require('websocket').server;
const HTTP = require('http');

class DSNP extends EventEmitter{
  /**
   * Create a plugin.
   * @constructor
   * @param {Options} options
   */
  constructor(options) {
    super();
    this.network = options.network
    this.init();
  }

  /**
   * initialize signaling services
   */
  init(){
     console.log('[DSNP] initializing DSNP server over network: %s', this.network);
     this.clients = []
     this.initHttpServer();
     this.initWebSocketServer();
     this.httpApp.listen(12034);
  }

  /**
   * initialize the http server for healthcheck/static content
   */
  initHttpServer(){
    console.log('[DSNP] creating DSNP HTTP endpoint');
    var file = new NodeStatic.Server(__dirname.replace('lib', 'www'));
    this.httpApp = HTTP.createServer(function(request, response) {
      request.addListener('end', function() {
        file.serve(request, response);
      }).resume();
    });
  }

  /**
   * initialize the web socket server for signaling
   */
  initWebSocketServer(){
    console.log('[DSNP] creating DSNP Web Socket server');
    this.wsApp = new WebSocketServer({
      httpServer: this.httpApp,
      autoAcceptConnections: false
    }).on('request', this.onRequest.bind(this));
  }

  onRequest(socket){
    var origin = socket.origin + socket.resource;
    console.log('[DSNP] received request from: %s', origin)
    var websocket = socket.accept(null, origin);
    this.clients.push(websocket);
    var self = this;
    websocket.on('message', function(message) {
      self.handleMessage(websocket, message)});
    websocket.on('close', function() {
      self.removeClient(websocket);});
  }

  handleMessage(websocket, message){
    if (message.type === 'utf8') {
      console.log('[DSNP] broadcasting utf8 data', message.utf8Data);
      this.clients.forEach(function(previousSocket) {
        if (previousSocket != websocket) previousSocket.sendUTF(message.utf8Data);
    });}
    else if (message.type === 'binary') {
      console.log('[DSNP] broadcasting binary data', message.binaryData);
      this.clients.forEach(function(previousSocket) {
        if (previousSocket != websocket) previousSocket.sendBytes(message.binaryData);
      });
    }
  }

  removeClient(websocket){
    var newClientsArray = [];
    for (var i = 0; i &lt; this.clients.length; i++) {
      var previousSocket = this.clients[i];
      if (previousSocket != websocket) newClientsArray.push(previousSocket);
    }
    this.clients = newClientsArray;
  }


}

module.exports = DSNP
</code></pre>
        </article>
    </section>


</div>

<nav>
    <h2><a href="index.html">Home</a></h2><h3>Modules</h3><ul><li><a href="module-plugin.html">plugin</a></li></ul><h3>Classes</h3><ul><li><a href="DSNP.html">DSNP</a></li><li><a href="module-plugin-Plugin.html">Plugin</a></li></ul>
</nav>

<br class="clear">

<footer>
    Documentation generated by <a href="https://github.com/jsdoc3/jsdoc">JSDoc 3.5.5</a> on Sun Apr 08 2018 15:56:16 GMT-0700 (PDT)
</footer>

<script> prettyPrint(); </script>
<script src="scripts/linenumber.js"> </script>
</body>
</html>