Merge pull request #7 from opentorc/develop

Add Caching
opentorc · Dec 12, 2022 · 7cec38c · 7cec38c
2 parents 122e25a + 690500b
commit 7cec38c
Show file tree

Hide file tree

Showing 4 changed files with 14 additions and 4 deletions.
diff --git a/codealike.json b/codealike.json
@@ -0,0 +1 @@
+{"projectId":"0bf825e0-7a14-11ed-9fab-c79574c4e560","projectName":"config-wrapper"}
diff --git a/package-lock.json b/package-lock.json
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@opentorc/config-wrapper",
-  "version": "1.2.2",
+  "version": "1.2.3",
   "description": "config management wrapper",
   "main": "./src/index.js",
   "bin": {

diff --git a/src/lib/awsManager.js b/src/lib/awsManager.js
@@ -4,6 +4,8 @@ let ssm
 
 const BASE_PATH = '/torc'
 
+const cachedParams = {}
+
 function initializeSSM() {
   if (!ssm) {
     ssm = new AWS.SSM();
@@ -44,6 +46,12 @@ async function getParameter(env, service, paramName, isEncrypted) {
 async function getParametersByService(env, service, isEncrypted) {
   const Path = constructParamPath(env, service)
   console.log(`Getting parameters from ${Path}`)
+
+  if (cachedParams[Path]) {
+    console.log('Found parameters in cache. Returning...')
+    return cachedParams[Path]
+  }
+
   var config = {
     Path,
     Recursive: true,
@@ -63,11 +71,12 @@ async function getParametersByService(env, service, isEncrypted) {
       convertedParams[param.name] = param
     }
 
-    params = await ssm.getParametersByPath(config).promise()
     nextToken = params.NextToken
     config.NextToken = nextToken
   } while (nextToken)
 
+  cachedParams[Path] = convertedParams
+
   return convertedParams
 }
Original file line number	Diff line number	Diff line change
		@@ -0,0 +1 @@
		{"projectId":"0bf825e0-7a14-11ed-9fab-c79574c4e560","projectName":"config-wrapper"}