2.5.14-alpha

Author: JamieRuderman

backend/package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "remoteit-headless",
-  "version": "2.5.13-alpha",
+  "version": "2.5.14-alpha",
   "private": true,
   "main": "build/index.js",
   "scripts": {

backend/package.json

@@ -0,0 +1,84 @@
+import WebSocket from 'ws'
+
+type ICallback = (payload: IPayload) => void
+
+export default class CLIWebSocket {
+  onConnect?: ICallback
+  onClose?: ICallback
+  onError?: ICallback
+  onDataReceived?: ICallback
+  private _ws: any
+  private _url: string
+  private _reconnect: boolean = true
+  private _delayInMsBeforeReconnect: number = 1000
+  private _onMessageReceived: { [key: string]: ICallback } = {}
+
+  constructor(url: string) {
+    this._url = url
+    this.setUpConnection()
+  }
+
+  public send(type: string, data: any) {
+    console.log('--------------')
+    console.trace()
+    console.log('--------------')
+    console.log('type', type)
+    console.log('--------------')
+    console.log('data', data)
+    console.log('--------------')
+    const dataAsString = JSON.stringify({
+      Type: type,
+      Data: data,
+    })
+
+    this._ws.send(dataAsString)
+  }
+
+  public on(type: string, callback: ICallback) {
+    this._onMessageReceived[type] = callback
+  }
+
+  private setUpConnection() {
+    this._ws = new WebSocket(this._url)
+
+    this._ws.onclose = (event: any) => {
+      const response = JSON.parse(event.data)
+
+      if (typeof this.onClose === 'function') {
+        this.onClose(response)
+      }
+
+      if (this._reconnect) {
+        setTimeout(() => this.setUpConnection, this._delayInMsBeforeReconnect)
+      }
+    }
+
+    this._ws.onopen = (response: any) => {
+      if (typeof this.onConnect === 'function') {
+        this.onConnect(response)
+      }
+    }
+
+    // WHEN data received, then de-serialize and pass up the chain
+    this._ws.onmessage = (event: any) => {
+      const response = JSON.parse(event.data)
+
+      if (typeof this.onDataReceived === 'function') {
+        this.onDataReceived(response)
+      }
+
+      if (typeof this._onMessageReceived[response.type] === 'function') {
+        this._onMessageReceived[response.type](response)
+      }
+    }
+
+    // IF errors just notify
+    this._ws.onerror = (event: any) => {
+      const response = JSON.parse(event.data)
+
+      if (typeof this.onError === 'function') {
+        this.onError(response)
+      }
+    }
+  }
+}

backend/src/CLIWebSocket.ts

@@ -0,0 +1,137 @@
+import server from './server'
+import Logger from './Logger'
+import EventBus from './EventBus'
+import CLIWebSocket from './CLIWebSocket'
+import { WEBSOCKET_URL } from './constants'
+
+class CLIController {
+  private socket: CLIWebSocket
+
+  constructor() {
+    Logger.info('START CLI CONTROLLER')
+    this.socket = new CLIWebSocket(WEBSOCKET_URL)
+    this.addHandlers()
+    EventBus.on(server.EVENTS.authenticated, this.ready)
+  }
+
+  ready = () => {
+    // this.socket.send('GetConnections', [])
+  }
+
+  send = (channel: string, data: object) => {
+    this.socket.send(channel, data)
+  }
+
+  addHandlers = () => {
+    this.socket.onConnect = () => console.log('onConnect')
+    this.socket.onClose = () => console.log('onClose')
+    this.socket.onError = () => console.warn('onError')
+
+    this.socket.on('GetConnections', (response: IPayload) => {
+      console.log('socket.on-GetConnections')
+      if (response.hasError) {
+        console.log('	error: ', response.errorMessage)
+      } else {
+        console.log('	data:', response.data)
+      }
+    })
+
+    this.socket.on('SetConnections', (response: IPayload) => {
+      console.log('socket.on-SetConnections')
+      if (response.hasError) {
+        console.log('	error: ', response.errorMessage)
+      }
+    })
+
+    this.socket.on('GetAuth', (response: IPayload) => {
+      console.log('socket.on-GetAuth')
+      if (response.hasError) {
+        console.log('	error: ', response.errorMessage)
+      } else {
+        console.log('	data:', response.data)
+      }
+    })
+
+    this.socket.on('SetAuth', (response: IPayload) => {
+      console.log('socket.on-SetAuth')
+      if (response.hasError) {
+        console.log('	error: ', response.errorMessage)
+      }
+    })
+
+    this.socket.on('Forget', (response: IPayload) => {
+      console.log('socket.on-Forget')
+      if (response.hasError) {
+        console.log('	error: ', response.errorMessage)
+      } else {
+        console.log('	data:', response.data)
+      }
+    })
+  }
+}
+
+export default new CLIController()
+
+/* 
+
+ACTION EXAMPLES
+
+function GetConnections() {
+  var object = {}
+
+  socket.Send('GetConnections', object)
+}
+function SetConnections() {
+  var object = {
+    connections: [
+      {
+        uid: '80:00:00:00:01:01:8E:EE',
+        name: '',
+        port: 25185,
+        hostname: 'localhost',
+        disabled: false,
+        retry: true,
+        failover: true,
+        restart: false,
+        createdTime: 0,
+        owner: '',
+        restriction: '',
+        connected: false,
+        connecting: false,
+        error: {
+          code: 0,
+          errorMessage: '',
+        },
+        startTime: 0,
+        stopTime: 0,
+        metadata: null,
+      },
+    ],
+  }
+
+  socket.Send('SetConnections', object)
+}
+
+function GetAuth() {
+  var object = {}
+
+  socket.Send('GetAuth', object)
+}
+function SetAuth() {
+  var object = {
+    authHash:
+      'hVYwtk/RhKZMDDFVf9SfIjNHCp9e/J+VHGHsXRP5Xeohd+5BHnEjI+MwBDEles+EUi/FF6ZNDki98eJu2D5ew1EtJ7pQc0hKNBqgJcqwEb4=',
+    userName: 'nicolae@remote.it',
+  }
+
+  socket.Send('SetAuth', object)
+}
+
+function Forget() {
+  var object = {
+    uid: '80:00:00:00:01:01:8E:EE',
+  }
+
+  socket.Send('Forget', object)
+}
+ */

backend/src/cliController.ts

@@ -1,6 +1,6 @@
 {
   "name": "remoteit-desktop-frontend",
-  "version": "2.5.13-alpha",
+  "version": "2.5.14-alpha",
   "private": true,
   "main": "src/server/initialize.js",
   "scripts": {

frontend/package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "remoteit-desktop",
-  "version": "2.5.13-alpha",
+  "version": "2.5.14-alpha",
   "private": true,
   "main": "build/index.js",
   "description": "remote.it cross platform desktop application for creating and hosting connections",