add smtp server

skadefro · skadefro · commit c979756da58a · 2019-05-27T21:12:53.000+02:00
diff --git a/OpenFlowNodeRED/package.json b/OpenFlowNodeRED/package.json
@@ -27,6 +27,7 @@
     "passport-openid-connect": "^0.1.0",
     "passport-saml": "^1.0.0",
     "passport-saml-metadata": "^1.6.0",
+    "smtp-server": "^3.5.0",
     "winston": "^3.2.1"
   }
 }
diff --git a/OpenFlowNodeRED/src/nodered/nodes/amqp.html b/OpenFlowNodeRED/src/nodered/nodes/amqp.html
@@ -13,16 +13,16 @@
     </div>
 </script>
 <script type="text/javascript">
-    RED.nodes.registerType('amqp-connection',{
+    RED.nodes.registerType('amqp-connection', {
         category: 'config',
         defaults: {
-            host: { value: "", required:true },
+            host: { value: "", required: true },
         },
         credentials: {
-            username: { type:"text" },
+            username: { type: "text" },
             password: { type: "password" }
         },
-        label: function() {
+        label: function () {
             return this.host || "amqp credentials";
         }
     });
@@ -56,10 +56,10 @@
         category: 'amqp',
         color: "#a6bbcf",
         defaults: {
-            queue: { value: "", required:true },
-            noack: { value: true, required:true },
+            queue: { value: "", required: true },
+            noack: { value: true, required: true },
             name: { value: "" },
-            config: {value:"",type:"amqp-connection", required:true}
+            config: { value: "", type: "amqp-connection", required: true }
         },
         inputs: 0,
         outputs: 1,
@@ -105,9 +105,9 @@
         category: 'amqp',
         color: "#a6bbcf",
         defaults: {
-            queue: { value: "", required:true },
+            queue: { value: "", required: true },
             localqueue: { value: "" },
-            config: {value:"",type:"amqp-connection", required:true}
+            config: { value: "", type: "amqp-connection", required: true }
         },
         inputs: 1,
         outputs: 1,
@@ -142,6 +142,7 @@
         inputs: 1,
         outputs: 1,
         icon: "bridge.png",
+        align: "right",
         label: function () {
             return this.name || "amqp acknowledgment";
         },
@@ -150,4 +151,4 @@
         },
 
     });
-</script>
+</script>
diff --git a/OpenFlowNodeRED/src/nodered/nodes/libmailserver.ts b/OpenFlowNodeRED/src/nodered/nodes/libmailserver.ts
@@ -0,0 +1,73 @@
+import { Readable } from "stream";
+import { SMTPServerSession, SMTPServer } from "smtp-server";
+import { EventEmitter } from "events";
+
+var test = require('@nodemailer/mailparser2');
+const simpleParser = test.SimpleParser;
+
+export class libmailserver extends EventEmitter {
+    constructor() {
+        super();
+    }
+    onMailFrom(address, session, callback) {
+        // session.xForward is a Map structure
+        try {
+            //config.log(4, 'XFORWARD ADDR=%s', session.xForward.get('ADDR'));
+        } catch (err) {
+            console.log(err);
+        }
+        callback();
+    }
+    onRcptTo(address, session, callback) {
+        //console.log(address.address);
+        //config.log(4, address.address);
+        // if (address.address !== 'allan@zenamic.dk') {
+        //     return callback(new Error('Non-existent email address'));
+        // }
+        return callback(); // Accept the address
+    }
+    async onData(stream: Readable, session: SMTPServerSession, callback: (err?: Error) => void) {
+        //var mail:ParsedMail = await simpleParser(stream);
+        var mail = await simpleParser(stream);
+        libmailserver.current.emit('email', mail);
+        //config.log(4, mail);
+        callback();
+    }
+    onAuth(auth, session, callback) {
+        // config.log(4, auth);
+        callback(null, { user: 123 }); // where 123 is the user id or similar property
+    }
+    static current: libmailserver;
+    server: SMTPServer;
+    static setupSMTP(port: number) {
+        return new Promise<libmailserver>(async (resolve, reject) => {
+            if (libmailserver.current) {
+                console.log('Smtpserver is allready listening on %s', port);
+                return resolve(libmailserver.current);
+            }
+
+            libmailserver.current = new libmailserver();
+            try {
+                const SMTPServer = require('smtp-server').SMTPServer;
+                libmailserver.current.server = new SMTPServer({
+                    secure: false,
+                    logger: false,
+                    authOptional: true,
+                    disableReverseLookup: true,
+                    useXClient: true,
+                    disabledCommands: ['STARTTLS', 'AUTH'],
+                    onMailFrom: libmailserver.current.onMailFrom,
+                    onRcptTo: libmailserver.current.onRcptTo,
+                    onAuth: libmailserver.current.onAuth,
+                    onData: libmailserver.current.onData
+                });
+                console.log('Smtpserver listening on %s', port);
+                await libmailserver.current.server.listen(port);
+                resolve(libmailserver.current);
+            } catch (err) {
+                reject(err);
+            }
+        });
+    }
+
+}    
diff --git a/OpenFlowNodeRED/src/nodered/nodes/rpa.html b/OpenFlowNodeRED/src/nodered/nodes/rpa.html
@@ -92,6 +92,7 @@
         inputs: 1,
         outputs: 3,
         icon: "bridge.png",
