z0mt3c/flashheart

A fully-featured Node.js REST client built for ease-of-use and resilience

flashheart

A fully-featured Node.js REST client built for ease-of-use and resilience

flashheart is request with batteries included. It provides everything you need to build HTTP-based services with confidence.

Installation

npm install --save flashheart

Features

• Parses JSON responses
• Understands HTTP errors
• Timeout
• Rate Limiting
• Caching
• Logging
• StatsD integration
• Retries
• Circuit breaker
• Promises

Usage

const client = require('flashheart').createClient({
  name: 'my_service',
  logger: console
});

client.get('http://echo.jsontest.com/key/value/', (err, body) => {
  if (err) return console.error(err.message);

  console.log(body);
  // {key: "value"}
});

JSON

The client assumes you're working with a JSON API by default. It uses the json: true option in request to send the Accept: application/json header and automatically parse the response into an object. If you need to call an API that returns plain text, XML, animated GIFs etc. then set the json flag to false in your request options.

Errors

Unlike request, any response with a status code greater than or equal to 400 results in an error. There's no need to manually check the status code of the response. The status code is exposed as err.statusCode on the returned error object, the body (if one exists) is assigned to err.body and the headers are assigned to err.headers.

Timeout

The client has a default timeout of 2 seconds. You can override this when creating a client by setting the timeout property.

const client = require('flashheart').createClient({
  timeout: 50
});

Rate Limiting

The client has no rate limitation by default. You can specify how many requests are allowed to happen within a given interval — respectively with the rateLimitLimit and rateLimitInterval properties.

const client = require('flashheart').createClient({
  rateLimitLimit: 10,         // Allow a maxmimum of 10 requests…
  rateLimitInterval: 6000,    // …in an interval of 6 seconds (6000ms)
});

Note: rate limiting is provided by simple-rate-limiter.

Caching

The client will optionally cache any publicly cacheable response with a max-age directive. You can specify the caching storage with an instance of Catbox using the cache parameter.

const Catbox = require('catbox').Client;
const Memory = require('catbox-memory');
const storage = new Catbox(new Memory());
const client = require('flashheart').createClient({
  cache: storage
});

Optionally, you can enable staleIfError which will start listening to the stale-if-error directive as well. This stores the response for the duration of the stale-if-error directive as well as the max-age and will try to retrieve them in this order:

• max-age stored version
• fresh version
• stale-if-error version

This is enabled simply by passing in the staleIfError parameter to createClient:

const client = require('flashheart').createClient({
  cache: storage,
  staleIfError: true
});

The cache varies on all request options (and therefore, headers) by default. If you don't want to vary on a particular header, use the doNotVary option:

const client = require('flashheart').createClient({
  cache: storage,
  doNotVary: ['Request-Id']
});

Logging

All requests can be logged at info level if you provide a logger that supports the standard logging API (like console or Winston)

const client = require('flashheart').createClient({
  logger: console
});

Stats

Metrics can be sent to StatsD by providing an instance of the node-statsd client:

const StatsD = require('node-statsd');
const stats = new StatsD();

const client = require('flashheart').createClient({
  stats: stats
});

The following metrics are sent from each client:

Name	Type	Description
{name}.requests	Counter	Incremented every time a request is made
{name}.responses.{code}	Counter	Incremented every time a response is received
{name}.request_errors	Counter	Incremented every time a request fails (timeout, DNS lookup fails etc.)
{name}.response_time	Timer	Measures of the response time in milliseconds across all requests
{name}.retries	Counter	Incremented every time the request retries
{name}.attempts	Timer	Measures the number of attempts
{name}.cache.hits	Counter	Incremented for each cache hit
{name}.cache.misses	Counter	Incremented for each cache miss
{name}.cache.errors	Counter	Incremented whenever there's is a problem communicating with the cache

The {name} variable comes from the name option you pass to createClient. It defaults to http if you don't name your client.

You can also add the name option on a per-request basis which will include the request name in the metric. For example: api.feed.cache.hits.

Retries

By default the client retries failed requests once, with a delay of 100 milliseconds between attempts. The number of times to retry and the delay between retries can be configured using the retries and retryTimeout properties.

