index.js

'use strict';

import { NativeEventEmitter, NativeModules, Platform } from 'react-native';

let SocketIO = NativeModules.SocketIO;
let SocketIOEventManager = new NativeEventEmitter(NativeModules.SocketIO);

class Socket {
  constructor (host, config) {

    if (typeof host === 'undefined')
      throw 'Hello there! Could you please give socket a host, please.';
    if (typeof config === 'undefined')
      config = {};

    this.sockets = SocketIO;
    this.isConnected = false;
    this.handlers = {};
    this.onAnyHandler = null;

    this.deviceEventSubscription = SocketIOEventManager.addListener(
      'socketEvent', this._handleEvent.bind(this)
    );

    // Set default handlers
    this.defaultHandlers = {
      connect: () => {
        this.isConnected = true;
      },

      disconnect: () => {
        this.isConnected = false;
      }
    };


    if (Platform.OS === 'android') {
      if(config.nsp) {
        host = host + config.nsp;
        delete config['nsp'];
      }
      if(config.connectParams) {
        var str = Object.keys(config.connectParams).map(function(key){
          return encodeURIComponent(key) + '=' + encodeURIComponent(config.connectParams[key]);
        }).join('&');
        config['query'] = str;
      }
    }

    // Set initial configuration
    this.sockets.initialize(host, config);
  }

  _handleEvent (event) {
    if (this.handlers.hasOwnProperty(event.name)) {
      this.handlers[event.name](
        (event.hasOwnProperty('items')) ? event.items : null
      );
    }
    if (this.defaultHandlers.hasOwnProperty(event.name)) {
      this.defaultHandlers[event.name]();
    }

    if (this.onAnyHandler) this.onAnyHandler(event);
  }

  connect () {
    this.sockets.connect();
  }

  on (event, handler) {
    this.handlers[event] = handler;
    if (Platform.OS === 'android') {
      this.sockets.on(event);
    }
  }

  onAny (handler) {
    this.onAnyHandler = handler;
  }

  emit (event, data) {
    this.sockets.emit(event, data);
  }

  joinNamespace (namespace) {
    this.sockets.joinNamespace(namespace);
  }

  leaveNamespace () {
    this.sockets.leaveNamespace();
  }

  disconnect () {
    this.handlers = {};
    this.onAnyHandler = null;
    this.sockets.disconnect();
  }

  reconnect () {
    this.sockets.reconnect();
  }
}

module.exports = Socket;