@request/core

@request/core

HTTP Duplex Streams2 client. By default it behaves identically to Node's Core http.request method.

Each additional feature must be enabled explicitly via option. Some options requires additional dependencies.

Options

URL

url/uri

• String
• url.Url

qs

• Object
• String

Body

form

• Object
• String pass URL encoded string if you want it to be RFC3986 encoded prior sending

json

• Object

body

• Stream
• Buffer
• String
• Array

multipart - requires @request/multipart

Pass Object for multipart/form-data body:

// set item
multipart: {photo: fs.createReadStream('cat.png')}
// pass additional info about the uploaded item
multipart: {
  photo: {
    value: fs.createReadStream('cat.png'),
    options: {filename: 'cat.png', contentType: 'image/png', knownLength: 22025}
  }
}
// pass array of values for this item
multipart: {attachments: [fs.createReadStream('cat.png'), fs.createReadStream('dog.png')]}

The item's value can be either: Stream, Request, Buffer or String.

Pass Array for any other multipart/[TYPE], defaults to multipart/related:

// Example: Upload image to Google Drive
multipart: [
  {
    'Content-Type': 'application/json',
    body: JSON.stringify({title: 'cat.png'})
  },
  {
    'Content-Type': 'image/png',
    body: fs.createReadStream('cat.png')
  }
]

The body key is required and reserved for setting up the item's body. It can be either: Stream, Request, Buffer or String.

Additionally you can set preambleCRLF and/or postambleCRLF to true.

Authentication

auth - digest auth requires @request/digest

• {user: '', pass: '', sendImmediately: false}
  • Sets the Authorization: Basic ... header.
  • The sendImmediately option default to true if omitted.
  • The sendImmediately: false options requires the redirect option to be enabled.
  • Digest authentication requires the @request/digest module.
• {bearer: '', sendImmediately: false}
  • Alternatively the Authorization: Bearer ... header can be set if using the bearer option.
  • The rules for the sendImmediately option from above applies here.

oauth - requires @request/oauth

hawk - requires hawk

httpSignature - requires http-signature

aws - requires aws-sign2

Modifiers

gzip

• gzip: true
  • Pipes the response body to zlib Inflate or Gunzip stream based on the compression method specified in the content-encoding response header.
• gzip: 'gzip' | gzip: 'deflate'
  • Explicitly specify which decompression method to use.

encoding - requires iconv-lite

• encoding: true
  • Pipes the response body to iconv-lite stream, defaults to utf8.
• encoding: 'ISO-8859-1' | encoding: 'win1251' | ...
  • Specific encoding to use.
• encoding: 'binary'
  • Set encoding to 'binary' when expecting binary response.

Misc

cookie - requires tough-cookie

• true
• new require('tough-cookie).CookieJar(store, options)

length

• true defaults to false if omitted

callback

buffers the response body

• function(err, res, body) by default the response buffer is decoded into string using utf8. Set the encoding property to binary if you expect binary data, or any other specific encoding

redirect

• true follow redirects for GET, HEAD, OPTIONS and TRACE requests
• Object
  • all follow all redirects
  • max maximum redirects allowed
  • removeReferer remove the referer header on redirect
  • allow function (res) user defined function to check if the redirect should be allowed

timeout

• Number integer containing the number of milliseconds to wait for a server to send response headers (and start the response body) before aborting the request. Note that if the underlying TCP connection cannot be established, the OS-wide TCP connection timeout will overrule the timeout option

proxy

• String
• url.Url
• Object

{
  proxy: 'http://localhost:6767'
  //
  proxy: url.parse('http://localhost:6767')
  //
  proxy: {
    url: 'http://localhost:6767',
    headers: {
      allow: ['header-name'],
      exclusive: ['header-name']
    }
  }
}

tunnel - requires tunnel-agent

• true

parse

• {json: true}
  • sets the accept: application/json header for the request
  • parses JSON or JSONP response bodies (only if the server responds with the approprite headers)
• {json: function () {}}
  • same as above but additionally passes a user defined reviver function to the JSON.parse method
• {qs: {sep:';', eq:':'}}
  • qs.parse options to use
• {querystring: {sep:';', eq:':', options: {}}} use the [querystring][node-querystring] module instead
  • querystring.parse options to use

stringify

• {qs: {sep:';', eq:':'}}
  • qs.stringify options to use
• {querystring: {sep:';', eq:':', options: {}}} use the [querystring][node-querystring] module instead
  • querystring.stringify options to use

end

• true tries to automatically end the request on nextTick

HTTPDuplex

Private Flags and State

• _initialized set when the outgoing HTTP request is fully initialized
• _started set after first write/end
• _req http.ClientRequest created in HTTPDuplex
• _res http.IncomingMessage created in HTTPDuplex
• _client http or https module
• _redirect boolean indicating that the client is going to be redirected
• _redirected boolean indicating that the client is been redirected at least once
• _src the input read stream, usually from pipe
• _chunks Array - the first chunk read from the input read stream
• _ended whether the outgoing request has ended
• _auth whether basic auth is being used
• _timeout timeout timer instance

Public Methods

• init
• abort

Request

Methods

• Request the HTTPDuplex child class

Events

• init should be private I guess
• request req, options
• onresponse res - internal event to execute options response logic
• redirect res
• response res
• options emit @request/core options
• body emit raw response body, either Buffer or String (the callback option is required)
• json emit parsed JSON response body (the callback and the parse:{json:true} options are required)

req/res

• headers is instance of the @request/headers module

Generated Options

• url contains the parsed URL
• redirect is converted to object containing all possible options including the followed state variable, containing the followed redirects count
• auth containes sent state variable indicating whether the Basic auth is sent already
• cookie is converted to object and containes the initial cookie header as a property
• jar the internal tough-cookie jar

Logger

Requires @request/log

• req prints out the request method, url, and headers
• res prints out the response statusCode, statusMessage, and headers
• http prints out the options object passed to the underlying http.request method
• raw prints out the raw @request/core options object right before sending the request
• body prints out the raw request and response bodies (the response body is available only when the callback option is being used)
• json prints out the parsed JSON response body (only if the response body is a JSON one, and if the callback and parse.json options are being used)

$ DEBUG=req,res node app.js

Errors

oauth

• oauth: transport_method: body requires method: POST and content-type: application/x-www-form-urlencoded
• oauth: signature_method: PLAINTEXT not supported with body_hash signing

Notice

This module may contain code snippets initially implemented in request by request contributors.