From fe109f15d84f3627b3c9867afdedc6de9351941a Mon Sep 17 00:00:00 2001
From: Kris Daniels <krisdaniels@gmail.com>
Date: Fri, 20 Dec 2013 10:00:35 +0100
Subject: [PATCH] added postgres node

---
 storage/postgres/110-postgresout.html | 148 ++++++++++++++++++++++++++
 storage/postgres/110-postgresout.js   |  83 +++++++++++++++
 storage/postgres/icons/postgres.png   | Bin 0 -> 625 bytes
 3 files changed, 231 insertions(+)
 create mode 100644 storage/postgres/110-postgresout.html
 create mode 100644 storage/postgres/110-postgresout.js
 create mode 100644 storage/postgres/icons/postgres.png

diff --git a/storage/postgres/110-postgresout.html b/storage/postgres/110-postgresout.html
new file mode 100644
index 00000000..ab3291cc
--- /dev/null
+++ b/storage/postgres/110-postgresout.html
@@ -0,0 +1,148 @@
+<!--
+  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.
+-->
+
+<script type="text/x-red" data-template-name="postgresdb">
+    <div class="form-row">
+        <label for="node-config-input-hostname"><i class="icon-bookmark"></i> Host</label>
+        <input class="input-append-left" type="text" id="node-config-input-hostname" placeholder="localhost" style="width: 40%;" >
+        <label for="node-config-input-port" style="margin-left: 10px; width: 35px; "> Port</label>
+        <input type="text" id="node-config-input-port" placeholder="5432" style="width:45px">
+    </div>
+    <div class="form-row">
+        <label for="node-config-input-db"><i class="icon-briefcase"></i> Database</label>
+        <input type="text" id="node-config-input-db" placeholder="test">
+    </div>
+    <div class="form-row">
+        <label for="node-config-input-name"><i class="icon-user"></i> Username</label>
+        <input type="text" id="node-config-input-username" placeholder="postgres">
+        <label for="node-config-input-password"><i class="icon-lock"></i> Password</label>
+        <input type="password" id="node-config-input-password" placeholder="postgres">
+    </div>
+</script>
+
+<script type="text/javascript">
+    RED.nodes.registerType('postgresdb',{
+        category: 'config',
+        color:"rgb(218, 196, 180)",
+        defaults: {
+            hostname: { value:"localhost",required:true},
+            port: { value: 5432,required:true},
+            db: { value:"postgres",required:true},
+            username: { value:"postgres", required:true },
+            password: { value:"postgres", required:true }
+        },
+        label: function() {
+            return this.name||this.hostname+":"+this.port+"/"+this.db;
+        }
+    });
+</script>
+
+<script type="text/x-red" data-template-name="postgres">
+	 <div class="form-row">
+        <label for="node-input-name"><i class="icon-tag"></i> Name</label>
+        <input type="text" id="node-input-name" placeholder="Name">
+    </div>
+    <div class="form-row">
+        <label for="node-input-postgresdb"><i class="icon-tag"></i> Server</label>
+        <input type="text" id="node-input-postgresdb">
+    </div>
+    <div class="form-row">
+        <label for="node-input-collection"><i class="icon-briefcase"></i> Query</label>
+        <input type="hidden" id="node-input-sqlquery" autofocus="autofocus">
+        <div style="height: 250px;" class="node-text-editor" id="node-input-sqlquery-editor"></div>
+    </div>
+     <div class="form-row">
+        <label for="node-input-outputs"><i class="icon-random"></i> Outputs</label>
+        <input id="node-input-outputs" style="width: 60px; height: 1.7em;" value="0">
+    </div>
+</script>
+
+<script type="text/x-red" data-help-name="postgres">
+    <p>A PostgreSql I/O node. </p>
+    <p>Executes the specified query with the msg.payload as query parameters</p>
+    <p>The parameters in the query must be specified as $propertyname</p>
+    <p>ex. if the property is msg.payload.value then the query parameter should be $value</p>
+    <p>This node can be used to write and read from a Postgres database</p>
+    <p>To receive the results from a query, simply set the outputs to 1 and connect a node</p>
+    <p>The msg.payload on the output will be a json array of the returned records</p>
+</script>
+
+<script type="text/javascript">
+		RED.nodes.registerType('postgres',{
+        category: 'storage-output',
+        color:"rgb(148, 226, 252)",
+        defaults: {
+            postgresdb: { type:"postgresdb",required:true},
+            name: {value:""},
+            sqlquery: {value:"",required:true},
+            outputs: {value:0}
+        },
+        inputs:1,
+        outputs:0,
+        icon: "postgres.png",
+        align: "right",
+        label: function() {
+            return this.name||(this.sqlquery?this.sqlquery:"postgres");
+        },
+        labelStyle: function() {
+            return this.name?"node_label_italic":"";
+        },
+        oneditprepare: function() {
+            $( "#node-input-outputs" ).spinner({
+                min:0,
+                max:1
+            });
+            
+            $( "#node-input-outputs" ).spinner( "value", this.outputs );
+
+            function functionDialogResize(ev,ui) {
+                $("#node-input-sqlquery-editor").css("height",(ui.size.height-235)+"px");
+            };
+
+            $( "#dialog" ).on("dialogresize", functionDialogResize);
+            $( "#dialog" ).one("dialogopen", function(ev) {
+                var size = $( "#dialog" ).dialog('option','sizeCache-function');
+                if (size) {
+                    functionDialogResize(null,{size:size});
+                }
+            });
+            $( "#dialog" ).one("dialogclose", function(ev,ui) {
+                var height = $( "#dialog" ).dialog('option','height');
+                $( "#dialog" ).off("dialogresize",functionDialogResize);
+            });
+            var that = this;
+            require(["orion/editor/edit"], function(edit) {
+                that.editor = edit({
+                    parent:document.getElementById('node-input-sqlquery-editor'),
+                    lang:"sql",
+                    contents: $("#node-input-sqlquery").val()
+                });
+                RED.library.create({
+                    url:"storage", // where to get the data from
+                    type:"postgres", // the type of object the library is for
+                    editor:that.editor, // the field name the main text body goes to
+                    fields:['name','outputs']
+                });
+                $("#node-input-name").focus();
+
+            });
+        },
+        oneditsave: function() {
+            $("#node-input-sqlquery").val(this.editor.getText())
+            delete this.editor;
+        }
+    });
+</script>
diff --git a/storage/postgres/110-postgresout.js b/storage/postgres/110-postgresout.js
new file mode 100644
index 00000000..bf882b6a
--- /dev/null
+++ b/storage/postgres/110-postgresout.js
@@ -0,0 +1,83 @@
+/**
+ * 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.
+ **/
+
+// If you use this as a template, replace IBM Corp. with your own name.
+
+// Sample Node-RED node file
+
+// Require main module
+var RED = require(process.env.NODE_RED_HOME+"/red/red");
+var pg=require('pg');
+var named=require('node-postgres-named');
+
+function PostgresDatabaseNode(n) {
+    RED.nodes.createNode(this,n);
+    this.hostname = n.hostname;
+    this.port = n.port;
+    this.db = n.db;
+    this.username = n.username;
+    this.password = n.password;
+}
+
+RED.nodes.registerType("postgresdb",PostgresDatabaseNode);
+
+function PostgresNode(n) {
+	RED.nodes.createNode(this,n);
+    
+    this.topic = n.topic;
+    this.postgresdb = n.postgresdb;
+    this.postgresConfig = RED.nodes.getNode(this.postgresdb);
+    this.sqlquery = n.sqlquery;
+    this.outputs = n.outputs;
+    
+    var node = this;
+    if(this.postgresConfig)
+    {
+		
+		var conString = 'postgres://'+this.postgresConfig.username +':' + this.postgresConfig.password + '@' + this.postgresConfig.hostname + ':' + this.postgresConfig.port + '/' + this.postgresConfig.db;
+		node.clientdb = new pg.Client(conString);
+		named.patch(node.clientdb);
+
+		node.clientdb.connect(function(err){
+				if(err) { node.error(err); }
+				else {
+					node.on('input', 
+						function(msg){
+							node.clientdb.query(node.sqlquery,
+										 msg.payload,
+										 function (err, results) {
+											 if(err) { node.error(err); }
+											 else {
+												if(node.outputs>0)
+												{
+													msg.payload = results.rows;
+													node.send(msg);
+												}
+											 }
+										 });
+						});
+				}
+		});
+	} else {
+        this.error("missing postgres configuration");
+    }
+    
+    this.on("close", function() {
+        if(node.clientdb) node.clientdb.end();
+    });
+}
+
+RED.nodes.registerType("postgres",PostgresNode);
diff --git a/storage/postgres/icons/postgres.png b/storage/postgres/icons/postgres.png
new file mode 100644
index 0000000000000000000000000000000000000000..e46c31696bc4e2240ffe3450323e74c6ae0bbe33
GIT binary patch
literal 625
zcmV-%0*?KOP)<h;3K|Lk000e1NJLTq000~S0012b1^@s6xls%;00006VoOIv0RI60
z0RN!9r;`8x010qNS#tmY3ljhU3ljkVnw%H_000McNliru-3$~64ixgWAkzQ<0scuu
zK~zY`)s?$yRY4SnzuD)QlZaXbd;lR3tOTo6B4QKE_yD$cT8LU$*a$v>HWn7*8>A2=
zPoR*(#?ID4Ng-Z2`D|v#*^}9G_Q^$X!NAO#%Ubi#|Ib1tYvF+7Tk2bNTU{%hi%RaO
z+0u;pmE@e8iN6ygs6-Pu4SWN3*>3`iz|YLz01Lo(U>VqnYtwxb;8(jiL}viLR)SqD
z1S78h0gQn!z`a63fA^_p)z^KPtEWoPRNA)M6#TZ38nckHwYMK?4KOY25eQ8(I4au(
z9s{?_>Cc9%ou8<yJ#eM%p}JK#SCwX9*2c^~M7T=UlJ6aGC7ZhdJZNutL%r0KZBXAQ
zebr_4Sz+x<^@MsRL#ESjbyy>YeFVsS8^B56MPbce|0o0Y21)zP49ZV{twXZ5lU%F6
zJHXY#;uYZ09EXQYVxc4p3Xj~jvHH0{@5uleslHJ!m#W36qDQlmG~}C8-7M_g)8Q0&
z3as_KWBZ|>2c8dv_gehW?Sr&0d(}_s{jC1=-ELH=nfn4h$;NjxSWG^E8l+1-g}qaN
z`?N%Xbv4~C#$ue>0`QxNagEwd@_w%dR+aT6nOr8t8`f+T2{!M~)G3zp*z~Z)vf&@w
ze-m)ypaJJ4O^qDmNd0h}kP55<n=#nA;|v&LTL-R3$$YG6H30kpT*{N;jNlQ600000
LNkvXXu0mjfmyI6#

literal 0
HcmV?d00001