code refactoring

Author: Gourav Dwivedi

src/js/components/logic/app.logic.js

@@ -0,0 +1,66 @@
+import * as appSignalR from './lib/app.signalr';
+
+var sr = null;
+class AppLogic {
+
+    constructor() {
+        this.isTokenRequired = false;
+        this.isBasicView = true;
+    }
+
+    Init(options) {
+
+        if(this.isBasicView !== true && this.isTokenRequired === true) {
+            //adding new property to options object
+            options["isTokenRequired"] = true;
+        } 
+        else {
+            options["isTokenRequired"] = false;
+        }
+        
+        sr = new appSignalR.SignalRApp(options.url);
+        sr.Init(options);        
+    }
+    
+    OnConnect() {
+        sr.OnConnect();
+    }
+    
+    OnSend(options) {
+        sr.OnSend(options);
+    }
+    
+    OnReceive(callback) { 
+        sr.OnReceive(callback);
+    }
+    
+    OnDisConnect() { 
+        sr.OnDisConnect();
+    }
+
+    EnableAuth() {
+        this.isTokenRequired = true;
+    }
+
+    DisableAuth() {
+        this.isTokenRequired = false;
+    }
+
+    IsAuthEnabled() {
+        return this.isTokenRequired;
+    }
+
+    GetCurrentView() {
+        return this.isBasicView;
+    }
+
+    SetCurrentViewAsBasic() {
+        this.isBasicView = true;
+    }
+
+    SetCurrentViewAsAdvance() {
+        this.isBasicView = false;
+    }
+}
+
+export { AppLogic }

src/js/components/logic/lib/app.common.js

@@ -0,0 +1,11 @@
+import mitt from 'mitt';
+
+const ContentType = { 
+    TEXT : "Text",
+    NUMBER : "Number",
+    JSON : "JSON"
+}
+
+const AppEvents = mitt();
+
+export { ContentType, AppEvents };

src/js/components/logic/lib/app.signalr.js

@@ -0,0 +1,77 @@
+import * as signalR from "@aspnet/signalr";
+import { AppEvents } from './app.common';
+
+var storeFunc = null;
+class SignalRApp {
+    constructor(url) {
+        this.url = url;
+        this.connection = null;
+        this.isConnected = false;        
+    }
+
+    Init(options) {
+
+        if(options.isTokenRequired === true) {
+            options.accessTokenFactory = () => options.getToken();
+        }
+        
+        this.connection = new signalR.HubConnectionBuilder()
+            .withUrl(options.url, options)
+            .configureLogging(signalR.LogLevel.Information)
+            .build();
+    
+
+        //Receive Data
+        //Reading the raw response
+        var self = this;
+        storeFunc = self.connection.processIncomingData;
+        self.connection.processIncomingData = function (data) {
+            console.log('processIncomingData'+ data);
+            storeFunc.call(self.connection, data);
+        }
+        debugger;
+        AppEvents.emit('Init', options);
+    }
+    
+    
+    OnConnect() {
+        var self = this;
+        self.connection.start()
+            .then(function () {
+                AppEvents.emit('OnConnect', { url: self.url });
+            })
+            .catch(function (err) {
+                return console.error(err.toString());
+            });
+    }
+    
+    OnSend(options) {
+        var methodArguments = new Array();
+        methodArguments = options.methodArguments;
+    
+        AppEvents.emit('OnSend', options);
+        this.connection.invoke(options.methodName, ...methodArguments)
+            .catch(function (err) {
+                return console.log(err);
+            });
+    }
+    
+    OnReceive(callback) {
+        this.connection.on("ReceiveData", function (data) {
+            callback(data);
+        });
+    }
+    
+    OnDisConnect() {
+        this.connection.stop()
+            .then(function () {
+                console.log('Disconnected');
+                AppEvents.emit('OnDisconnected');
+            })
+            .catch(function (err) {
+                return console.error(err.toString());
+            });
+    }
+}
+
+export { SignalRApp }