Merge pull request openiap#41 from skadefro/master

bump

Author: skadefro

OpenFlow/src/Config.ts

@@ -14,6 +14,9 @@ export class Config {
 
     public static NODE_ENV: string = Config.getEnv("NODE_ENV", "development");
 
+    public static stripe_api_key: string = Config.getEnv("stripe_api_key", "");
+    public static stripe_api_secret: string = Config.getEnv("stripe_api_secret", "");
+
     public static auto_create_users: boolean = Config.parseBoolean(Config.getEnv("auto_create_users", "false"));
     public static auto_create_domains: string[] = Config.parseArray(Config.getEnv("auto_create_domains", ""));
     public static allow_user_registration: boolean = Config.parseBoolean(Config.getEnv("allow_user_registration", "false"));

OpenFlow/src/LoginProvider.ts

@@ -237,7 +237,8 @@ export class LoginProvider {
                 namespace: Config.namespace,
                 nodered_domain_schema: Config.nodered_domain_schema,
                 websocket_package_size: Config.websocket_package_size,
-                version: Config.version
+                version: Config.version,
+                stripe_api_key: Config.stripe_api_key
             }
             res.end(JSON.stringify(res2));
         });

OpenFlow/src/Messages/Message.ts

@@ -41,6 +41,10 @@ import * as path from "path";
 import { UpdateFileMessage } from "./UpdateFileMessage";
 import { DatabaseConnection } from "../DatabaseConnection";
 import { CreateWorkflowInstanceMessage } from "./CreateWorkflowInstanceMessage";
