ding

wampInit.js

var autobahn = require("autobahn");

module.exports = new autobahn.Connection({
        url: "ws://188.226.208.149:3000/",
        realm: "realm"
      });

wampMixin.js

'use strict';

var React = require('react');

var WampMixin = {
  componentWillMount: function() {
    this.subscriptions = [];
  },
  subscribe: function(topic, cb){
    var component = this;
    if(typeof connection.session === 'object'){
      connection.session.subscribe(topic, cb)
      .then(
        function(sub){
          component.subscriptions.push(sub);
        },
        function(err){
          console.log(err);
        }
      );
    }
  },
  publish: function(topic, args){
    if(typeof connection.session === 'object'){
      connection.session.publish(topic, args);
    }
  },
  call: function(procedure, args, cb){
    if(typeof connection.session === 'object'){
      connection.session.call(procedure, args)
      .then(
        function(result){
          cb(result);
        },
        function(err){
          console.log(err);
        }
      );
    }
  },
  componentWillUnmount: function(){
    this.subscriptions.map(
      function(sub){
        connection.session.unsubscribe(sub)
        .then(
          function(gone){},
          function(error){
            console.dir(error);
          }
        );
      }
    );
  }
};

module.exports = WampMixin;