2019-01-18 00:02:57 -08:00
// Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
// SPDX-License-Identifier: Apache-2.0
2024-01-16 10:41:11 -05:00
2019-01-18 00:02:57 -08:00
//
// This file is licensed under the Apache License, Version 2.0 (the "License").
// You may not use this file except in compliance with the License. A copy of the
// License is located at
//
// http://aws.amazon.com/apache2.0/
//
// This file 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.
// snippet-start:[cdk.typescript.widgets]
// snippet-start:[cdk.typescript.widgets.imports]
const AWS = require ( "aws-sdk" ) ;
const S3 = new AWS . S3 ( ) ;
// snippet-end:[cdk.typescript.widgets.imports]
const bucketName = process . env . BUCKET ;
// snippet-start:[cdk.typescript.widgets.exports_main]
2020-05-07 13:05:50 +01:00
/*
This code uses callbacks to handle asynchronous function responses.
It currently demonstrates using an async-await pattern.
AWS supports both the async-await and promises patterns.
For more information, see the following:
https://developer.mozilla.org/en-US/docs/Web/JavaScript/Reference/Statements/async_function
https://developer.mozilla.org/en-US/docs/Web/JavaScript/Guide/Using_promises
https://docs.aws.amazon.com/sdk-for-javascript/v2/developer-guide/calling-services-asynchronously.html
https://docs.aws.amazon.com/lambda/latest/dg/nodejs-prog-model-handler.html
*/
2019-01-18 00:02:57 -08:00
exports . main = async function ( event , context ) {
try {
var method = event . httpMethod ;
// Get name, if present
var widgetName = event . path . startsWith ( "/" )
? event . path . substring ( 1 )
: event . path ;
if ( method === "GET" ) {
// GET / to get the names of all widgets
if ( event . path === "/" ) {
const data = await S3 . listObjectsV2 ( { Bucket : bucketName } ) . promise ( ) ;
var body = {
widgets : data . Contents . map ( function ( e ) {
return e . Key ;
} ) ,
} ;
return {
statusCode : 200 ,
headers : { } ,
body : JSON . stringify ( body ) ,
} ;
}
if ( widgetName ) {
// GET /name to get info on widget name
const data = await S3 . getObject ( {
Bucket : bucketName ,
Key : widgetName ,
} ) . promise ( ) ;
var body = data . Body . toString ( "utf-8" ) ;
return {
statusCode : 200 ,
headers : { } ,
body : JSON . stringify ( body ) ,
} ;
}
}
if ( method === "POST" ) {
// POST /name
// Return error if we do not have a name
if ( ! widgetName ) {
return {
statusCode : 400 ,
headers : { } ,
body : "Widget name missing" ,
} ;
}
// Create some dummy data to populate object
const now = new Date ( ) ;
var data = widgetName + " created: " + now ;
var base64data = new Buffer ( data , "binary" ) ;
await S3 . putObject ( {
Bucket : bucketName ,
Key : widgetName ,
Body : base64data ,
ContentType : "application/json" ,
} ) . promise ( ) ;
return {
statusCode : 200 ,
headers : { } ,
body : JSON . stringify ( event . widgets ) ,
} ;
}
if ( method === "DELETE" ) {
// DELETE /name
// Return an error if we do not have a name
if ( ! widgetName ) {
return {
statusCode : 400 ,
headers : { } ,
body : "Widget name missing" ,
} ;
}
await S3 . deleteObject ( {
Bucket : bucketName ,
Key : widgetName ,
} ) . promise ( ) ;
return {
statusCode : 200 ,
headers : { } ,
body : "Successfully deleted widget " + widgetName ,
} ;
}
// We got something besides a GET, POST, or DELETE
return {
statusCode : 400 ,
headers : { } ,
body : "We only accept GET, POST, and DELETE, not " + method ,
} ;
} catch ( error ) {
var body = error . stack || JSON . stringify ( error , null , 2 ) ;
return {
statusCode : 400 ,
headers : { } ,
body : body ,
} ;
}
} ;
// snippet-end:[cdk.typescript.widgets.exports_main]
// snippet-end:[cdk.typescript.widgets]