+import { StripeMessage } from "./StripeMessage";
+var request = require("request");
+var got = require("got");
+
 
 const safeObjectID = (s: string | number | ObjectID) => ObjectID.isValid(s) ? new ObjectID(s) : null;
 export class Message {
@@ -180,6 +184,9 @@ export class Message {
                 case "createworkflowinstance":
                     this.CreateWorkflowInstance(cli);
                     break;
+                case "stripemessage":
+                    this.StripeMessage(cli);
+                    break;
                 default:
                     this.UnknownCommand(cli);
                     break;
@@ -1394,6 +1401,150 @@ export class Message {
         }
         this.Send(cli);
     }
+
+    async async_request(options: any) {
+        return new Promise<any>(async (resolve, reject) => {
+            try {
+                request(options, (error, response, body) => {
+                    if (error) return reject(error);
+                    if (response.statusCode != 200) {
+                        if (body != null) return reject(body);
+                        return reject(response.statusText);
+                    }
+                    resolve(body);
+                });
+            } catch (error) {
+                reject(error);
+            }
+        });
+    }
+    isObject(obj) {
+        const type = typeof obj;
+        return (type === 'function' || type === 'object') && !!obj;
+    }
+    flattenAndStringify(data) {
+        const result = {};
+
+        const step = (obj, prevKey) => {
+            Object.keys(obj).forEach((key) => {
+                const value = obj[key];
+
+                const newKey = prevKey ? `${prevKey}[${key}]` : key;
+
+                if (this.isObject(value)) {
+                    if (!Buffer.isBuffer(value) && !value.hasOwnProperty('data')) {
+                        // Non-buffer non-file Objects are recursively flattened
+                        return step(value, newKey);
+                    } else {
+                        // Buffers and file objects are stored without modification
+                        result[newKey] = value;
+                    }
+                } else {
+                    // Primitives are converted to strings
+                    result[newKey] = String(value);
+                }
+            });
+        };
+        step(data, undefined);
+        return result;
+    }
+    async StripeMessage(cli: WebSocketClient) {
+        this.Reply();
+        var msg: StripeMessage;
+        try {
+            msg = StripeMessage.assign(this.data);
+
+            if (Util.IsNullEmpty(msg.object)) throw new Error("object is mandatory");
+            var url = "https://api.stripe.com/v1/" + msg.object;
+            if (!Util.IsNullEmpty(msg.id)) url = url + "/" + msg.id;
+            if (!Util.IsNullEmpty(msg.url)) url = msg.url;
+            if (!cli.user.HasRoleName("admins")) {
+                if (!Util.IsNullEmpty(msg.url)) throw new Error("Custom url not allowed");
+                if (msg.object != "customers" && msg.object != "tax_ids"
+                    && msg.object != "products" && msg.object != "plans" &&
+                    msg.object != "checkout.sessions" && msg.object != "tax_rates") throw new Error("Access to " + msg.object + " is not allowed");
+            }
+            if (msg.object == "tax_ids") {
+                if (Util.IsNullEmpty(msg.customerid)) throw new Error("Need customer to work with tax_id");
+                url = "https://api.stripe.com/v1/customers/" + msg.customerid + "/tax_ids";
+                if (msg.method == "DELETE" || msg.method == "PUT") {
+                    if (Util.IsNullEmpty(msg.id)) throw new Error("Need id");
+                    url = "https://api.stripe.com/v1/customers/" + msg.customerid + "/tax_ids/" + msg.id;
+                }
+                if (!Util.IsNullEmpty(msg.id)) {
+                    url = "https://api.stripe.com/v1/customers/" + msg.customerid + "/tax_ids/" + msg.id;
+                }
+            }
+            if (msg.object == "checkout.sessions") {
+                if (msg.method != "GET") {
+                    if (Util.IsNullEmpty(msg.customerid)) throw new Error("Need customer to work with sessions");
+                }
+                url = "https://api.stripe.com/v1/checkout/sessions";
+                if (!Util.IsNullEmpty(msg.id)) {
+                    url = "https://api.stripe.com/v1/checkout/sessions/" + msg.id;
+                }
+            }
+
+
+            var auth = "Basic " + new Buffer(Config.stripe_api_secret + ":").toString("base64");
+
+            var options = {
+                headers: {
+                    'Content-type': 'application/x-www-form-urlencoded',
+                    'Authorization': auth
+                }
+                // , body: JSON.stringify(msg.payload)
+            };
+            if (msg.payload != null && msg.method != "GET" && msg.method != "DELETE") {
+                var flattenedData = this.flattenAndStringify(msg.payload);
+                (options as any).form = flattenedData;
+            }
+            if (msg.method == "POST") {
+                var response = await got.post(url, options);
+                msg.payload = JSON.parse(response.body);
+            }
+            if (msg.method == "GET") {
+                var response = await got.get(url, options);
+                msg.payload = JSON.parse(response.body);
+            }
+            if (msg.method == "PUT") {
+                var response = await got.put(url, options);
+                msg.payload = JSON.parse(response.body);
+            }
+            if (msg.method == "DELETE") {
+                var response = await got.delete(url, options);
+                msg.payload = JSON.parse(response.body);
+            }
+            if (msg.payload != null) {
+                if (msg.payload.deleted) {
+                    msg.payload = null;
+                }
+            }
+
+            // msg.payload = JSON.parse(result);
+        } catch (error) {
+            if (error == null) new Error("Unknown error");
+            cli._logger.error(error);
+            if (Util.IsNullUndefinded(msg)) { (msg as any) = {}; }
+            if (msg !== null && msg !== undefined) {
+                msg.error = error;
+                if (error.message) msg.error = error.message;
+                // if (error.stack) msg.error = error.stack;
+                if (error.response && error.response.body) {
+                    msg.error = error.response.body;
+                }
+            }
+            cli._logger.error(error);
+        }
+        try {
+            this.data = JSON.stringify(msg);
+        } catch (error) {
+            this.data = "";
+            cli._logger.error(error);
+        }
+        this.Send(cli);
+    }
+
 }
 
 export class JSONfn {

OpenFlow/src/Messages/StripeMessage.ts

@@ -0,0 +1,41 @@
+export class stripe_base {
+    public id: string;
+    public object: string;
+    public created: number;
+    public livemode: boolean;
+    public deleted: boolean;
+}
+export class StripeMessage implements IReplyMessage {
+    public error: string;
+    public jwt: any;
+    public method: string;
+    public object: string;
+    public id: string;
+    public customerid: string;
+    public url: string;
+    public payload: stripe_base;
+
+    static assign(o: any): StripeMessage {
+        if (typeof o === "string" || o instanceof String) {
+            return Object.assign(new StripeMessage(), JSON.parse(o.toString()));
+        }
+        return Object.assign(new StripeMessage(), o);
+    }
+}
+export class stripe_list<T> {
+    public object: string;
+    public has_more: boolean;
+    public url: string;
+    public data: T[];
+}
+export class stripe_customer extends stripe_base {
+}
+export class stripe_tax_id extends stripe_base {
+}
+export class stripe_subscription extends stripe_base {
+    public address: string;
+    public balance: number;
+    public currency: string;
+    public subscriptions: stripe_list<stripe_subscription>;
+    public tax_ids: stripe_list<stripe_tax_id>;
+}

OpenFlow/src/public/CommonControllers.ts

@@ -97,7 +97,7 @@ module openflow {
                         }
                     }
                     if (data === null || data === undefined) {
-                        if (this.$location.path() !== "/Login") {
+                        if (this.$location.path() !== "/Login" && this.$location.path() !== "/Signup") {
                             var _url = this.$location.absUrl();
                             this.setCookie("url", _url, 365);
                             this.$location.path("/Login");
@@ -315,6 +315,13 @@ module openflow {
             var result: UpdateFileMessage = await this.WebSocketClient.Send<UpdateFileMessage>(msg);
             return;
         }
+        async Stripe<T extends stripe_base>(method: string, object: string, customerid: string, id: string, payload: stripe_base): Promise<T> {
+            var q: StripeMessage = new StripeMessage();
+            q.method = method; q.object = object; q.customerid = customerid; q.id = id; q.payload = payload;
+            var msg: Message = new Message(); msg.command = "stripemessage"; msg.data = JSON.stringify(q);
+            q = await this.WebSocketClient.Send<StripeMessage>(msg);
+            return (q.payload as any);
+        }
 
         setCookie(cname, cvalue, exdays) {
             var d = new Date();
@@ -671,7 +678,6 @@ module openflow {
                         query = { $and: [query, { $or: finalor.concat() }] };
                     }
                 }
-                console.log(this.orderby);
                 this.models = await this.api.Query(this.collection, query, this.baseprojection, this.orderby, 100, 0, this.basequeryas);
                 this.loading = false;
                 if (this.autorefresh) {