Add rawserial, mpd, mysql and swearfilter nodes.

2025-03-01 10:37:43 +00:00 · 2013-11-03 21:29:20 +00:00
parent 7c3b1d7ff4
commit 5e67f41114
9 changed files with 707 additions and 0 deletions
--- a/storage/mysql/68-mysql.js
+++ b/storage/mysql/68-mysql.js
@@ -0,0 +1,108 @@
+/**
+ * Copyright 2013 IBM Corp.
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ * http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ **/
+
+var RED = require(process.env.NODE_RED_HOME+"/red/red");
+var mysqldb = require('mysql');
+
+function MySQLNode(n) {
+    RED.nodes.createNode(this,n);
+    this.host = n.host;
+    this.port = n.port;
+    this.user = n.user;
+    this.password = n.pass;
+    this.dbname = n.db;
+    var node = this;
+
+    node.connection = mysqldb.createConnection({
+        host : node.host,
+        port : node.port,
+        user : node.user,
+        password : node.password,
+        database : node.dbname
+    });
+
+    node.connection.connect(function(err) {
+        if (err) node.error(err);
+    });
+
+    node.on('close', function () {
+        node.connection.end(function(err) {
+            if (err) node.error(err);
+        });
+    });
+}
+RED.nodes.registerType("MySQLdatabase",MySQLNode);
+
+
+function MysqlDBNodeIn(n) {
+    RED.nodes.createNode(this,n);
+    this.mydb = n.mydb;
+    this.mydbConfig = RED.nodes.getNode(this.mydb);
+
+    if (this.mydbConfig) {
+        var node = this;
+        node.on("input", function(msg) {
+            if (typeof msg.topic === 'string') {
+                //console.log("query:",msg.topic);
+                node.mydbConfig.connection.query(msg.topic, function(err, rows) {
+                    if (err) { node.warn(err); }
+                    else {
+                        msg.payload = rows;
+                        node.send(msg);
+                    }
+                });
+            }
+            else {
+                if (typeof msg.topic !== 'string') node.error("msg.topic : the query is not defined as a string");
+            }
+        });
+    }
+    else {
+        this.error("MySQL database not configured");
+    }
+}
+RED.nodes.registerType("mysql",MysqlDBNodeIn);
+
+
+//function MysqlDBNodeOut(n) {
+    //RED.nodes.createNode(this,n);
+    //this.level = n.level;
+    //this.operation = n.operation;
+    //this.levelConfig = RED.nodes.getNode(this.level);
+
+    //if (this.levelConfig) {
+        //var node = this;
+        //node.on("input", function(msg) {
+            //if (typeof msg.topic === 'string') {
+                //if (node.operation === "delete") {
+                    //node.levelConfig.db.del(msg.topic);
+                //}
+                //else {
+                    //node.levelConfig.db.put(msg.topic, msg.payload, function(err) {
+                        //if (err) node.error(err);
+                    //});
+                //}
+            //}
+            //else {
+                //if (typeof msg.topic !== 'string') node.error("msg.topic : the key is not defined");
+            //}
+        //});
+    //}
+    //else {
+        //this.error("MySQL database not configured");
+    //}
+//}
+//RED.nodes.registerType("mysql out",MysqlDBNodeOut);