+        align: "right",
         outputLabels: ["completed", "status", "failed"],
         label: function () {
             return this.name || "rpa workflow";
diff --git a/OpenFlowNodeRED/src/nodered/nodes/smtpserver.html b/OpenFlowNodeRED/src/nodered/nodes/smtpserver.html
@@ -0,0 +1,33 @@
+<script type="text/x-red" data-template-name="smtpserver in">
+    <div class="form-row">
+        <label for="node-input-name"><i class="fa fa-tag"></i> Name</label>
+        <input type="text" id="node-input-name" placeholder="Name">
+    </div>
+    <div class="form-row">
+        <label for="node-input-email"><i class="fa fa-tag"></i> Email</label>
+        <input type="text" id="node-input-email" placeholder="Name">
+    </div>
+</script>
+<script type="text/x-red" data-help-name="smtpserver in">
+   <p>Receive emails directly from outside world on port 25s</p>
+</script>
+<script type="text/javascript">
+    RED.nodes.registerType('smtpserver in', {
+        category: 'rpa',
+        color: "rgb(215, 215, 160)",
+        defaults: {
+            name: { value: "", required: false },
+            email: { value: 'allan@demo1.openrpa.dk', required: true }
+        },
+        inputs: 0,
+        outputs: 1,
+        icon: "parser-html.png",     // saved in icons/myicon.png
+        //align: "right",
+        label: function () {
+            return this.name || this.email || "smtpserver in";
+        },
+        labelStyle: function () {
+            return this.name ? "node_label_italic" : "";
+        }
+    });
+</script>
diff --git a/OpenFlowNodeRED/src/nodered/nodes/smtpserver.ts b/OpenFlowNodeRED/src/nodered/nodes/smtpserver.ts
@@ -0,0 +1,84 @@
+import { Node } from "node-red";
+import { libmailserver } from "./libmailserver";
+import { NoderedUtil } from "./NoderedUtil";
+
+module.exports = function (RED) {
+    "use strict";
+
+    RED.nodes.registerType("smtpserver in", function (n) {
+        RED.nodes.createNode(this, n);
+        this.name = n.name;
+        this.email = n.email;
+        this.port = n.port;
+        var node = this;
+        var mailserver: libmailserver;
+
+        const onEmail = (email) => {
+            try {
+                var sendit: boolean = false;
+                if (node.email == null || node.email == '' || node.email == '*') {
+                    sendit = true;
+                }
+                if (email.to) {
+                    if (email.to.value.filter(addr => addr.address == node.email).length > 0) {
+                        sendit = true;
+                    }
+                }
+                if (email.bcc) {
+                    if (email.bcc.value.filter(addr => addr.address == node.email).length > 0) {
+                        sendit = true;
+                    }
+                }
+                if (sendit) {
+                    var msg = { payload: email, instanceid: null };
+                    var instanceid = email.headers.get('instanceid');
+                    if (!instanceid) {
+                        instanceid = email.headers.get('XREF');
+                    }
+                    if (!instanceid) {
+                        var startindex = email.text.indexOf('instanceid');
+                        //var endindex = email.text.indexOf('instanceid', startindex+10) + 10;
+                        //var text = email.text.substring(startindex, endindex - startindex);
+                        var text = email.text.substring(startindex);
+                        var arr = text.split(':');
+                        instanceid = arr[1];
+                    }
+
+                    msg.instanceid = instanceid;
+                    node.send(msg);
+                    // } else {
+                    //     config.log(1, email);
+                }
+            } catch (error) {
+                NoderedUtil.HandleError(this, error);
+            }
+        }
+        async function init(port: number) {
+            try {
+                mailserver = await libmailserver.setupSMTP(port);
+                mailserver.on('email', onEmail);
+                //mailserver.on('email', onEmail);
+                //libmailserver.current.on('email', onEmail);
+            } catch (error) {
+                NoderedUtil.HandleError(this, error);
+            }
+        }
+
+        var port = node.port;
+        // if(port && port !='') {
+        //     port = parseInt(node.port);
+        // } else {
+        //     port = config.mailserver_port;
+        // }
+        // port = config.mailserver_port;
+        port = 25;
+        init(port);
+
+        this.on("close", function () {
+            //mailserver.removeAllListeners(node.endpointname);
+            mailserver.removeListener('email', onEmail);
+        });
+
+    });
+
+}
diff --git a/OpenFlowNodeRED/src/nodered/nodes/workflow.html b/OpenFlowNodeRED/src/nodered/nodes/workflow.html
@@ -17,7 +17,7 @@
 </script>
 <script type="text/javascript">
     RED.nodes.registerType('workflow in', {
-        category: 'workflow',
+        category: 'rpa',
         color: "#a6bbcf",
         defaults: {
             queue: { value: "", required: true },
@@ -67,6 +67,7 @@
         inputs: 1,
         outputs: 1,
         icon: "bridge.png",
+        align: "right",
         label: function () {
             return this.name || "workflow out";
         },
diff --git a/OpenFlowNodeRED/src/nodered_settings.ts b/OpenFlowNodeRED/src/nodered_settings.ts
@@ -2,30 +2,30 @@ import { Config } from "./Config";
 
 // tslint:disable-next-line: class-name
 export class nodered_settings {
-    public flowFile:string = "flows.json";
-    public settingsFile:string = "nodered_settings.js";
-    public nodesDir:string = ".";
-    public userDir:string = ".";
+    public flowFile: string = "flows.json";
+    public settingsFile: string = "nodered_settings.js";
+    public nodesDir: string = ".";
+    public userDir: string = ".";
 
     public credentialSecret: string | boolean = false;
     public adminAuth: any = null;
     public httpNodeAuth: any = null;
     public httpStaticAuth: any = null;
-    public httpNodeMiddleware:any;
+    public httpNodeMiddleware: any;
 
-    public httpAdminRoot:string = "/";
-    public httpNodeRoot:string = "/";
+    public httpAdminRoot: string = "/";
+    public httpNodeRoot: string = "/";
     public storageModule: any = null;
-    public uiPort:number = Config.port;
-    public mqttReconnectTime:number = 15000;
-    public serialReconnectTime:number = 15000;
-    public debugMaxLength:number = 1000;
-    public functionGlobalContext:any = { process: process };
-    public paletteCategories:string[] = ["workflow", "form", "robot", "api", "smtpserver", "subflows", "input", "output", "function",
-    "social", "mobile", "storage", "analysis", "advanced"];
-    public debugUseColors:boolean = true;
-    public flowFilePretty:boolean = true;
-    public logging:any = {
+    public uiPort: number = Config.port;
+    public mqttReconnectTime: number = 15000;
+    public serialReconnectTime: number = 15000;
+    public debugMaxLength: number = 1000;
+    public functionGlobalContext: any = { process: process };
+    public paletteCategories: string[] = ["workflow", "rpa", "subflows", "input", "output", "function", "api",
+        "social", "mobile", "storage", "analysis", "advanced"];
+    public debugUseColors: boolean = true;
+    public flowFilePretty: boolean = true;
+    public logging: any = {
         console: {
             level: "warn",
             metrics: false,
diff --git a/package.json b/package.json
@@ -17,6 +17,7 @@
   },
   "homepage": "https://github.com/open-rpa/openflow",
   "dependencies": {
+    "@nodemailer/mailparser2": "^1.0.3",
     "@types/angular": "^1.6.54",
     "@types/angular-route": "^1.7.0",
     "@types/jquery": "^3.3.29",

Original file line number	Diff line number	Diff line change
`@@ -27,6 +27,7 @@`
`27`	`27`	`"passport-openid-connect": "^0.1.0",`
`28`	`28`	`"passport-saml": "^1.0.0",`
`29`	`29`	`"passport-saml-metadata": "^1.6.0",`
	`30`	`+ "smtp-server": "^3.5.0",`
`30`	`31`	`"winston": "^3.2.1"`
`31`	`32`	`}`
`32`	`33`	`}`