Added support to query secret manager via parameter store (#30)

* Added support for secrets manager

* Rollback changes

* Updates to README.md

* Added information around dynamodb key to include <hyphen> part of the lookup

Co-authored-by: Hari Ohm Prasath <[email protected]>

Author: hariohmprasath

cache-extension-demo/README.md

@@ -72,6 +72,7 @@ aws dynamodb put-item \
     --return-consumed-capacity TOTAL \
     --return-item-collection-metrics SIZE
 ```
+> Note: Dynamodb values are stored under the key generated using the format `<table><hyphen><hashkey><hyphen><rangekey>`
 
 ## Compile package and dependencies
 To run this example, you will need to ensure that your build architecture matches that of the Lambda execution environment by compiling with `GOOS=linux` and `GOARCH=amd64` if you are not running in a Linux environment.
@@ -108,7 +109,8 @@ Add the newly created layer version to a Lambda function.
 - Make sure to have a `config.yaml` in the root of the lambda function's directory and updated with the correct region information. You can use the provided `config.yaml` in the the `example/` directory
 - Make sure to increase the default timeout to 2 mins and memory to 512 MB
 
->Note: Make sure to have`'AmazonDynamoDBReadOnlyAccess'` & `'AmazonSSMReadOnlyAccess'` IAM policies assigned to the IAM role associated with the Lambda function
+>Note: Make sure to have`'AmazonDynamoDBReadOnlyAccess'` & `'AmazonSSMReadOnlyAccess'` IAM policies assigned to the IAM role associated with the Lambda function.
+> If you are caching entries in secrets manager using /aws/reference/secretsmanager/<secret> then make sure to assign `'SecretsManagerReadWrite'` policy to the IAM role
 
 Here is the AWS CLI command that can update the layers on the existing AWS Lambda function
 

cache-extension-demo/example-function/index.js

@@ -6,7 +6,7 @@ exports.handler = function(event, context, callback) {
     const options = {
         hostname: 'localhost',
         port: 3000,
-        path: '/dynamodb/DynamoDbTable-pKey1-sKey1',
+        path: '/dynamodb?name=DynamoDbTable-pKey1-sKey1',
         method: 'GET'
     }
 

cache-extension-demo/img/Sequence.svg

@@ -6,7 +6,7 @@ Extension-->Extension: Initialization complete
 Extension->DynamoDB: Initialize cache map and fetch all \nrecords listed in config.yaml if \n CACHE_EXTENSION_INIT_STARTUP=true
 Extension-->Extension: Initialization complete
 Extension-->Extension: Start a HTTP server
-Lambda->Extension: HTTP Get:/parameters/<name> to read from parameters cache
+Lambda->Extension: HTTP Get:/parameters?name=<name> to read from parameters cache
 Extension-->Lambda: Check whether item exists in cache and not exired?\nIf yes return it or \nread it from parameter store, cache it and return it
-Lambda->Extension: HTTP Get:/dynamodb/<table><hashkey><rangekey> to read from dynamodb cache
+Lambda->Extension: HTTP Get:/dynamodb?name=<table><hyphen><hashkey><hyphen><rangekey> \nto read from dynamodb cache
 Extension-->Lambda: Check whether item exists in cache and not exired?\nIf yes return it or \nread it from Dynamodb, cache it and return it as JSON string

cache-extension-demo/img/Sequence.txt

@@ -18,10 +18,10 @@ func Start(port string) {
 // Method that responds back with the cached values
 func startHTTPServer(port string) {
 	router := mux.NewRouter()
-	router.HandleFunc("/{cacheType}/{key}",
+	router.Path("/{cacheType}").Queries("name", "{name}").HandlerFunc(
 		func(w http.ResponseWriter, r *http.Request) {
 			vars := mux.Vars(r)
-			value := extension.RouteCache(vars["cacheType"], vars["key"])
+			value := extension.RouteCache(vars["cacheType"], vars["name"])
 
 			if len(value) != 0 {
 				_, _ = w.Write([]byte(value))