/******************************************************************************
* (c) 2005-2015 Copyright, Real-Time Innovations.  All rights reserved.       *
* No duplications, whole or partial, manual or electronic, may be made        *
* without express written permission.  Any such copies, or revisions thereof, *
* must display this notice unaltered.                                         *
* This code contains trade secrets of Real-Time Innovations, Inc.             *
******************************************************************************/

var os = require('os');
var ffi = require("ffi");
var util = require('util');
EventEmitter = require('events').EventEmitter

var LIB_FULL_PATH = "";

if (os.arch()=='x64') {
  switch (os.platform()) {
    case 'darwin':
      LIB_FULL_PATH = __dirname + '/lib/x64Darwin12clang4.1/librti_dds_connector.dylib';
      break;
    case 'linux':
      LIB_FULL_PATH = __dirname + '/lib/x64Linux2.6gcc4.4.5/librti_dds_connector.so';
      break;
    case 'win32':
      LIB_FULL_PATH = __dirname + '/lib/x64Win64VS2013/rti_dds_connector.dll';
      break;
    default:
      console.log(os.platform() + ' not yet supported');
  }
} else if (os.arch() == 'ia32') {
  switch (os.platform()) {
    case 'linux':
      LIB_FULL_PATH = __dirname + '/lib/i86Linux3.xgcc4.6.3/librti_dds_connector.so';
      break;
    case 'win32':
      LIB_FULL_PATH = __dirname + '/lib/i86Win32VS2010/rti_dds_connector.dll';
      break;
    default:
      console.log(os.platform() + ' not yet supported');
  }
} else if (os.arch() == 'arm') {
  switch (os.platform()) {
    case 'linux':
      LIB_FULL_PATH = __dirname + '/lib/armv6vfphLinux3.xgcc4.7.2/librti_dds_connector.so';
      break;
    default:
      console.log(os.platform() + ' not yet supported');
  }
}

var rtin = ffi.Library(LIB_FULL_PATH, {
"RTIDDSConnector_new": [ "pointer", ["string", "string", "pointer"]],
"RTIDDSConnector_getSamplesLength": [ "double", ["pointer", "string"]],
"RTIDDSConnector_getInfosLength": [ "double", ["pointer", "string"]],
"RTIDDSConnector_clear": ["void", ["pointer", "string"]],
"RTIDDSConnector_setNumberIntoSamples": [ "void", ["pointer", "string", "string", "double"]],
"RTIDDSConnector_getNumberFromSamples": [ "double", ["pointer", "string", "int", "string"]],
"RTIDDSConnector_getNumberFromInfos": [ "double", ["pointer", "string", "int", "string"]],
"RTIDDSConnector_setBooleanIntoSamples": [ "void", ["pointer", "string", "string", "int"]],
"RTIDDSConnector_getBooleanFromSamples": [ "int", ["pointer", "string", "int", "string"]],
"RTIDDSConnector_getBooleanFromInfos": [ "int", ["pointer", "string", "int", "string"]],
"RTIDDSConnector_setStringIntoSamples": [ "void", ["pointer", "string", "string", "string"]],
"RTIDDSConnector_getStringFromSamples": [ "string", ["pointer", "string", "int", "string"]],
"RTIDDSConnector_getStringFromInfos": [ "string", ["pointer", "string", "int", "string"]],
"RTIDDSConnector_write": [ "void", ["pointer", "string"]],
"RTIDDSConnector_read": [ "void", ["pointer", "string"]],
"RTIDDSConnector_take": [ "void", ["pointer", "string"]],
"RTIDDSConnector_wait": [ "int", ["pointer", "int"]],
"RTIDDSConnector_getJSONSample": [ "string", ["pointer", "string", "int"]],
"RTIDDSConnector_setJSONInstance": [ "void", ["pointer", "string", "string"]],
"RTIDDSConnector_delete": [ "void", ["pointer"]],
"RTIDDSConnector_getWriter": [ "pointer", ["pointer","string"]],
"RTIDDSConnector_getReader": [ "pointer", ["pointer","string"]],
});


