The most simple HttpComponent example
The following example demonstrates the most simple component sending a GET request to a HTTP resource. This is accomplished by defining request options and passing them to HttpComponent.get
.
var HttpComponent = HttpComponent; // exporting the process function to be called by elastic.io runtimeexportsprocess = doProcess; { // creating requestion options var options = url: 'http://foobarbazbarney.com/api' json: true ; // sending GET request with given options this; }
Please note that HttpComponent.get
sends a HTTP GET request. The response is checked to have a status codes 200 OK
or 201 Created
. If so, the response's body will be be used as component's output. Any other status code will result in an error being thrown.
Supported HTTP verbs
The HttpComponent
class exposes function for each of the supported HTTP verbs. Currently following are supported:
HttpComponent.get
: sends HTTP GETHttpComponent.post
: sends HTTP POSTHttpComponent.put
: sends HTTP PUT
Here is an example of how to send a HTTP POST request:
var HttpComponent = HttpComponent; // exporting the process function to be called by elastic.io runtimeexportsprocess = doProcess; { // creating requestion options var options = url: 'http://foobarbazbarney.com/api' body : JSON ; // sending GET request with given options this; }
Headers
HTTP Headers for the request can be set in the options object:
// creating requestion options
var options = {
url: 'http://foobarbazbarney.com/api',
json : {message : "Hello, world!"},
headers: {
'Authorization': 'Basic QWxhZGRpbjpvcGVuIHNlc2FtZQ==',
'Accept-Charset': 'utf-8',
'User-Agent': 'Mozilla/5.0'
}
};
Overriding the success handler
var elasticio = ;var HttpComponent = elasticioHttpComponent;var messages = elasticiomessages; exportsprocess = doProcess; { var self = this; // creating requestion options var options = url: 'http://foobarbazbarney.com/api' json: true ; // overrides the default response handler { if responsestatusCode === 400 throw JSON; // you may also modify the data before emitting them delete bodyinternalId; // creating a message from given response body var data = messages; // emitting the "data" event self; } // sending GET request with given options this; }