@dkx/http-server

DKX/Http/Server

Super simple HTTP server with zero dependencies and with middlewares support for node.js.

Installation

$ npm install --save @dkx/http-server

or with yarn

$ yarn add @dkx/http-server

Basic usage

const {Server} = require('@dkx/http-server');
const {someRandomMiddleware} = require('some-random-middleware');

const app = new Server;

app.use(someRandomMiddleware);

app.run(8080, () => {
    console.log('Server is running on port 8080');
});

Writing middlewares

Each middleware is just an ordinary async function.

Middleware must call the next function with current response.

const {Server} = require('@dkx/http-server');

async function appendHeaderMiddleware(request, response, next)
{
    response = response.withHeader('X-My-custom-header', 'hello world');
    return next(response);
}

const app = new Server;

app.use(appendHeaderMiddleware);

Writing response data

function writeResponseDataMiddleware(request, response, next)
{
    response.getBody((body) => {
        body.write('hello');
        body.write(' ');
        body.write('world');
    });
    
    return next(response);
}

Passing data between middlewares

function middlewareA(request, response, next, state)
{
    state.message = 'hello world';
    return next(response);
}

function middlewareB(request, response, next, state)
{
    console.log(state.message);    // output: hello world
    return next(response);
}

Server object

• use

  Append middleware.

  Arguments:

  middleware: Middleware: middleware to attach.

• run()

  Start the HTTP server.

  Arguments:

  port: number: port where the HTTP server will be listening for new requests. fn: () => void: callback called when server is ready to handle requests.

• close()

  Stop running HTTP server.

  Arguments:

  fn: () => void: callback called when server is completely shut down.

Request object

• method

  Contains request method (GET, POST, ...).

• url

  Contains requested URL.

• headers

  Contains request HTTP headers.

• body

  Readable stream for accessing request data.

Response object

The Response is an immutable object.

• statusCode

  Response status code, default 200.

• statusMessage

  Response status message, default is an empty string.

• headers

  Contains list of currently returned HTTP headers.

• getBody()

  Method used for accessing the ResponseBody object, which can be used for writing the response data.

  Arguments:

  fn: (body) => void: callback with ResponseBody object.

• withStatus()

  Write response status.

  Arguments:

  code: number: new response status code. message: string: new response status message, default is an empty string.

  Return:

  Response: cloned Response object with modified status.

• withHeader()

  Write response header.

  Arguments:

  name: string: name of the new header. value: string: value of the new header.

  Return:

  Response: cloned Response object with modified headers.

• removeHeader()

  Remove response header.

  Arguments:

  name: string: name of the removed header.

  Return:

  Response: cloned Response object with modified headers.

ResponseBody object

Writable stream for writing the response data.

• write()

  Write response chunk

  Arguments:

  chunk: chunk of data to write.