function Samples(input) {

  this.getLength = function() {
    return rtin.RTIDDSConnector_getSamplesLength(input.connector.native,input.name);
  }

  this.getNumber = function(index, fieldName) {
    return rtin.RTIDDSConnector_getNumberFromSamples(input.connector.native,input.name,index,fieldName);
  }

  this.getBoolean = function(index, fieldName) {
    return rtin.RTIDDSConnector_getBooleanFromSamples(input.connector.native,input.name,index,fieldName);
  }

  this.getString = function(index, fieldName) {
    return rtin.RTIDDSConnector_getStringFromSamples(input.connector.native,input.name,index,fieldName);
  }

  this.getJSON = function(index) {
    var jsonObj;
    try {
      jsonObj = JSON.parse(rtin.RTIDDSConnector_getJSONSample(input.connector.native, input.name, index));
    } catch (err) {
      throw err;
    }
    return jsonObj;
  }

}

function Infos(input) {

  this.getLength = function() {
    return rtin.RTIDDSConnector_getInfosLength(input.connector.native,input.name);
  }

  this.isValid = function(index) {
    return rtin.RTIDDSConnector_getBooleanFromInfos(input.connector.native,input.name,index,'valid_data');
  }

}

function Input(connector,name) {
  this.connector = connector;
  this.name = name;
  this.native = rtin.RTIDDSConnector_getReader(this.connector.native,
    this.name);
  if (this.native.isNull()){
    throw new Error("Invalid Subscription::DataReader name")
  }
  this.samples = new Samples(this)
  this.infos = new Infos(this);

  this.read = function() {
    rtin.RTIDDSConnector_read(this.connector.native,name);
  }

  this.take = function() {
    rtin.RTIDDSConnector_take(this.connector.native,name);
  }
}


function Instance(output) {

  this.setNumber = function(fieldName, value) {
    rtin.RTIDDSConnector_setNumberIntoSamples(output.connector.native,output.name,fieldName,value);
  }

  this.setBoolean = function(fieldName, value) {
    rtin.RTIDDSConnector_setBooleanIntoSamples(output.connector.native,output.name,fieldName,value);
  }

  this.setString = function(fieldName, value) {
    try{
      rtin.RTIDDSConnector_setStringIntoSamples(output.connector.native,output.name,fieldName,value);
    }catch(TypeError)
    {
      throw Error(util.format("value of field:%s should be of type String."+
        "Got: %s",fieldName,typeof value))
    }
  }

  this.setFromJSON = function(jsonObj) {
    rtin.RTIDDSConnector_setJSONInstance(output.connector.native,output.name, JSON.stringify(jsonObj));
  }

}


function Output(connector,name) {
  this.connector = connector;
  this.name = name;
  this.native = rtin.RTIDDSConnector_getWriter(this.connector.native,
    this.name);
  if (this.native.isNull()){
    throw new Error("Invalid Publication::DataWriter name")
  }
  this.instance = new Instance(this)

  this.write = function() {
    return rtin.RTIDDSConnector_write(this.connector.native,name);
  }

  this.clear_members = function() {
      return rtin.RTIDDSConnector_clear(this.connector.native,name);
  }
}

function Connector(configName,fileName) {
  this.native = rtin.RTIDDSConnector_new(configName,fileName,null);
  if (this.native.isNull()){
    throw new Error("Invalid participant profile, xml path or xml profile")
  }
  var on_data_available_run = false;

  this.delete = function() {
    return rtin.RTIDDSConnector_delete(this.native);
  }

  this.getInput = function(inputName) {
    return new Input(this,inputName);
  }

  this.getOutput = function(outputName) {
    return new Output(this,outputName);
  }

  var onDataAvailable = function(connector) {
      var rc = rtin.RTIDDSConnector_wait.async(
          connector.native, -1,
          function(err, res) {
            if (err) throw err;
            if (on_data_available_run == true) {
              onDataAvailable(connector);
            }
            connector.emit("on_data_available");
          }
      );
  }

  var newListenerCallBack = function(eventName, fnListener) {
    if (eventName=='on_data_available') {
      if (on_data_available_run == false) {
        on_data_available_run = true;
        onDataAvailable(this);
      }
    }
  }

  this.on('newListener', newListenerCallBack);

  var removeListenerCallBack = function(eventName, fnListener) {
    if (EventEmitter.listenerCount(this, eventName) == 0) {
      on_data_available_run = false;
    }
  }

  this.on('removeListener', removeListenerCallBack);

}

util.inherits(Connector,EventEmitter);

module.exports.Connector = Connector;