.

Author: blakeembrey

.editorconfig

@@ -0,0 +1,11 @@
+# EditorConfig is awesome: http://EditorConfig.org
+
+root = true
+
+[*]
+indent_size = 2
+indent_style = space
+end_of_line = lf
+charset = utf-8
+trim_trailing_whitespace = true
+insert_final_newline = true

.gitignore

@@ -0,0 +1,7 @@
+.DS_Store
+.vscode
+coverage/
+node_modules/
+npm-debug.log
+dist/
+typings/

.travis.yml

@@ -0,0 +1,13 @@
+sudo: false
+language: node_js
+
+notifications:
+  email:
+    on_success: never
+    on_failure: change
+
+node_js:
+  - '4'
+  - stable
+
+after_script: "npm install coveralls@2 && cat ./coverage/lcov.info | coveralls"

LICENSE

@@ -0,0 +1,13 @@
+Copyright 2017 Blake Embrey ([email protected])
+
+Licensed under the Apache License, Version 2.0 (the "License");
+you may not use this file except in compliance with the License.
+You may obtain a copy of the License at
+
+    http://www.apache.org/licenses/LICENSE-2.0
+
+Unless required by applicable law or agreed to in writing, software
+distributed under the License is distributed on an "AS IS" BASIS,
+WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+See the License for the specific language governing permissions and
+limitations under the License.

README.md

