add nodered page

Author: skadefro

OpenFlow/src/public/Controllers.ts

@@ -1545,4 +1545,97 @@ module openflow {
             document.getElementById('visual').innerHTML = jsondiffpatch.formatters.html.format(model.delta, model.item);
         }
     }
+
+    export class NoderedCtrl {
+        public static $inject = [
+            "$scope",
+            "$location",
+            "$routeParams",
+            "WebSocketClient",
+            "api"
+        ];
+        public messages: string = "";
+        public queuename: string = "webtest";
+        public message: string = "Hi mom";
+        public noderedurl: string = "";
+        constructor(
+            public $scope: ng.IScope,
+            public $location: ng.ILocationService,
+            public $routeParams: ng.route.IRouteParamsService,
+            public WebSocketClient: WebSocketClient,
+            public api: api
+        ) {
+            console.debug("NoderedCtrl");
+            WebSocketClient.onSignedin(async (user: TokenUser) => {
+                await api.RegisterQueue();
+                this.noderedurl = WebSocketClient.nodered_domain_schema.replace("$nodered_id$", WebSocketClient.user.username);
+            });
+        }
+
+        async EnsureNoderedInstance() {
+            try {
+                await this.api.EnsureNoderedInstance();
+                this.messages += "EnsureNoderedInstance completed" + "\n";
+            } catch (error) {
+                this.messages += error + "\n";
+                console.error(error);
+            }
+            if (!this.$scope.$$phase) { this.$scope.$apply(); }
+        }
+        async DeleteNoderedInstance() {
+            try {
+                await this.api.DeleteNoderedInstance();
+                this.messages += "DeleteNoderedInstance completed" + "\n";
+            } catch (error) {
+                this.messages += error + "\n";
+                console.error(error);
+            }
+            if (!this.$scope.$$phase) { this.$scope.$apply(); }
+        }
+        async RestartNoderedInstance() {
+            try {
+                await this.api.RestartNoderedInstance();
+                this.messages += "RestartNoderedInstance completed" + "\n";
+            } catch (error) {
+                this.messages += error + "\n";
+                console.error(error);
+            }
+            if (!this.$scope.$$phase) { this.$scope.$apply(); }
+        }
+        async StartNoderedInstance() {
+            try {
+                await this.api.StartNoderedInstance();
+                this.messages += "StartNoderedInstance completed" + "\n";
+            } catch (error) {
+                this.messages += error + "\n";
+                console.error(error);
+            }
+            if (!this.$scope.$$phase) { this.$scope.$apply(); }
+        }
+        async StopNoderedInstance() {
+            try {
+                await this.api.StopNoderedInstance();
+                this.messages += "StopNoderedInstance completed" + "\n";
+            } catch (error) {
+                this.messages += error + "\n";
+                console.error(error);
+            }
+            if (!this.$scope.$$phase) { this.$scope.$apply(); }
+        }
+
+        async submit() {
+            await this.SendOne(this.queuename, this.message);
+        }
+        async SendOne(queuename: string, message: any): Promise<void> {
+            var result: any = await this.api.QueueMessage(queuename, message);
+            try {
+                // result = JSON.parse(result);
+            } catch (error) {
+            }
+            this.messages += result + "\n";
+            if (!this.$scope.$$phase) { this.$scope.$apply(); }
+        }
+    }
+
+
 }

OpenFlow/src/public/Nodered.html

@@ -0,0 +1,19 @@
+<div class="starter-template">
+  <h1 translate lib="web">sockets</h1>
+</div>
+
+<a ng-href="ctrl.noderedurl" target="nodered">Open Nodered</a>
+<form ng-submit="ctrl.submit()" class="form-horizontal" role="form" autocomplete="off" ng-hide="ctrl.showjson==true">
+  <section>
+    <div class="form-group">
+      <div class="col-sm-offset-2 col-sm-10">
+        <button type="button" class="btn btn-secondary" ng-click="ctrl.EnsureNoderedInstance()">Create Nodered</button>
+        <button type="button" class="btn btn-secondary" ng-click="ctrl.RestartNoderedInstance()">Restart
+          Nodered</button>
+        <button type="button" class="btn btn-secondary" ng-click="ctrl.DeleteNoderedInstance()">Delete Nodered</button>
+      </div>
+    </div>
+  </section>
+</form>
+
+<pre>{{ ctrl.messages }}</pre>

OpenFlow/src/public/app.ts

@@ -50,6 +50,7 @@ module openflow {
                 .when('/History/:collection/:id', { templateUrl: 'History.html', controller: HistoryCtrl, controllerAs: 'ctrl' })
 
                 .when('/Socket', { templateUrl: 'Socket.html', controller: SocketCtrl, controllerAs: 'ctrl' })
+                .when('/Nodered', { templateUrl: 'Nodered.html', controller: NoderedCtrl, controllerAs: 'ctrl' })
 
                 .otherwise({ redirectTo: '/main' });
         }

OpenFlow/src/public/index.html

@@ -39,6 +39,9 @@
         <li class="nav-item">
           <a class="nav-link" href="#/Reports"><span translate lib="web">reports</span></a>
         </li>
+        <li class="nav-item">
+          <a class="nav-link" href="#/Nodered"><span translate lib="web">nodered</span></a>
+        </li>
         <li class="nav-item dropdown">
           <a class="nav-link dropdown-toggle" data-toggle="dropdown" aria-haspopup="true" aria-expanded="false"
             translate lib="web">admin</a>