mirror of
https://github.com/node-red/node-red.git
synced 2023-10-10 13:36:53 +02:00
Move HTTPRequest node to its own file
This commit is contained in:
Nick O'Leary
parent
64431c6711
commit
d3de7037e5
@ -84,74 +84,6 @@
|
|||||||
</ul>
|
</ul>
|
||||||
</script>
|
</script>
|
||||||
|
|
||||||
<script type="text/x-red" data-template-name="http request">
|
|
||||||
<div class="form-row">
|
|
||||||
<label for="node-input-method"><i class="fa fa-tasks"></i> <span data-i18n="httpin.label.method"></span></label>
|
|
||||||
<select type="text" id="node-input-method" style="width:72%;">
|
|
||||||
<option value="GET">GET</option>
|
|
||||||
<option value="POST">POST</option>
|
|
||||||
<option value="PUT">PUT</option>
|
|
||||||
<option value="DELETE">DELETE</option>
|
|
||||||
<option value="use" data-i18n="httpin.setby"></option>
|
|
||||||
</select>
|
|
||||||
</div>
|
|
||||||
<div class="form-row">
|
|
||||||
<label for="node-input-url"><i class="fa fa-globe"></i> <span data-i18n="httpin.label.url"></span></label>
|
|
||||||
<input type="text" id="node-input-url" placeholder="http://">
|
|
||||||
</div>
|
|
||||||
<div class="form-row">
|
|
||||||
<label> </label>
|
|
||||||
<input type="checkbox" id="node-input-useAuth" style="display: inline-block; width: auto; vertical-align: top;">
|
|
||||||
<label for="node-input-useAuth" style="width: 70%;"><span data-i18n="httpin.basicauth"></span></label>
|
|
||||||
</div>
|
|
||||||
<div class="form-row node-input-useAuth-row">
|
|
||||||
<label for="node-input-user"><i class="fa fa-user"></i> <span data-i18n="common.label.username"></span></label>
|
|
||||||
<input type="text" id="node-input-user">
|
|
||||||
</div>
|
|
||||||
<div class="form-row node-input-useAuth-row">
|
|
||||||
<label for="node-input-password"><i class="fa fa-lock"></i> <span data-i18n="common.label.password"></span></label>
|
|
||||||
<input type="password" id="node-input-password">
|
|
||||||
</div>
|
|
||||||
<div class="form-row">
|
|
||||||
<label for="node-input-ret"><i class="fa fa-arrow-left"></i> <span data-i18n="httpin.label.return"></span></label>
|
|
||||||
<select type="text" id="node-input-ret" style="width:72%;">
|
|
||||||
<option value="txt" data-i18n="httpin.utf8"></option>
|
|
||||||
<option value="bin" data-i18n="httpin.binary"></option>
|
|
||||||
<option value="obj" data-i18n="httpin.json"></option>
|
|
||||||
</select>
|
|
||||||
</div>
|
|
||||||
<div class="form-row">
|
|
||||||
<label for="node-input-name"><i class="fa fa-tag"></i> <span data-i18n="common.label.name"></span></label>
|
|
||||||
<input type="text" id="node-input-name" data-i18n="[placeholder]common.label.name">
|
|
||||||
</div>
|
|
||||||
<div class="form-tips" id="tip-json" hidden><span data-i18n="httpin.tip.req"></span></div>
|
|
||||||
</script>
|
|
||||||
|
|
||||||
<script type="text/x-red" data-help-name="http request">
|
|
||||||
<p>Provides a node for making http requests.</p>
|
|
||||||
<p>The URL and HTTP method can be configured in the node, if they are left blank they should be set in an incoming message on <code>msg.url</code> and <code>msg.method</code>:</p>
|
|
||||||
<ul>
|
|
||||||
<li><code>url</code>, if set, is used as the url of the request. Must start with http: or https:</li>
|
|
||||||
<li><code>method</code>, if set, is used as the HTTP method of the request.
|
|
||||||
Must be one of <code>GET</code>, <code>PUT</code>, <code>POST</code>, <code>PATCH</code> or <code>DELETE</code> (default: GET)</li>
|
|
||||||
<li><code>headers</code>, if set, should be an object containing field/value
|
|
||||||
pairs to be added as request headers</li>
|
|
||||||
<li><code>payload</code> is sent as the body of the request</li>
|
|
||||||
</ul>
|
|
||||||
<p>When configured within the node, the URL property can contain <a href="http://mustache.github.io/mustache.5.html" target="_new">mustache-style</a> tags. These allow the
|
|
||||||
url to be constructed using values of the incoming message. For example, if the url is set to
|
|
||||||
<code>example.com/{{{topic}}}</code>, it will have the value of <code>msg.topic</code> automatically inserted.
|
|
||||||
Using {{{...}}} prevents mustache from escaping characters like / & etc.</p>
|
|
||||||
<p>
|
|
||||||
The output message contains the following properties:
|
|
||||||
<ul>
|
|
||||||
<li><code>payload</code> is the body of the response</li>
|
|
||||||
<li><code>statusCode</code> is the status code of the response, or the error code if the request could not be completed</li>
|
|
||||||
<li><code>headers</code> is an object containing the response headers</li>
|
|
||||||
</ul>
|
|
||||||
<p><b>Note</b>: If you need to configure a proxy please add <b>http_proxy=...</b> to your environment variables and restart Node-RED.</p>
|
|
||||||
</script>
|
|
||||||
|
|
||||||
<script type="text/javascript">
|
<script type="text/javascript">
|
||||||
RED.nodes.registerType('http in',{
|
RED.nodes.registerType('http in',{
|
||||||
category: 'input',
|
category: 'input',
|
||||||
@ -221,57 +153,4 @@
|
|||||||
return this.name?"node_label_italic":"";
|
return this.name?"node_label_italic":"";
|
||||||
}
|
}
|
||||||
});
|
});
|
||||||
|
|
||||||
RED.nodes.registerType('http request',{
|
|
||||||
category: 'function',
|
|
||||||
color:"rgb(231, 231, 174)",
|
|
||||||
defaults: {
|
|
||||||
name: {value:""},
|
|
||||||
method:{value:"GET"},
|
|
||||||
ret: {value:"txt"},
|
|
||||||
url:{value:""},
|
|
||||||
//user -> credentials
|
|
||||||
//pass -> credentials
|
|
||||||
},
|
|
||||||
credentials: {
|
|
||||||
user: {type:"text"},
|
|
||||||
password: {type: "password"}
|
|
||||||
},
|
|
||||||
inputs:1,
|
|
||||||
outputs:1,
|
|
||||||
icon: "white-globe.png",
|
|
||||||
label: function() {
|
|
||||||
return this.name||this._("httpin.httpreq");
|
|
||||||
},
|
|
||||||
labelStyle: function() {
|
|
||||||
return this.name?"node_label_italic":"";
|
|
||||||
},
|
|
||||||
oneditprepare: function() {
|
|
||||||
if (this.credentials.user || this.credentials.has_password) {
|
|
||||||
$('#node-input-useAuth').prop('checked', true);
|
|
||||||
$(".node-input-useAuth-row").show();
|
|
||||||
} else {
|
|
||||||
$('#node-input-useAuth').prop('checked', false);
|
|
||||||
$(".node-input-useAuth-row").hide();
|
|
||||||
}
|
|
||||||
|
|
||||||
$("#node-input-useAuth").change(function() {
|
|
||||||
if ($(this).is(":checked")) {
|
|
||||||
$(".node-input-useAuth-row").show();
|
|
||||||
} else {
|
|
||||||
$(".node-input-useAuth-row").hide();
|
|
||||||
$('#node-input-user').val('');
|
|
||||||
$('#node-input-password').val('');
|
|
||||||
}
|
|
||||||
});
|
|
||||||
|
|
||||||
$("#node-input-ret").change(function() {
|
|
||||||
if ($("#node-input-ret").val() === "obj") {
|
|
||||||
$("#tip-json").show();
|
|
||||||
} else {
|
|
||||||
$("#tip-json").hide();
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
|
||||||
});
|
|
||||||
</script>
|
</script>
|
||||||
|
|||||||
@ -16,13 +16,8 @@
|
|||||||
|
|
||||||
module.exports = function(RED) {
|
module.exports = function(RED) {
|
||||||
"use strict";
|
"use strict";
|
||||||
var http = require("follow-redirects").http;
|
|
||||||
var https = require("follow-redirects").https;
|
|
||||||
var urllib = require("url");
|
|
||||||
var bodyParser = require("body-parser");
|
var bodyParser = require("body-parser");
|
||||||
var getBody = require('raw-body');
|
var getBody = require('raw-body');
|
||||||
var mustache = require("mustache");
|
|
||||||
var querystring = require("querystring");
|
|
||||||
var cors = require('cors');
|
var cors = require('cors');
|
||||||
var jsonParser = bodyParser.json();
|
var jsonParser = bodyParser.json();
|
||||||
var urlencParser = bodyParser.urlencoded({extended:true});
|
var urlencParser = bodyParser.urlencoded({extended:true});
|
||||||
@ -67,7 +62,6 @@ module.exports = function(RED) {
|
|||||||
|
|
||||||
var corsSetup = false;
|
var corsSetup = false;
|
||||||
|
|
||||||
|
|
||||||
function createRequestWrapper(node,req) {
|
function createRequestWrapper(node,req) {
|
||||||
var wrapper = {
|
var wrapper = {
|
||||||
_req: req
|
_req: req
|
||||||
@ -286,165 +280,4 @@ module.exports = function(RED) {
|
|||||||
});
|
});
|
||||||
}
|
}
|
||||||
RED.nodes.registerType("http response",HTTPOut);
|
RED.nodes.registerType("http response",HTTPOut);
|
||||||
|
|
||||||
|
|
||||||
function HTTPRequest(n) {
|
|
||||||
RED.nodes.createNode(this,n);
|
|
||||||
var nodeUrl = n.url;
|
|
||||||
var isTemplatedUrl = (nodeUrl||"").indexOf("{{") != -1;
|
|
||||||
var nodeMethod = n.method || "GET";
|
|
||||||
this.ret = n.ret || "txt";
|
|
||||||
var node = this;
|
|
||||||
|
|
||||||
var prox, noprox;
|
|
||||||
if (process.env.http_proxy != null) { prox = process.env.http_proxy; }
|
|
||||||
if (process.env.HTTP_PROXY != null) { prox = process.env.HTTP_PROXY; }
|
|
||||||
if (process.env.no_proxy != null) { noprox = process.env.no_proxy.split(","); }
|
|
||||||
if (process.env.NO_PROXY != null) { noprox = process.env.NO_PROXY.split(","); }
|
|
||||||
|
|
||||||
this.on("input",function(msg) {
|
|
||||||
var preRequestTimestamp = process.hrtime();
|
|
||||||
node.status({fill:"blue",shape:"dot",text:"httpin.status.requesting"});
|
|
||||||
var url = nodeUrl || msg.url;
|
|
||||||
if (msg.url && nodeUrl && (nodeUrl !== msg.url)) { // revert change below when warning is finally removed
|
|
||||||
node.warn(RED._("common.errors.nooverride"));
|
|
||||||
}
|
|
||||||
if (isTemplatedUrl) {
|
|
||||||
url = mustache.render(nodeUrl,msg);
|
|
||||||
}
|
|
||||||
if (!url) {
|
|
||||||
node.error(RED._("httpin.errors.no-url"),msg);
|
|
||||||
return;
|
|
||||||
}
|
|
||||||
// url must start http:// or https:// so assume http:// if not set
|
|
||||||
if (!((url.indexOf("http://") === 0) || (url.indexOf("https://") === 0))) {
|
|
||||||
url = "http://"+url;
|
|
||||||
}
|
|
||||||
|
|
||||||
var method = nodeMethod.toUpperCase() || "GET";
|
|
||||||
if (msg.method && n.method && (n.method !== "use")) { // warn if override option not set
|
|
||||||
node.warn(RED._("common.errors.nooverride"));
|
|
||||||
}
|
|
||||||
if (msg.method && n.method && (n.method === "use")) {
|
|
||||||
method = msg.method.toUpperCase(); // use the msg parameter
|
|
||||||
}
|
|
||||||
var opts = urllib.parse(url);
|
|
||||||
opts.method = method;
|
|
||||||
opts.headers = {};
|
|
||||||
if (msg.headers) {
|
|
||||||
for (var v in msg.headers) {
|
|
||||||
if (msg.headers.hasOwnProperty(v)) {
|
|
||||||
var name = v.toLowerCase();
|
|
||||||
if (name !== "content-type" && name !== "content-length") {
|
|
||||||
// only normalise the known headers used later in this
|
|
||||||
// function. Otherwise leave them alone.
|
|
||||||
name = v;
|
|
||||||
}
|
|
||||||
opts.headers[name] = msg.headers[v];
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (this.credentials && this.credentials.user) {
|
|
||||||
opts.auth = this.credentials.user+":"+(this.credentials.password||"");
|
|
||||||
}
|
|
||||||
var payload = null;
|
|
||||||
|
|
||||||
if (msg.payload && (method == "POST" || method == "PUT" || method == "PATCH" ) ) {
|
|
||||||
if (typeof msg.payload === "string" || Buffer.isBuffer(msg.payload)) {
|
|
||||||
payload = msg.payload;
|
|
||||||
} else if (typeof msg.payload == "number") {
|
|
||||||
payload = msg.payload+"";
|
|
||||||
} else {
|
|
||||||
if (opts.headers['content-type'] == 'application/x-www-form-urlencoded') {
|
|
||||||
payload = querystring.stringify(msg.payload);
|
|
||||||
} else {
|
|
||||||
payload = JSON.stringify(msg.payload);
|
|
||||||
if (opts.headers['content-type'] == null) {
|
|
||||||
opts.headers['content-type'] = "application/json";
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (opts.headers['content-length'] == null) {
|
|
||||||
if (Buffer.isBuffer(payload)) {
|
|
||||||
opts.headers['content-length'] = payload.length;
|
|
||||||
} else {
|
|
||||||
opts.headers['content-length'] = Buffer.byteLength(payload);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
||||||
var urltotest = url;
|
|
||||||
var noproxy;
|
|
||||||
if (noprox) {
|
|
||||||
for (var i in noprox) {
|
|
||||||
if (url.indexOf(noprox[i]) !== -1) { noproxy=true; }
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (prox && !noproxy) {
|
|
||||||
var match = prox.match(/^(http:\/\/)?(.+)?:([0-9]+)?/i);
|
|
||||||
if (match) {
|
|
||||||
//opts.protocol = "http:";
|
|
||||||
//opts.host = opts.hostname = match[2];
|
|
||||||
//opts.port = (match[3] != null ? match[3] : 80);
|
|
||||||
opts.headers['Host'] = opts.host;
|
|
||||||
var heads = opts.headers;
|
|
||||||
var path = opts.pathname = opts.href;
|
|
||||||
opts = urllib.parse(prox);
|
|
||||||
opts.path = opts.pathname = path;
|
|
||||||
opts.headers = heads;
|
|
||||||
opts.method = method;
|
|
||||||
//console.log(opts);
|
|
||||||
urltotest = match[0];
|
|
||||||
}
|
|
||||||
else { node.warn("Bad proxy url: "+process.env.http_proxy); }
|
|
||||||
}
|
|
||||||
var req = ((/^https/.test(urltotest))?https:http).request(opts,function(res) {
|
|
||||||
(node.ret === "bin") ? res.setEncoding('binary') : res.setEncoding('utf8');
|
|
||||||
msg.statusCode = res.statusCode;
|
|
||||||
msg.headers = res.headers;
|
|
||||||
msg.payload = "";
|
|
||||||
// msg.url = url; // revert when warning above finally removed
|
|
||||||
res.on('data',function(chunk) {
|
|
||||||
msg.payload += chunk;
|
|
||||||
});
|
|
||||||
res.on('end',function() {
|
|
||||||
if (node.metric()) {
|
|
||||||
// Calculate request time
|
|
||||||
var diff = process.hrtime(preRequestTimestamp);
|
|
||||||
var ms = diff[0] * 1e3 + diff[1] * 1e-6;
|
|
||||||
var metricRequestDurationMillis = ms.toFixed(3);
|
|
||||||
node.metric("duration.millis", msg, metricRequestDurationMillis);
|
|
||||||
if (res.client && res.client.bytesRead) {
|
|
||||||
node.metric("size.bytes", msg, res.client.bytesRead);
|
|
||||||
}
|
|
||||||
}
|
|
||||||
if (node.ret === "bin") {
|
|
||||||
msg.payload = new Buffer(msg.payload,"binary");
|
|
||||||
}
|
|
||||||
else if (node.ret === "obj") {
|
|
||||||
try { msg.payload = JSON.parse(msg.payload); }
|
|
||||||
catch(e) { node.warn(RED._("httpin.errors.json-error")); }
|
|
||||||
}
|
|
||||||
node.send(msg);
|
|
||||||
node.status({});
|
|
||||||
});
|
|
||||||
});
|
|
||||||
req.on('error',function(err) {
|
|
||||||
msg.payload = err.toString() + " : " + url;
|
|
||||||
msg.statusCode = err.code;
|
|
||||||
node.send(msg);
|
|
||||||
node.status({fill:"red",shape:"ring",text:err.code});
|
|
||||||
});
|
|
||||||
if (payload) {
|
|
||||||
req.write(payload);
|
|
||||||
}
|
|
||||||
req.end();
|
|
||||||
});
|
|
||||||
}
|
|
||||||
|
|
||||||
RED.nodes.registerType("http request",HTTPRequest,{
|
|
||||||
credentials: {
|
|
||||||
user: {type:"text"},
|
|
||||||
password: {type: "password"}
|
|
||||||
}
|
|
||||||
});
|
|
||||||
}
|
}
|
||||||
|
|||||||
138
nodes/core/io/21-httprequest.html
Normal file
138
nodes/core/io/21-httprequest.html
Normal file
@ -0,0 +1,138 @@
|
|||||||
|
<!--
|
||||||
|
Copyright 2013, 2015 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="http request">
|
||||||
|
<div class="form-row">
|
||||||
|
<label for="node-input-method"><i class="fa fa-tasks"></i> <span data-i18n="httpin.label.method"></span></label>
|
||||||
|
<select type="text" id="node-input-method" style="width:72%;">
|
||||||
|
<option value="GET">GET</option>
|
||||||
|
<option value="POST">POST</option>
|
||||||
|
<option value="PUT">PUT</option>
|
||||||
|
<option value="DELETE">DELETE</option>
|
||||||
|
<option value="use" data-i18n="httpin.setby"></option>
|
||||||
|
</select>
|
||||||
|
</div>
|
||||||
|
<div class="form-row">
|
||||||
|
<label for="node-input-url"><i class="fa fa-globe"></i> <span data-i18n="httpin.label.url"></span></label>
|
||||||
|
<input type="text" id="node-input-url" placeholder="http://">
|
||||||
|
</div>
|
||||||
|
<div class="form-row">
|
||||||
|
<label> </label>
|
||||||
|
<input type="checkbox" id="node-input-useAuth" style="display: inline-block; width: auto; vertical-align: top;">
|
||||||
|
<label for="node-input-useAuth" style="width: 70%;"><span data-i18n="httpin.basicauth"></span></label>
|
||||||
|
</div>
|
||||||
|
<div class="form-row node-input-useAuth-row">
|
||||||
|
<label for="node-input-user"><i class="fa fa-user"></i> <span data-i18n="common.label.username"></span></label>
|
||||||
|
<input type="text" id="node-input-user">
|
||||||
|
</div>
|
||||||
|
<div class="form-row node-input-useAuth-row">
|
||||||
|
<label for="node-input-password"><i class="fa fa-lock"></i> <span data-i18n="common.label.password"></span></label>
|
||||||
|
<input type="password" id="node-input-password">
|
||||||
|
</div>
|
||||||
|
<div class="form-row">
|
||||||
|
<label for="node-input-ret"><i class="fa fa-arrow-left"></i> <span data-i18n="httpin.label.return"></span></label>
|
||||||
|
<select type="text" id="node-input-ret" style="width:72%;">
|
||||||
|
<option value="txt" data-i18n="httpin.utf8"></option>
|
||||||
|
<option value="bin" data-i18n="httpin.binary"></option>
|
||||||
|
<option value="obj" data-i18n="httpin.json"></option>
|
||||||
|
</select>
|
||||||
|
</div>
|
||||||
|
<div class="form-row">
|
||||||
|
<label for="node-input-name"><i class="fa fa-tag"></i> <span data-i18n="common.label.name"></span></label>
|
||||||
|
<input type="text" id="node-input-name" data-i18n="[placeholder]common.label.name">
|
||||||
|
</div>
|
||||||
|
<div class="form-tips" id="tip-json" hidden><span data-i18n="httpin.tip.req"></span></div>
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<script type="text/x-red" data-help-name="http request">
|
||||||
|
<p>Provides a node for making http requests.</p>
|
||||||
|
<p>The URL and HTTP method can be configured in the node, if they are left blank they should be set in an incoming message on <code>msg.url</code> and <code>msg.method</code>:</p>
|
||||||
|
<ul>
|
||||||
|
<li><code>url</code>, if set, is used as the url of the request. Must start with http: or https:</li>
|
||||||
|
<li><code>method</code>, if set, is used as the HTTP method of the request.
|
||||||
|
Must be one of <code>GET</code>, <code>PUT</code>, <code>POST</code>, <code>PATCH</code> or <code>DELETE</code> (default: GET)</li>
|
||||||
|
<li><code>headers</code>, if set, should be an object containing field/value
|
||||||
|
pairs to be added as request headers</li>
|
||||||
|
<li><code>payload</code> is sent as the body of the request</li>
|
||||||
|
</ul>
|
||||||
|
<p>When configured within the node, the URL property can contain <a href="http://mustache.github.io/mustache.5.html" target="_new">mustache-style</a> tags. These allow the
|
||||||
|
url to be constructed using values of the incoming message. For example, if the url is set to
|
||||||
|
<code>example.com/{{{topic}}}</code>, it will have the value of <code>msg.topic</code> automatically inserted.
|
||||||
|
Using {{{...}}} prevents mustache from escaping characters like / & etc.</p>
|
||||||
|
<p>
|
||||||
|
The output message contains the following properties:
|
||||||
|
<ul>
|
||||||
|
<li><code>payload</code> is the body of the response</li>
|
||||||
|
<li><code>statusCode</code> is the status code of the response, or the error code if the request could not be completed</li>
|
||||||
|
<li><code>headers</code> is an object containing the response headers</li>
|
||||||
|
</ul>
|
||||||
|
<p><b>Note</b>: If you need to configure a proxy please add <b>http_proxy=...</b> to your environment variables and restart Node-RED.</p>
|
||||||
|
</script>
|
||||||
|
|
||||||
|
<script type="text/javascript">
|
||||||
|
RED.nodes.registerType('http request',{
|
||||||
|
category: 'function',
|
||||||
|
color:"rgb(231, 231, 174)",
|
||||||
|
defaults: {
|
||||||
|
name: {value:""},
|
||||||
|
method:{value:"GET"},
|
||||||
|
ret: {value:"txt"},
|
||||||
|
url:{value:""},
|
||||||
|
//user -> credentials
|
||||||
|
//pass -> credentials
|
||||||
|
},
|
||||||
|
credentials: {
|
||||||
|
user: {type:"text"},
|
||||||
|
password: {type: "password"}
|
||||||
|
},
|
||||||
|
inputs:1,
|
||||||
|
outputs:1,
|
||||||
|
icon: "white-globe.png",
|
||||||
|
label: function() {
|
||||||
|
return this.name||this._("httpin.httpreq");
|
||||||
|
},
|
||||||
|
labelStyle: function() {
|
||||||
|
return this.name?"node_label_italic":"";
|
||||||
|
},
|
||||||
|
oneditprepare: function() {
|
||||||
|
if (this.credentials.user || this.credentials.has_password) {
|
||||||
|
$('#node-input-useAuth').prop('checked', true);
|
||||||
|
$(".node-input-useAuth-row").show();
|
||||||
|
} else {
|
||||||
|
$('#node-input-useAuth').prop('checked', false);
|
||||||
|
$(".node-input-useAuth-row").hide();
|
||||||
|
}
|
||||||
|
|
||||||
|
$("#node-input-useAuth").change(function() {
|
||||||
|
if ($(this).is(":checked")) {
|
||||||
|
$(".node-input-useAuth-row").show();
|
||||||
|
} else {
|
||||||
|
$(".node-input-useAuth-row").hide();
|
||||||
|
$('#node-input-user').val('');
|
||||||
|
$('#node-input-password').val('');
|
||||||
|
}
|
||||||
|
});
|
||||||
|
|
||||||
|
$("#node-input-ret").change(function() {
|
||||||
|
if ($("#node-input-ret").val() === "obj") {
|
||||||
|
$("#tip-json").show();
|
||||||
|
} else {
|
||||||
|
$("#tip-json").hide();
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
|
});
|
||||||
|
</script>
|
||||||
184
nodes/core/io/21-httprequest.js
Normal file
184
nodes/core/io/21-httprequest.js
Normal file
@ -0,0 +1,184 @@
|
|||||||
|
/**
|
||||||
|
* Copyright 2013, 2015 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.
|
||||||
|
**/
|
||||||
|
|
||||||
|
module.exports = function(RED) {
|
||||||
|
"use strict";
|
||||||
|
var http = require("follow-redirects").http;
|
||||||
|
var https = require("follow-redirects").https;
|
||||||
|
var urllib = require("url");
|
||||||
|
var mustache = require("mustache");
|
||||||
|
var querystring = require("querystring");
|
||||||
|
|
||||||
|
function HTTPRequest(n) {
|
||||||
|
RED.nodes.createNode(this,n);
|
||||||
|
var nodeUrl = n.url;
|
||||||
|
var isTemplatedUrl = (nodeUrl||"").indexOf("{{") != -1;
|
||||||
|
var nodeMethod = n.method || "GET";
|
||||||
|
this.ret = n.ret || "txt";
|
||||||
|
var node = this;
|
||||||
|
|
||||||
|
var prox, noprox;
|
||||||
|
if (process.env.http_proxy != null) { prox = process.env.http_proxy; }
|
||||||
|
if (process.env.HTTP_PROXY != null) { prox = process.env.HTTP_PROXY; }
|
||||||
|
if (process.env.no_proxy != null) { noprox = process.env.no_proxy.split(","); }
|
||||||
|
if (process.env.NO_PROXY != null) { noprox = process.env.NO_PROXY.split(","); }
|
||||||
|
|
||||||
|
this.on("input",function(msg) {
|
||||||
|
var preRequestTimestamp = process.hrtime();
|
||||||
|
node.status({fill:"blue",shape:"dot",text:"httpin.status.requesting"});
|
||||||
|
var url = nodeUrl || msg.url;
|
||||||
|
if (msg.url && nodeUrl && (nodeUrl !== msg.url)) { // revert change below when warning is finally removed
|
||||||
|
node.warn(RED._("common.errors.nooverride"));
|
||||||
|
}
|
||||||
|
if (isTemplatedUrl) {
|
||||||
|
url = mustache.render(nodeUrl,msg);
|
||||||
|
}
|
||||||
|
if (!url) {
|
||||||
|
node.error(RED._("httpin.errors.no-url"),msg);
|
||||||
|
return;
|
||||||
|
}
|
||||||
|
// url must start http:// or https:// so assume http:// if not set
|
||||||
|
if (!((url.indexOf("http://") === 0) || (url.indexOf("https://") === 0))) {
|
||||||
|
url = "http://"+url;
|
||||||
|
}
|
||||||
|
|
||||||
|
var method = nodeMethod.toUpperCase() || "GET";
|
||||||
|
if (msg.method && n.method && (n.method !== "use")) { // warn if override option not set
|
||||||
|
node.warn(RED._("common.errors.nooverride"));
|
||||||
|
}
|
||||||
|
if (msg.method && n.method && (n.method === "use")) {
|
||||||
|
method = msg.method.toUpperCase(); // use the msg parameter
|
||||||
|
}
|
||||||
|
var opts = urllib.parse(url);
|
||||||
|
opts.method = method;
|
||||||
|
opts.headers = {};
|
||||||
|
if (msg.headers) {
|
||||||
|
for (var v in msg.headers) {
|
||||||
|
if (msg.headers.hasOwnProperty(v)) {
|
||||||
|
var name = v.toLowerCase();
|
||||||
|
if (name !== "content-type" && name !== "content-length") {
|
||||||
|
// only normalise the known headers used later in this
|
||||||
|
// function. Otherwise leave them alone.
|
||||||
|
name = v;
|
||||||
|
}
|
||||||
|
opts.headers[name] = msg.headers[v];
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (this.credentials && this.credentials.user) {
|
||||||
|
opts.auth = this.credentials.user+":"+(this.credentials.password||"");
|
||||||
|
}
|
||||||
|
var payload = null;
|
||||||
|
|
||||||
|
if (msg.payload && (method == "POST" || method == "PUT" || method == "PATCH" ) ) {
|
||||||
|
if (typeof msg.payload === "string" || Buffer.isBuffer(msg.payload)) {
|
||||||
|
payload = msg.payload;
|
||||||
|
} else if (typeof msg.payload == "number") {
|
||||||
|
payload = msg.payload+"";
|
||||||
|
} else {
|
||||||
|
if (opts.headers['content-type'] == 'application/x-www-form-urlencoded') {
|
||||||
|
payload = querystring.stringify(msg.payload);
|
||||||
|
} else {
|
||||||
|
payload = JSON.stringify(msg.payload);
|
||||||
|
if (opts.headers['content-type'] == null) {
|
||||||
|
opts.headers['content-type'] = "application/json";
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (opts.headers['content-length'] == null) {
|
||||||
|
if (Buffer.isBuffer(payload)) {
|
||||||
|
opts.headers['content-length'] = payload.length;
|
||||||
|
} else {
|
||||||
|
opts.headers['content-length'] = Buffer.byteLength(payload);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
var urltotest = url;
|
||||||
|
var noproxy;
|
||||||
|
if (noprox) {
|
||||||
|
for (var i in noprox) {
|
||||||
|
if (url.indexOf(noprox[i]) !== -1) { noproxy=true; }
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (prox && !noproxy) {
|
||||||
|
var match = prox.match(/^(http:\/\/)?(.+)?:([0-9]+)?/i);
|
||||||
|
if (match) {
|
||||||
|
//opts.protocol = "http:";
|
||||||
|
//opts.host = opts.hostname = match[2];
|
||||||
|
//opts.port = (match[3] != null ? match[3] : 80);
|
||||||
|
opts.headers['Host'] = opts.host;
|
||||||
|
var heads = opts.headers;
|
||||||
|
var path = opts.pathname = opts.href;
|
||||||
|
opts = urllib.parse(prox);
|
||||||
|
opts.path = opts.pathname = path;
|
||||||
|
opts.headers = heads;
|
||||||
|
opts.method = method;
|
||||||
|
//console.log(opts);
|
||||||
|
urltotest = match[0];
|
||||||
|
}
|
||||||
|
else { node.warn("Bad proxy url: "+process.env.http_proxy); }
|
||||||
|
}
|
||||||
|
var req = ((/^https/.test(urltotest))?https:http).request(opts,function(res) {
|
||||||
|
(node.ret === "bin") ? res.setEncoding('binary') : res.setEncoding('utf8');
|
||||||
|
msg.statusCode = res.statusCode;
|
||||||
|
msg.headers = res.headers;
|
||||||
|
msg.payload = "";
|
||||||
|
// msg.url = url; // revert when warning above finally removed
|
||||||
|
res.on('data',function(chunk) {
|
||||||
|
msg.payload += chunk;
|
||||||
|
});
|
||||||
|
res.on('end',function() {
|
||||||
|
if (node.metric()) {
|
||||||
|
// Calculate request time
|
||||||
|
var diff = process.hrtime(preRequestTimestamp);
|
||||||
|
var ms = diff[0] * 1e3 + diff[1] * 1e-6;
|
||||||
|
var metricRequestDurationMillis = ms.toFixed(3);
|
||||||
|
node.metric("duration.millis", msg, metricRequestDurationMillis);
|
||||||
|
if (res.client && res.client.bytesRead) {
|
||||||
|
node.metric("size.bytes", msg, res.client.bytesRead);
|
||||||
|
}
|
||||||
|
}
|
||||||
|
if (node.ret === "bin") {
|
||||||
|
msg.payload = new Buffer(msg.payload,"binary");
|
||||||
|
}
|
||||||
|
else if (node.ret === "obj") {
|
||||||
|
try { msg.payload = JSON.parse(msg.payload); }
|
||||||
|
catch(e) { node.warn(RED._("httpin.errors.json-error")); }
|
||||||
|
}
|
||||||
|
node.send(msg);
|
||||||
|
node.status({});
|
||||||
|
});
|
||||||
|
});
|
||||||
|
req.on('error',function(err) {
|
||||||
|
msg.payload = err.toString() + " : " + url;
|
||||||
|
msg.statusCode = err.code;
|
||||||
|
node.send(msg);
|
||||||
|
node.status({fill:"red",shape:"ring",text:err.code});
|
||||||
|
});
|
||||||
|
if (payload) {
|
||||||
|
req.write(payload);
|
||||||
|
}
|
||||||
|
req.end();
|
||||||
|
});
|
||||||
|
}
|
||||||
|
|
||||||
|
RED.nodes.registerType("http request",HTTPRequest,{
|
||||||
|
credentials: {
|
||||||
|
user: {type:"text"},
|
||||||
|
password: {type: "password"}
|
||||||
|
}
|
||||||
|
});
|
||||||
|
}
|
||||||
Loading…
x
Reference in New Issue
Block a user