save jslog

Author: skadefro

OpenFlow/src/DatabaseConnection.ts

@@ -231,6 +231,9 @@ export class DatabaseConnection {
         await this.connect();
         item = this.ensureResource(item);
         this.traversejsonencode(item);
+        if (jwt === null || jwt === undefined && collectionname === "jslog") {
+            jwt = TokenUser.rootToken();
+        }
         var user: TokenUser = Crypt.verityToken(jwt);
         if (!this.hasAuthorization(user, item, "create")) { throw new Error("Access denied"); }
         item._createdby = user.name;

OpenFlow/src/WebSocketClient.ts

@@ -165,6 +165,10 @@ export class WebSocketClient {
         });
         ids.forEach(id => {
             var msgs: SocketMessage[] = this._receiveQueue.filter(function (msg: SocketMessage): boolean { return msg.id === id; });
+            if (this._receiveQueue.length > 100) {
+                this._logger.error("_receiveQueue containers more than 100 messages for id '" + id + "' so discarding all !!!!!!!");
+                this._receiveQueue = this._receiveQueue.filter(function (msg: SocketMessage): boolean { return msg.id !== id; });
+            }
             msgs.sort((a, b) => a.index - b.index);
             var first: SocketMessage = msgs[0];
             if (first.count === msgs.length) {

OpenFlow/src/public/CommonControllers.ts

@@ -11,11 +11,45 @@ module openflow {
     export type mapFunc = () => void;
     export type reduceFunc = (key: string, values: any[]) => any;
     export type finalizeFunc = (key: string, value: any) => any;
-
+    const getCircularReplacer = () => {
+        const seen = new WeakSet();
+        return (key, value) => {
+            if (typeof value === "object" && value !== null) {
+                if (seen.has(value)) {
+                    return;
+                }
+                seen.add(value);
+            }
+            return value;
+        };
+    };
     export class api {
         static $inject = ["$rootScope", "$location", "WebSocketClient"];
         public messageQueue: IHashTable<messagequeue> = {};
         constructor(public $rootScope: ng.IRootScopeService, public $location, public WebSocketClient: WebSocketClient) {
+            var formerlog = console.log.bind(window.console);
+            var formerwarn = console.warn.bind(window.console);
+            var formerdebug = console.debug.bind(window.console);
+            console.log = (msg) => {
+                formerlog.apply(console, { arguments: arguments });
+                var log = { message: msg, _type: "message" };
+                this.Insert("jslog", log);
+            }
+            console.warn = (msg) => {
+                formerwarn.apply(console, { arguments: arguments });
+                var log = { message: msg, _type: "warning" };
+                this.Insert("jslog", log);
+            }
+            console.debug = (msg) => {
+                formerdebug.apply(console, { arguments: arguments });
+                var log = { message: msg, _type: "debug" };
+                this.Insert("jslog", log);
+            }
+            window.onerror = (message, url, linenumber) => {
+                var log = { message: message, url: url, linenumber: linenumber, _type: "error" };
+                this.Insert("jslog", log);
+            }
+
 
             var cleanup = $rootScope.$on('queuemessage', (event, data: QueueMessage) => {
                 if (event && data) { }

OpenFlow/src/public/Controllers.ts

@@ -752,6 +752,36 @@ module openflow {
             if (!this.$scope.$$phase) { this.$scope.$apply(); }
         }
     }
+
+    export class jslogCtrl extends entitiesCtrl<openflow.Base> {
+        public loading: boolean = false;
+        public message: string = "";
+        public charts: chartset[] = [];
+        constructor(
+            public $scope: ng.IScope,
+            public $location: ng.ILocationService,
+            public $routeParams: ng.route.IRouteParamsService,
+            public WebSocketClient: WebSocketClient,
+            public api: api
+        ) {
+            super($scope, $location, $routeParams, WebSocketClient, api);
+            WebSocketClient.onSignedin((user: TokenUser) => {
+                this.loadData();
+            });
+        }
+
+        async loadData(): Promise<void> {
+            this.loading = true;
+            this.charts = [];
+            var chart: chartset = null;
+            console.log("get log");
+            this.models = await this.api.Query("jslog", {}, null, { _created: -1 });
+            this.loading = false;
+            if (!this.$scope.$$phase) { this.$scope.$apply(); }
+        }
+    }
+
+
     export class EntityCtrl extends entityCtrl<openflow.Base> {
         public addthis: any = "";
         public users: any[] = null;

OpenFlow/src/public/app.ts

@@ -36,6 +36,8 @@ module openflow {
                 .when('/Workflows', { templateUrl: 'Workflows.html', controller: WorkflowsCtrl, controllerAs: 'ctrl' })
 
                 .when('/Reports', { templateUrl: 'Reports.html', controller: ReportsCtrl, controllerAs: 'ctrl' })
+                .when('/jslog', { templateUrl: 'jslog.html', controller: jslogCtrl, controllerAs: 'ctrl' })
+
 
                 .when('/Entities/:collection', { templateUrl: 'Entities.html', controller: EntitiesCtrl, controllerAs: 'ctrl' })
                 .when('/Entity/:collection', { templateUrl: 'Entity.html', controller: EntityCtrl, controllerAs: 'ctrl' })

OpenFlow/src/public/index.html

@@ -43,6 +43,7 @@
             <a class="dropdown-item" href="#/Users"><span translate lib="web">users</span></a>
             <a class="dropdown-item" href="#/Roles"><span translate lib="web">roles</span></a>
             <a class="dropdown-item" href="#/Providers"><span translate lib="web">providers</span></a>
+            <a class="dropdown-item" href="#/jslog"><span translate lib="web">jslog</span></a>
           </div>
         </li>
       </ul>

OpenFlow/src/public/jslog.html

@@ -0,0 +1,24 @@
+<div class="starter-template">
+  <h1 translate lib="web">entities</h1>
+</div>
+<div class="row">
+  <table id="table1" class="table table-striped" when-scrolled="ctrl.more()" style="width: 100%;">
+    <thead class="thead-dark">
+      <tr>
+        <th ng-click="ctrl.ToggleOrder('_createdby')"><b translate lib="web">createdby</b></th>
+        <th ng-click="ctrl.ToggleOrder('_created')"><b translate lib="web">created</b></th>
+        <th></th>
+      </tr>
+    </thead>
+    <tbody>
+      <tr ng-repeat="model in ctrl.models">
+        <td>{{model._createdby}}</td>
+        <td>
+          <timesince ng-model="model._created" />
+        </td>
+        <td class="btn-cell">
+          {{model.message}}
+        </td>
+      </tr>
+    </tbody>
+  </table>

VERSION

@@ -1 +1 @@
-0.0.124
+0.0.125