From 3b279855a2562765975f7271490e4483254d7c96 Mon Sep 17 00:00:00 2001
From: Bert Verhelst <verhelstbert@gmail.com>
Date: Wed, 23 May 2018 10:18:39 +0200
Subject: [PATCH] Add example code to deploy xmysql to aws lambda

---
 examples/aws-lambda/index.js | 81 ++++++++++++++++++++++++++++++++++++
 1 file changed, 81 insertions(+)
 create mode 100644 examples/aws-lambda/index.js

diff --git a/examples/aws-lambda/index.js b/examples/aws-lambda/index.js
new file mode 100644
index 0000000000..98a455376d
--- /dev/null
+++ b/examples/aws-lambda/index.js
@@ -0,0 +1,81 @@
+/**
+ * I was able to get xmysql to work on AWS lambda. This is just some docs on the process to help others.
+ * AWS setup notes:
+ * * The deploy uses serverless: https://serverless.com/framework/docs/getting-started/
+ * * The lambda function is accessed through API Gateway and access the RDS (mysql) database
+ * ** Make sure you deploy your API Gateway setup otherwise it won't be accessible.
+ * * The security setup:
+ * ** You need to put your lambda in a VPC
+ * ** The lambda role needs access to the VPC
+ * ** The RDS server has to be inside the VPC as well
+*
+ * Performance:
+ * * Requests to the API Gateway resolve in ~ 90ms
+ *
+ * Extra packages needed:
+ * * serverless-http
+ *
+ * More info on deploying this to lambda:
+ * * https://serverless.com/blog/serverless-express-rest-api/
+ */
+
+"use strict";
+Object.defineProperty(exports, "__esModule", {value: true});
+var bodyParser = require("body-parser");
+var express = require("express");
+var serverless = require('serverless-http');
+var cors = require("cors");
+var mysql = require('mysql');
+var Xapi = require('./node_modules/xmysql/lib/xapi.js');
+var morgan = require('morgan');
+var app = express();
+
+var onXapiInitialized = new Promise(function (resolve, reject) {
+    try {
+        // /**************** START : setup express ****************/
+        app.use(morgan('tiny'));
+        app.use(cors());
+        app.use(bodyParser.json());
+        app.use(bodyParser.urlencoded({
+            extended: true
+        }));
+        // /**************** END : setup express ****************/
+
+        app.use(function (req, res, next) {
+            // You can add authentication here
+            console.log('Received request for: ' + req.url, req);
+            next();
+        });
+
+        var mysqlConfig = {
+            host: config.mysql.host,
+            port: 3306,
+            database: config.mysql.database,
+            user: config.mysql.user,
+            password: config.mysql.password,
+            apiPrefix: '/',
+            ipAddress: 'localhost',
+            portNumber: 3000,
+            ignoreTables: [],
+            storageFolder: __dirname
+        };
+
+        var mysqlPool = mysql.createPool(mysqlConfig);
+        var xapi = new Xapi(mysqlConfig, mysqlPool, app);
+        xapi.init(function (err, results) {
+            app.listen(3000);
+            resolve();
+        });
+    }
+    catch (err) {
+        reject(err);
+    }
+});
+
+function handler(event, context, callback) {
+    onXapiInitialized.then(function () {
+        serverless(app)(event, context, callback);
+    });
+}
+
+exports.handler = handler;