bump

Author: skadefro

OpenFlow/src/OAuthProvider.ts

@@ -0,0 +1,55 @@
+import * as oauthServer from "oauth2-server";
+import * as winston from "winston";
+import * as express from "express";
+export class OAuthProvider {
+    private _logger: winston.Logger;
+    private app: express.Express;
+    private clients = [{ clientId: 'thom', clientSecret: 'nightworld', redirectUris: [''] }];
+    private tokens = [];
+    private users = [{ id: '123', username: 'thomseddon', password: 'nightworld' }];
+    static configure(logger: winston.Logger, app: express.Express): OAuthProvider {
+        var instance = new OAuthProvider();
+        instance._logger = logger;
+        instance.app = app;
+
+        (app as any).oauth = oauthServer({
+            model: instance
+        });
+        app.post('/oauth/token', (app as any).oauth.token());
+        return instance;
+    }
+    public getAccessToken(bearerToken) {
+        var tokens = this.tokens.filter(function (token) {
+            return token.accessToken === bearerToken;
+        });
+        return tokens.length ? tokens[0] : false;
+    }
+    public getRefreshToken(bearerToken) {
+        var tokens = this.tokens.filter(function (token) {
+            return token.refreshToken === bearerToken;
+        });
+        return tokens.length ? tokens[0] : false;
+    }
+    public getClient(clientId, clientSecret) {
+        var clients = this.clients.filter(function (client) {
+            return client.clientId === clientId && client.clientSecret === clientSecret;
+        });
+        return clients.length ? clients[0] : false;
+    }
+    public saveToken(token, client, user) {
+        this.tokens.push({
+            accessToken: token.accessToken,
+            accessTokenExpiresAt: token.accessTokenExpiresAt,
+            clientId: client.clientId,
+            refreshToken: token.refreshToken,
+            refreshTokenExpiresAt: token.refreshTokenExpiresAt,
+            userId: user.id
+        });
+    }
+    public getUser(username, password) {
+        var users = this.users.filter(function (user) {
+            return user.username === username && user.password === password;
+        });
+        return users.length ? users[0] : false;
+    };
+}

OpenFlow/src/index.ts

@@ -238,6 +238,7 @@ rejectionEmitter.on("rejectionHandled", (error, promise) => {
     console.dir(error.stack);
 });
 import * as fs from "fs";
+import { OAuthProvider } from "./OAuthProvider";
 // import { GrafanaProxy } from "./grafana-proxy";
 var GrafanaProxy: any = null;
 try {
@@ -257,6 +258,7 @@ try {
         if (GrafanaProxy != null) {
             const grafana = await GrafanaProxy.GrafanaProxy.configure(logger, WebServer.app);
         }
+        // OAuthProvider.configure(logger, WebServer.app);
         WebSocketServer.configure(logger, server);
         logger.info("listening on " + Config.baseurl());
         logger.info("namespace: " + Config.namespace);

OpenFlowNodeRED/package.json

@@ -1,6 +1,6 @@
 {
   "name": "openflow-nodered",
-  "version": "1.0.90",
+  "version": "1.0.91",
   "description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
   "main": "index.js",
   "scripts": {

VERSION

@@ -1 +1 @@
-1.0.90
+1.0.91

package.json

@@ -1,6 +1,6 @@
 {
   "name": "openiap",
-  "version": "1.0.90",
+  "version": "1.0.91",
   "description": "Simple wrapper around NodeRed, RabbitMQ and MongoDB to support a more scaleable NodeRed implementation.\r Also the \"backend\" for [OpenRPA](https://github.com/skadefro/OpenRPA)",
   "main": "index.js",
   "scripts": {
@@ -58,6 +58,7 @@
     "morgan": "^1.10.0",
     "multer": "^1.4.2",
     "multer-gridfs-storage": "^4.2.0",
+    "oauth2-server": "^3.1.1",
     "openflow-api": "^1.0.20",
     "os-service": "^2.2.0",
     "passport": "^0.4.1",