Thomasconner add nativescript support (#117)

* Add NativeScript support

* Add tests for NativeScript

* Replace React-Native with NativeScript in NativeScript tests

* Fix support for nativescript

* Add tasks for to gulpfile for nativescript

* Create dist for nativescript

* Update .gitignore for nativescript

* Remove NativeScript dist bundle

* Use NativeScript http module

* Remove some Gulp tasks related to NativeScript

* Update compiled modules

* Update dist bundles

* Replace all uses of uuid with lil-uuid

* Fix error detection for NartiveScript network module

* Check if abort is a function before calling it

Some platforms don't return an object that contains an abort function to cancel network requests. This change checks if an abort function is available before calling it.

* Update all the builds

* add entry point to app with Native Script

* resolve eslint issues

* add operation delete to native script

* remove multi-spaces

Author: ManuelFernando

package.json

@@ -9,6 +9,7 @@
   },
   "main": "./lib/node/index.js",
   "react-native": "./lib/react_native/index.js",
+  "nativescript": "./lib/nativescript/index.js",
   "browser": "./dist/web/pubnub.min.js",
   "repository": {
     "type": "git",

src/core/components/subscription_manager.js

@@ -497,7 +497,9 @@ export default class {
 
   _stopSubscribeLoop() {
     if (this._subscribeCall) {
-      this._subscribeCall.abort();
+      if (typeof this._subscribeCall.abort === 'function') {
+        this._subscribeCall.abort();
+      }
       this._subscribeCall = null;
     }
   }

src/nativescript/index.js

@@ -0,0 +1,16 @@
+/* @flow */
+
+import PubNubCore from '../core/pubnub-common';
+import Networking from '../networking';
+import Database from '../db/common';
+import { del, get, post } from '../networking/modules/nativescript';
+import { InternalSetupStruct } from '../core/flow_interfaces';
+
+export default class extends PubNubCore {
+  constructor(setup: InternalSetupStruct) {
+    setup.db = new Database();
+    setup.networking = new Networking({ del, get, post });
+    setup.sdkFamily = 'NativeScript';
+    super(setup);
+  }
+}

src/networking/modules/nativescript.js

@@ -0,0 +1,76 @@
+/* @flow */
+
+import { request as HttpRequest } from 'http';
+import { EndpointDefinition, StatusAnnouncement } from '../../core/flow_interfaces';
+import { buildUrl } from '../utils';
+
+function log(url, qs, res) {
+  let _pickLogger = () => {
+    if (console && console.log) return console; // eslint-disable-line no-console
+    return console;
+  };
+
+  let start = new Date().getTime();
+  let timestamp = new Date().toISOString();
+  let logger = _pickLogger();
+  logger.log('<<<<<'); // eslint-disable-line no-console
+  logger.log(`[${timestamp}]`, '\n', url, '\n', qs); // eslint-disable-line no-console
+  logger.log('-----'); // eslint-disable-line no-console
+
+  let now = new Date().getTime();
+  let elapsed = now - start;
+  let timestampDone = new Date().toISOString();
+
+  logger.log('>>>>>>'); // eslint-disable-line no-console
+  logger.log(`[${timestampDone} / ${elapsed}]`, '\n', url, '\n', qs, '\n', res); // eslint-disable-line no-console
+  logger.log('-----'); // eslint-disable-line no-console
+}
+
+function xdr(method: string, url: string, params: Object, body: string, endpoint: EndpointDefinition, callback: Function): void {
+  let status: StatusAnnouncement = {};
+  status.operation = endpoint.operation;
+
+  // $FlowFixMe
+  return HttpRequest({
+    method,
+    url: buildUrl(url, params),
+    content: body,
+    timeout: endpoint.timeout
+  }).then((response) => {
+    status.error = false;
+
+    if (response.statusCode) {
+      status.statusCode = response.statusCode;
+    }
+
+    return response.content.toJSON();
+  }).then((response) => {
+    let resp = response;
+
+    if (this._config.logVerbosity) {
+      log(url, params, resp);
+    }
+
+    callback(status, resp);
+  }).catch((e) => {
+    status.error = true;
+    status.errorData = e;
+    status.category = this._detectErrorCategory(e);
+    callback(status, null);
+  });
+}
+
+export function get(params: Object, endpoint: EndpointDefinition, callback: Function) {
+  let url = this.getStandardOrigin() + endpoint.url;
+  return xdr.call(this, 'GET', url, params, '', endpoint, callback);
+}
+
+export function post(params: Object, body: string, endpoint: EndpointDefinition, callback: Function) {
+  let url = this.getStandardOrigin() + endpoint.url;
+  return xdr.call(this, 'POST', url, params, body, endpoint, callback);
+}
+
+export function del(params: Object, endpoint: EndpointDefinition, callback: Function) {
+  let url = this.getStandardOrigin() + endpoint.url;
+  return xdr.call(this, 'DELETE', url, params, {}, endpoint, callback);
+}