using es6

Author: ankkho

.gitignore

@@ -1 +1,2 @@
 node_modules
+.webpack

README.md

@@ -14,6 +14,7 @@ In order to install and run this example you need an AWS accounts credentials co
 git clone [email protected]:ankkho/aws-node-elasticache-redis.git
 cd aws-node-elasticache-redis
 npm install
+export REGION='your-desired-aws-region' eg: 'ap-south-1'
 ```
 
 2. Deploy using sls deploy

aws/redis.js

@@ -1,25 +1,23 @@
-const redis = require('redis');
-const bluebird = require('bluebird');
-const currentRedisEndpoint = 'redis://localhost:6379';
+/*
+	Returns promise functions for interacting with redis
+*/
 
-bluebird.promisifyAll(redis.RedisClient.prototype);
-bluebird.promisifyAll(redis.Multi.prototype);
+import redis from 'redis'
+import bluebird from 'bluebird'
 
-const createRedisClient = (endpoint) => {
-	const clientObj = redis.createClient(false, endpoint, {
-		no_ready_check: true,
-	});
+bluebird.promisifyAll(redis.RedisClient.prototype)
+bluebird.promisifyAll(redis.Multi.prototype)
 
-	clientObj.on('error', (err) => {
-		console.log(`Error while creating redis client: ${err}`);
-	});
+const createRedisClient = () => {
+	const clientObj = redis.createClient(6379, process.env.cacheURL, { no_ready_check: true })
 
-	return clientObj;
-};
+	clientObj.on('error', (err) => {
+		console.log(`Error while creating redis client: ${err}`)
+	})
 
-const client = createRedisClient(currentRedisEndpoint);
+	return clientObj
+}
 
+const client = createRedisClient()
 
-module.exports = {
-	client,
-};
+export default client

handler.js

@@ -1,8 +1,12 @@
-const lib = require('./lib');
+import {
+	getProductDataResponse,
+	saveProductDataResponse,
+} from './lib'
 
-const getProductData = (event, context) =>
-lib.getProductDataResponse(event, (error, response) => context.done(error, response));
+const getProductData = (event, context) => getProductDataResponse(event, (error, response) => context.done(error, response))
+const saveProductData = (event, context) => saveProductDataResponse(event, (error, response) => context.done(error, response))
 
-module.exports = {
-  getProductData,
-};
+export {
+	getProductData,
+	saveProductData,
+}

lib/functions/getProductData.js

@@ -1,16 +1,13 @@
-const redis = require('../../aws/redis');
-const util = require('../util');
+import redis from '../../aws/redis'
+import { keyName } from '../util'
 
-const get = function* (productId) {
-	const keyName = util.keyName(productId);
+function* get(productId) {
 	const name = {
 		name: 'foo',
 	};
-	console.log('.......');
-	yield redis.client.hmsetAsync(keyName, name);
+	yield redis.client.hmsetAsync(keyName(productId), name);
 	const data = yield redis.client.hmgetallAsync(keyName);
-	console.log({ data });
 	return data ? { data: {} } : { data };
-};
+}
 
-module.exports = { get };
+export default get

lib/functions/saveProductData.js

@@ -1,10 +1,9 @@
-const redis = require('../../aws/redis');
-const util = require('../util');
+import redis from '../../aws/redis'
+import { keyName } from '../util'
 
-const save = function* (body) {
+function* save(body) {
 	const { productId } = body;
-	const keyName = util.keyName(productId);
-	return yield redis.hmsetAsync(keyName, body);
-};
+	return yield redis.hmsetAsync(keyName(productId), body);
+}
 
-module.exports = { save };
+export default save

lib/index.js

@@ -1,19 +1,26 @@
-const getProductData = require('./functions/getProductData');
-const saveProductData = require('./functions/saveProductData');
+import co from 'co'
+import getProductData from './functions/getProductData'
+import saveProductData from './functions/saveProductData'
 
-const util = require('./util');
+import { response } from './util'
 
 // response for getAllProducts
 const getProductDataResponse = (event, cb) => {
-	const id = event.pathParameters.id;
-	const resp = getProductData.get(id);
+	co(function* () {
+		const { pathParameters: { id } } = event
+		const resp = yield getProductData(id);
 
-	return cb(null, util.response(resp));
+		return cb(null, response(resp))
+	})
 };
 
 const saveProductDataResponse = (event, cb) => {
-	const { body } = JSON.parse(event.body);
-	saveProductData.save(body).then(resp => cb(null, util.response('done')));
+	co(function* () {
+		const { body } = JSON.parse(event.body);
+		const resp = yield saveProductData(body)
+
+		return cb(null, response(resp))
+	})
 };
 
 export {

lib/util.js

@@ -1,11 +1,5 @@
 const keyName = productId => `product:${productId}:data`;
-
-const response = message => ({
-	statusCode: 200,
-	body: {
-		message,
-	},
-});
+const response = body => ({ statusCode: 200, body: JSON.stringify(body) })
 
 export {
 	keyName,

serverless.yml

@@ -4,8 +4,7 @@ provider:
   name: aws
   runtime: nodejs6.10
   stage: dev
-  profile: disvoice-${self:provider.stage}
-  region: ${env:REGION}
+  region: 'ap-south-1'
   memorySize: 128
   timeout: 10
   cfLogs: true
@@ -15,14 +14,14 @@ provider:
     environment: dev
     serviceName: serverless-sample
   environment:
-    cacheUrl: ${cf:serverless-sample-dev.cacheUrl}
-  vpc:
-    securityGroupIds:
-      - ${cf:serverless-sample-dev.VPCSecurityGroup}
-      - ${cf:serverless-sample-dev.RedisSecurityGroup}
-    subnetIds:
-      - ${cf:serverless-sample-dev.PrivateSubnetA}
-      - ${cf:serverless-sample-dev.PublicSubnetB}
+    # cacheUrl: ${cf:serverless-sample-dev.cacheUrl}
+  # vpc:
+  #   securityGroupIds:
+  #     - ${cf:serverless-sample-dev.VPCSecurityGroup}
+  #     - ${cf:serverless-sample-dev.RedisSecurityGroup}
+  #   subnetIds:
+  #     - ${cf:serverless-sample-dev.PrivateSubnetA}
+  #     - ${cf:serverless-sample-dev.PublicSubnetB}
 package:
   exclude:
     - ./node_modules/**

webpack.config.js

@@ -27,20 +27,6 @@ module.exports = {
 	},
 	plugins: [
 		new webpack.NoEmitOnErrorsPlugin(),
-		new webpack.optimize.UglifyJsPlugin({
-			mangle: true,
-			comments: false,
-			compress: {
-				warnings: false,
-				pure_getters: true,
-				unsafe: true,
-				unsafe_comps: true,
-			},
-			output: {
-				comments: false,
-			},
-			exclude: [/\.min\.js$/gi],
-		}),
 		new CompressionPlugin({ asset: '[path].gz[query]', algorithm: 'gzip', test: /\.js/, threshold: 10240, minRatio: 0 }),
 	],
 };