update examples

Author: manwaring

examples/ts/app/cloudformation.ts

@@ -1,10 +1,23 @@
 import { cloudFormation } from '@manwaring/lambda-wrapper';
 import 'source-map-support/register';
+// import { send, SUCCESS } from './send';
+import { sendResponse } from './native-send';
 
-export const handler = cloudFormation(async ({ event, success, failure }) => {
+// export const handler = cloudFormation(async ({ event, success, failure }) => {
+//   try {
+//     success(event);
+//   } catch (err) {
+//     failure(err);
+//   }
+// });
+
+export const handler = (event, context, callback) => {
   try {
-    return success(event);
+    // send(event, context, SUCCESS);
+    sendResponse(event, context);
   } catch (err) {
-    return failure(err);
+    console.log('Error', err);
+    // send(event, context, SUCCESS);
+    sendResponse(event, context);
   }
-});
+};

examples/ts/app/native-send.ts

@@ -0,0 +1,48 @@
+// Send response to the pre-signed S3 URL
+export function sendResponse(event, context, responseStatus = 'SUCCESS', responseData = {}) {
+  var responseBody = JSON.stringify({
+    Status: responseStatus,
+    Reason: 'See the details in CloudWatch Log Stream: ' + context.logStreamName,
+    PhysicalResourceId: context.logStreamName,
+    StackId: event.StackId,
+    RequestId: event.RequestId,
+    LogicalResourceId: event.LogicalResourceId,
+    Data: responseData
+  });
+
+  console.log('RESPONSE BODY:\n', responseBody);
+
+  var https = require('https');
+  var url = require('url');
+
+  var parsedUrl = url.parse(event.ResponseURL);
+  var options = {
+    hostname: parsedUrl.hostname,
+    port: 443,
+    path: parsedUrl.path,
+    method: 'PUT',
+    headers: {
+      'content-type': '',
+      'content-length': responseBody.length
+    }
+  };
+
+  console.log('SENDING RESPONSE...\n', parsedUrl, responseBody);
+
+  var request = https.request(options, function(response) {
+    console.log('STATUS: ' + response.statusCode);
+    console.log('HEADERS: ' + JSON.stringify(response.headers));
+    // Tell AWS Lambda that the function execution is done
+    context.done();
+  });
+
+  request.on('error', function(error) {
+    console.log('sendResponse Error:' + error);
+    // Tell AWS Lambda that the function execution is done
+    context.done();
+  });
+
+  // write data to request body
+  request.write(responseBody);
+  request.end();
+}

examples/ts/app/send.ts

@@ -0,0 +1,63 @@
+import { CloudFormationCustomResourceEvent, Context } from 'aws-lambda';
+import axios from 'axios';
+import * as retry from 'async-retry';
+
+const MAX_RETRIES = 10;
+
+type ResponseStatus = 'SUCCESS' | 'FAILED';
+export const SUCCESS: ResponseStatus = 'SUCCESS';
+export const FAILED: ResponseStatus = 'FAILED';
+
+export function send(
+  event: CloudFormationCustomResourceEvent,
+  context: Context,
+  Status: ResponseStatus,
+  Data: any = {},
+  physicalResourceId: any = false,
+  NoEcho: any = false
+) {
+  const body = JSON.stringify({
+    Status,
+    Reason: `See the details in CloudWatch Log Stream: ${context.logStreamName}`,
+    PhysicalResourceId: physicalResourceId || context.logStreamName,
+    StackId: event.StackId,
+    RequestId: event.RequestId,
+    LogicalResourceId: event.LogicalResourceId,
+    NoEcho,
+    Data
+  });
+  try {
+    sendResponse(event.ResponseURL, body)
+      .then(() => {
+        console.log('Promise chain success');
+        context.done();
+      })
+      .catch(err => {
+        console.error('Promise chain error', err);
+        context.done();
+      });
+    console.log('After promise chain');
+  } catch (err) {
+    console.log('Try catch error', err);
+  }
+  console.log('Reached end of sending calls');
+}
+
+async function retrySendResponse(url, body): Promise<any> {
+  console.log('Initiating retry call');
+  return await retry(
+    async (abort, attemptCount) => {
+      console.log(`Making retry call ${attemptCount} of ${MAX_RETRIES}`);
+      await sendResponse(url, body);
+    },
+    { retries: MAX_RETRIES }
+  );
+}
+
+async function sendResponse(url, body): Promise<any> {
+  const config = { headers: { 'content-type': '', 'content-length': body.length } };
+  console.log('Making request with params', url, body, config);
+  const response = await axios.put(url, body, config);
+  console.log('Completed making request', response);
+  return response;
+}

examples/ts/package.json

@@ -7,8 +7,10 @@
     "deploy": "sls deploy"
   },
   "dependencies": {
-    "source-map-support": "^0.5.10",
-    "@manwaring/lambda-wrapper": "*"
+    "@manwaring/lambda-wrapper": "*",
+    "async-retry": "^1.2.3",
+    "axios": "^0.19.0",
+    "source-map-support": "^0.5.10"
   },
   "devDependencies": {
     "@types/aws-lambda": "^8.10.17",

examples/ts/serverless.yml

@@ -1,5 +1,5 @@
 service:
-  name: lambda-wrapper-ts
+  name: lambda-wrapper-ts3
 
 plugins:
   - serverless-webpack