@alexshelkov/lambda

Type-safe middleware for AWS Lambda ===================================

Usage no npm install needed!

<script type="module">
  import alexshelkovLambda from 'https://cdn.skypack.dev/@alexshelkov/lambda';
</script>

README

Type-safe middleware for AWS Lambda

Leveraging the power of Typescript to build middleware-like request handlers for lambda functions with type-based dependency checking.

TypeScript Test Coverage Status

Gif

An example

A service which parse request body as JSON, get a and b from it, check if both are valid numbers, then adds them and return result.

import { Err, MiddlewareCreator, Handler, JsonBodyService, ok, fail, creator, addService, jsonBodyService } from '@alexshelkov/lambda';

type NumberService = { a: number; b: number };
type NumberErrNaN = Err<'NaA'>;
type NumberDependencies = JsonBodyService;

const numbers: MiddlewareCreator<{}, NumberService, NumberErrNaN, NumberDependencies> = () => {
  return async (request) => {
    const body = request.service.jsonBody;

    if (!(Number.isFinite(body.a) && Number.isFinite(body.b))) {
      return fail<NumberErrNaN>('NaA');
    }

    const service = body as NumberService;

    return addService(request, service);
  };
};

type Options = { acceptFloat: boolean };
type AdderService = { add: (a: number, b: number) => number };
type AdderErrNoFloats = Err<'Float'>;

const adder: MiddlewareCreator<Options, AdderService, AdderErrNoFloats> = (options, { throws }) => {
  return async (request) => {
    const service: AdderService = {
      add: (a: number, b: number) => {
        if (!options.acceptFloat && !(Number.isInteger(a) && Number.isInteger(b))) {
          throws<AdderErrNoFloats>('Float');
        }

        return a + b;
      },
    };

    return addService(request, service);
  };
};

const handler: Handler<AdderService & NumberService, number, never> = async ({
  service: { a, b, add },
}) => {
  return ok(add(a, b));
};

const lambda = creator(jsonBodyService).srv(numbers).srv(adder).ok(handler);

API

Defining services

Static service:

MiddlewareCreator

Type used for creating new services.

Params:

  • Options
  • Service
  • Errors
  • ServiceDeps
  • Event
import { Err } from '@alexshelkov/result';
import { MiddlewareCreator, addService } from '@alexshelkov/lambda';

type Options = { };
type Service = { add: (a: number, b: number) => number };
type Errors = never;

const service: MiddlewareCreator<Options, Service, Errors> = () => {
  return async (request) => {
    return addService(request, {
      add: (a: number, b: number) => {
        return a + b;
      },
    });
  };
};
Dynamic service:

Middleware

Used to define services dynamically based on provided options.

Params:

  • Service
  • Errors
  • ServiceDeps
  • Event
import { Middleware, GetOpt, ServiceContainer, Request, AwsEvent, GetService, empty, addService, creator } from '@alexshelkov/lambda';

type Options = { test: number };
type Service<O> = O;
type Errors = never;

const service = <O extends Options>(
  options: Partial<O>
): Middleware<{ service: Service<O> }, Errors> => {
  return async <Service1 extends ServiceContainer>(request: Request<AwsEvent, Service1>) => {
    return addService(request, {
      service: { test: options.test } as Service<O>,
    });
  };
};

const res = creator(empty).opt({ test: 1 }).srv(service);

Initialization

creator

Starts the creation of the lambda chain.

Params:

  • creator: MiddlewareCreator
import { creator, empty } from '@alexshelkov/lambda';

const res = creator(empty); // now you can use other methods, for example: .srv 

srv

Adds a new service.

Params:

  • creator: MiddlewareCreator
import { MiddlewareCreator, creator, empty, addService } from '@alexshelkov/lambda';

const service: MiddlewareCreator<{}, {}, never> = () => {
  return async (request) => {
    return addService(request, {});
  }
};

const res = creator(empty).srv(service); 

opt

Set the options.

Params:

  • options

Handlers

ok

Adds a handler which will be run if all middleware creators executed successfully.

Params:

  • handler: Handler
import { ok, creator, empty } from '@alexshelkov/lambda';

const res = creator(empty).ok(async () => {
  return ok('success'); // can be used in onOk
});

fail

Adds a handler which runs on middleware failure.

Params:

  • handler: HandlerError
import { ok, creator, empty } from '@alexshelkov/lambda';

const res = creator(empty).fail(async () => {
  // this handler will not runs because 
  // empty middleware not fails
  
  return ok('success'); // can be used in onFail
});

fatal

Adds an unknown exception handler.

Params:

  • handler: HandlerException
import { ok } from '@alexshelkov/result';
import { creator, empty } from '@alexshelkov/lambda';

const res = creator(empty).fatal(async () => {
  // this handler will not runs because 
  // empty middleware won't throw fatal errors
  
  return ok('success'); // can be used in onFatal
});

Transforms

onOk, onOkRes

Sets the result transformation of ok handler.

Params:

  • transform: Transform