Observable Server

Overview

@mck-p/obvi is a simple wrapper around http.createServer. It exposes a few helper methods and wraps each request inside of a Context object. The goal of this library is to be the lowest abstraction for more robust userland libraries.

Usage

1const makeServer = require('@mck-p/obvi')
2
3const {
4  _server, // http.creatServer() response
5  requests, // Observable of requests sent to server
6  start, // Start server listening on passed in port
7  stop // Stop server
8} = makeServer({
9  port: 5000 // Port to listen for connections on
10})
11
12// We subscribe to all requests from this server
13requests.subscribe((context) => {
14  console.log('I am responding to a request!')
15})
16
17// We create a stream of all post requests
18const postRequests = requests.filter(({ request }) => request.method.toLowerCase() === 'post')
19
20postRequests
21  // And we handle all post requests
22  .subscribe(({ response }) => response.send('You are sending me a post request!'))

API

• makeServer({ port?: number }):
  • Main export of module
  • Returns a Server object

Server

• requests: Observable<Context>:
  • The main abstraction over http requests
• _server: http.Server:
  • The underlying http.createServer() value
• stop: () => http.Server:
  • How we stop listening for incoming requests
• start: () => http.Server

Context

• request: Request:
  • Our base abstraction over http.IncomingMessage
• response: Response:
  • Our base abstraction over http.ServerResponse

Request

It is the underlying http.IncomingMessage with

• url: Url:
  • Instead of string, it returns this object with true as the second argument.

Response

• response: http.ServerResponse:
  • The underlying http.ServerResponse of the request
• send: string => void:
  • An alias for response.end