For example, to retry 10 times, with a delay of 500ms:

const client = require('flashheart').createClient({
  retries: 10,
  retryTimeout: 500
});

Default retries can be overridden using method options:

client.get(url, {
  retries: 5,
  retryTimeout: 250
}, done);

Only request errors or server errors result in a retry; 4XX errors are not retried.

Circuit breaker

By default the client implements a circuit breaker using the Levee library. It is configured to trip after 100 failures and resets after 10 seconds. This can be configured using the circuitBreakerMaxFailures and circuitBreakerResetTimeout properties.

For example to trip after 200 failures and try to reset after 30 seconds:

const client = require('flashheart').createClient({
  circuitBreakerMaxFailures: 200,
  circuitBreakerResetTimeout: 30000
});

Advanced configuration

The client uses request to make HTTP requests. You can override the default request instance using the request parameter:

const request = require('request').defaults({
  json: false,
  headers: {
    'X-Api-Key': 'foo'
  }
});

const client = require('flashheart').createClient({
  request: request
});

Alternatively, you can override or append to the default request options.

const client = require('flashheart').createClient({
  defaults: {
    json: false,
    headers: {
      'X-Api-Key': 'foo'
    }
  }
});

Usage with client certificates

The request option can also be used to pass a pre-configured request client for HTTPS client certificate authentication:

const fs = require('fs');
const request = require('request').defaults({
  pfx: fs.readFileSync('/path/to/my/cert.p12'),
  passphrase: 'password',
  strictSSL: false
});

const client = require('flashheart').createClient({
  request: request
});

Promises

Flashheart uses callbacks, but we expose the Client constructor to make it easy to promisify the entire library:

const Promise = require('bluebird');
const Client = require('flashheart').Client;
const client = require('flashheart').createClient();

Promise.promisifyAll(Client.prototype);

client.getAsync('http://httpstat.us/200')
  .then((body) => console.log(body));

API

Callback return values

All of the client methods (.get, .put etc.) return three arguments to their callbacks; err, body and res:

client.get(url, (err, body, res) => {
  // `err` is an optional error
  // `body` is the parsed JSON response body
  // `res` is an object containing information about the response
  //   `res.headers` is an object containing the response headers
  //   `res.statusCode` is the status code
  //   `res.elapsedTime` is the response time in milliseconds
});

.createClient

Creates a new client.

Parameters

• opts - An options object

Options

• name - optional - A name to be used for logging and stats (default http)
• cache - optional - A Catbox instance to use for caching
• timeout - optional - A timeout in milliseconds (default 2000)
• retries - optional - Number of times to retry failed requests (default 3)
• retryTimeout - optional - Time to wait between retries in milliseconds (default 100)
• circuitBreakerMaxFailures - optional - The number of failures required to trip the circuit breaker (default 100)
• circuitBreakerResetTimeout - optional - Time in milliseconds to wait before the circuit breaker resets after opening (default 10000)
• userAgent - optional - A custom user agent for the client (default flashheart/VERSION)
• doNotVary - optional - An array of headers to ignore when creating cache keys (default [])
• defaults - optional - A request options object to append or override existing default options
• request - optional - A pre-configured instance of request

client.get

Parameters

• url - The URL to be requested
• opts - optional - A set of options. All of the request options are supported
• callback - A function called with the callback return values

client.head

Parameters

• url - The URL to be requested
• opts - optional - A set of options. All of the request options are supported
• callback - A function called with the callback return values

client.put

Parameters

• url - The URL to be requested
• body - A JavaScript object to be used as the request body
• opts - optional - A set of options. All of the request options are supported
• callback - A function called with the callback return values

client.post

Parameters

• url - The URL to be requested
• body - A JavaScript object to be used as the request body
• opts - optional - A set of options. All of the request options are supported
• callback - A function called with the callback return values

client.patch

Parameters

• url - The URL to be requested
• body - A JavaScript object to be used as the request body
• opts - optional - A set of options. All of the request options are supported
• callback - A function called with the callback return values

client.delete

Parameters

• url - The URL to be requested
• opts - optional - A set of options. All of the request options are supported
• callback - A function called with the callback return values