@@ -0,0 +1,45 @@
+# Servie Lambda
+
+[![NPM version][npm-image]][npm-url]
+[![NPM downloads][downloads-image]][downloads-url]
+[![Build status][travis-image]][travis-url]
+[![Test coverage][coveralls-image]][coveralls-url]
+
+> Servie transport for AWS lambda proxy.
+
+## Installation
+
+```
+npm install servie-lambda --save
+```
+
+## Usage
+
+Wrap a standard Servie middleware function in `createServer` to return a AWS Lambda handler.
+
+```ts
+import { createServer } from 'servie-lambda'
+import { compose } from 'throwback'
+import { get } from 'servie-route'
+
+export const handler = createServer(compose([
+  get('/test', (req, res) => res.body = 'hello world')
+]))
+```
+
+## TypeScript
+
+This project is written using [TypeScript](https://github.com/Microsoft/TypeScript) and publishes the definitions directly to NPM.
+
+## License
+
+MIT
+
+[npm-image]: https://img.shields.io/npm/v/servie-lambda.svg?style=flat
+[npm-url]: https://npmjs.org/package/servie-lambda
+[downloads-image]: https://img.shields.io/npm/dm/servie-lambda.svg?style=flat
+[downloads-url]: https://npmjs.org/package/servie-lambda
+[travis-image]: https://img.shields.io/travis/blakeembrey/node-servie-lambda.svg?style=flat
+[travis-url]: https://travis-ci.org/blakeembrey/node-servie-lambda
+[coveralls-image]: https://img.shields.io/coveralls/blakeembrey/node-servie-lambda.svg?style=flat
+[coveralls-url]: https://coveralls.io/r/blakeembrey/node-servie-lambda?branch=master

package.json

@@ -0,0 +1,51 @@
+{
+  "name": "servie-lambda",
+  "version": "0.0.0",
+  "description": "Servie transport for AWS lambda proxy",
+  "main": "dist/index.js",
+  "typings": "dist/index.d.ts",
+  "files": [
+    "dist/"
+  ],
+  "scripts": {
+    "lint": "tslint \"src/**/*.ts\"",
+    "build": "rimraf dist && tsc",
+    "specs": "jest --coverage",
+    "test": "npm run -s lint && npm run -s build && npm run -s specs",
+    "prepublish": "typings install && npm run build"
+  },
+  "repository": {
+    "type": "git",
+    "url": "git://github.com/blakeembrey/node-servie-lambda.git"
+  },
+  "keywords": [
+    "servie",
+    "aws",
+    "lambda",
+    "request",
+    "async",
+    "http"
+  ],
+  "author": {
+    "name": "Blake Embrey",
+    "email": "[email protected]",
+    "url": "http://blakeembrey.me"
+  },
+  "license": "Apache-2.0",
+  "bugs": {
+    "url": "https://github.com/blakeembrey/node-servie-lambda/issues"
+  },
+  "homepage": "https://github.com/blakeembrey/node-servie-lambda",
+  "devDependencies": {
+    "jest": "^18.1.0",
+    "rimraf": "^2.5.4",
+    "servie": "0.0.6",
+    "tslint": "^4.3.1",
+    "tslint-config-standard": "^2.0.0",
+    "typescript": "^2.1.5",
+    "typings": "^2.1.0"
+  },
+  "peerDependencies": {
+    "servie": "^0.0.3"
+  }
+}

src/index.spec.ts

@@ -0,0 +1,76 @@
+import { createServer, Event, Context, Result } from './index'
+
+describe('servie-lambda', () => {
+  const event: Event = {
+    path: '/test',
+    pathParameters: null,
+    httpMethod: 'GET',
+    body: null,
+    resource: '/test',
+    headers: null,
+    queryStringParameters: null,
+    requestContext: {
+      identity: {
+        sourceIp: ''
+      }
+    }
+  }
+
+  const context: Context = {
+    functionName: '',
+    functionVersion: '$LATEST',
+    memoryLimitInMB: '128',
+    invokeid: '',
+    awsRequestId: '',
+    invokedFunctionArn: ''
+  }
+
+  it('should support routers', (done) => {
+    const handler = createServer(function (_req, res) {
+      res.status = 200
+      res.body = 'response'
+
+      return Promise.resolve()
+    })
+
+    return handler(event, context, (err: Error | null, res: Result) => {
+      if (err) {
+        return done(err)
+      }
+
+      expect(res).toEqual({
+        statusCode: 200,
+        body: 'response',
+        headers: {
+          'content-type': 'text/plain',
+          'content-length': '8'
+        },
+        isBase64Encoded: false
+      })
+
+      return done()
+    })
+  })
+
+  it('should fall through to 404', (done) => {
+    const handler = createServer((_req, _res, next) => next())
+
+    return handler(event, context, (err: Error | null, res: Result) => {
+      if (err) {
+        return done(err)
+      }
+
+      expect(res).toEqual({
+        statusCode: 404,
+        body: 'Cannot GET /test',
+        headers: {
+          'content-type': 'text/plain',
+          'content-length': '16'
+        },
+        isBase64Encoded: false
+      })
+
+      return done()
+    })
+  })
+})

src/index.ts

@@ -0,0 +1,132 @@
+import { format } from 'url'
+import { Request, Response } from 'servie'
+
+export type Middleware = (req: Request, res: Response, next: () => Promise<void>) => Promise<void>
+
+/**
+ * AWS Lambda event object.
+ */
+export interface Event {
+  path: string
+  httpMethod: string
+  body: string | null
+  isBase64Encoded?: boolean
+  resource: string
+  headers: {
+    [key: string]: string
+  } | null
+  queryStringParameters: {
+    [key: string]: string
+  } | null
+  pathParameters: {
+    [key: string]: string
+  } | null
+  requestContext: {
+    identity: {
+      sourceIp: string
+    }
+  }
+}
+
+/**
+ * AWS lambda context object.
+ */
+export interface Context {
+  functionName: string
+  memoryLimitInMB: string
+  functionVersion: string
+  invokeid: string
+  awsRequestId: string
+  invokedFunctionArn: string
+}
+
+/**
+ * Standard lambda HTTP response.
+ */
+export interface Result {
+  body?: string
+  statusCode?: number
+  headers?: {
+    [key: string]: string | string[]
+  }
+  isBase64Encoded?: boolean
+}
+
+/**
+ * Lambda server options.
+ */
+export interface Options {
+  isBinary?: (res: Response) => boolean
+}
+
+/**
+ * Create a server for handling AWS Lambda requests.
+ */
+export function createServer (fn: Middleware, options: Options = {}) {
+  return function (event: Event, _context: Context, cb: (err: Error | null, res?: Result) => void): void {
+    const { httpMethod: method, headers, isBase64Encoded } = event
+    const url = format({ pathname: event.path, query: event.queryStringParameters })
+    const body = event.body ? new Buffer(event.body, isBase64Encoded ? 'base64' : 'utf8') : undefined
+
+    const connection = { encrypted: true, remoteAddress: event.requestContext.identity.sourceIp }
+
+    const request = new Request({ method, url, connection, headers, body })
+    const response = new Response(request, {})
+
+    // Handle request and response errors.
+    request.events.on('error', done)
+    response.events.on('error', done)
+
+    // Marked request as finished.
+    request.started = true
+    request.finished = true
+    request.bytesTransferred = body ? body.length : 0
+
+    function done (err: Error | null, res?: Result) {
+      if (err && (request.aborted || response.started)) {
+        console.error(err)
+        return
+      }
+
+      response.started = true
+      response.finished = true
+
+      return cb(err, res)
+    }
+
+    fn(request, response, finalhandler(request, response))
+      .then((): void | Promise<void> => {
+        if (request.aborted || response.started) {
+          return
+        }
+
+        return response.buffer().then((body) => {
+          const isBase64Encoded = options.isBinary ? options.isBinary(response) : false
+
+          // Set bytes transferred.
+          response.bytesTransferred = body ? body.length : 0
+
+          return done(null, {
+            statusCode: response.status,
+            body: body ? (isBase64Encoded ? body.toString('base64') : body.toString('utf8')) : undefined,
+            headers: response.headers.object(),
+            isBase64Encoded
+          })
+        })
+      })
+      .catch((err) => done(err))
+  }
+}
+
+/**
+ * Final throwback server handler.
+ */
+function finalhandler (req: Request, res: Response) {
+  return function () {
+    res.status = 404
+    res.type = 'text/plain'
+    res.body = `Cannot ${req.method} ${req.url}`
+
+    return Promise.resolve()
+  }
+}

tsconfig.json

@@ -0,0 +1,25 @@
+{
+  "compilerOptions": {
+    "target": "es5",
+    "lib": [
+      "es2015"
+    ],
+    "rootDir": "src",
+    "outDir": "dist",
+    "module": "commonjs",
+    "moduleResolution": "node",
+    "declaration": true,
+    "noImplicitAny": true,
+    "noImplicitThis": true,
+    "noImplicitReturns": true,
+    "noUnusedLocals": true,
+    "noUnusedParameters": true,
+    "removeComments": false,
+    "sourceMap": true,
+    "inlineSources": true
+  },
+  "include": [
+    "src/**/*",
+    "typings/**/*"
+  ]
+}

tslint.json

@@ -0,0 +1,3 @@
+{
+  "extends": "tslint-config-standard"
+}

typings.json

@@ -0,0 +1,11 @@
+{
+  "globalDependencies": {
+    "node": "registry:env/node#6.0.0+20170119204930"
+  },
+  "globalDevDependencies": {
+    "jest": "registry:dt/jest#16.0.0+20170112172802"
+  },
+  "dependencies": {
+    "debug": "registry:npm/debug#2.0.0+20160723033700"
+  }
+}