Added a configurable handle of the cache to enable/disable by environ…

…ment variable ENABLE_CACHE

src/config.ts

@@ -126,6 +126,7 @@ const parseConfig = (config: EnvironmentVariables & Record<string, string>): Run
     ACL_CONTEXT_BUILDER_PATH = defaults.ACL_CONTEXT_BUILDER_PATH,
     LANGUAGES_DIRECTORY_PATH = defaults.LANGUAGES_DIRECTORY_PATH,
     SERVICE_CONFIG_PATH = defaults.SERVICE_CONFIG_PATH,
+    ENABLE_CACHE = defaults.ENABLE_CACHE,
   } = config
   let serviceConfig: unknown = defaults.PUBLIC_HEADERS_MAP
 
@@ -164,6 +165,7 @@ const parseConfig = (config: EnvironmentVariables & Record<string, string>): Run
     RESOURCES_DIRECTORY_PATH: config.RESOURCES_DIRECTORY_PATH ?? defaults.RESOURCES_DIRECTORY_PATH,
     SERVICE_CONFIG_PATH,
     USER_PROPERTIES_HEADER_KEY: config.USER_PROPERTIES_HEADER_KEY,
+    ENABLE_CACHE,
   }
 }
 

src/defaults.ts

@@ -22,6 +22,8 @@ const CONTENT_TYPE_MAP: Record<Extension | string, string> = {
   '.yml': 'text/yaml',
 }
 
+const ENABLE_CACHE = 'true'
+
 export {
   ACL_CONTEXT_BUILDER_PATH,
   CONTENT_TYPE_MAP,
@@ -30,4 +32,5 @@ export {
   PUBLIC_DIRECTORY_PATH,
   PUBLIC_HEADERS_MAP,
   LANGUAGES_DIRECTORY_PATH,
+  ENABLE_CACHE,
 }

src/lib/configurations.ts

@@ -89,8 +89,15 @@ const shouldManipulate = (extension: ExtensionOutput): extension is Extension =>
   ['.json', '.yaml', '.yml'].includes(extension)
 
 async function configurationsHandler(request: FastifyRequest, filename: string, config: RuntimeConfig): Promise<ConfigurationResponse> {
-  const bufferPromise = fsCache.get(filename) ?? fileLoader(filename)
-  fsCache.set(filename, bufferPromise)
+  let bufferPromise: Promise<Buffer>
+
+  if (config.ENABLE_CACHE === "true" ) {
+    bufferPromise = fsCache.get(filename) ?? fileLoader(filename)
+    fsCache.set(filename, bufferPromise)
+  } else {
+    bufferPromise = fileLoader(filename)
+  }
+
   const buffer = await bufferPromise
 
   const fileExtension = path.extname(filename) as ExtensionOutput

src/lib/onSendHandler.ts

@@ -85,7 +85,7 @@ const staticFileHandler = (context: FastifyContext) => async (
     language && reply.header('content-language', language)
     buffer = fileBuffer
   } else if (isPublic(url)) {
-    const fileBuffer = await publicHandler(filename, injectNonce)
+    const fileBuffer = await publicHandler(filename, injectNonce, config)
     // eslint-disable-next-line @typescript-eslint/no-floating-promises
     reply.header('content-length', fileBuffer.length)
     buffer = fileBuffer

src/lib/public.ts

@@ -1,10 +1,17 @@
 import { readFile } from 'fs/promises'
+import { RuntimeConfig } from '../config'
 
 const fsCache = new Map<string, Promise<Buffer>>()
 
-async function publicHandler(filename: string, injectNonce: (input: string) => string): Promise<Buffer> {
-  const bufferPromise: Promise<Buffer> = fsCache.get(filename) ?? readFile(filename)
-  fsCache.set(filename, bufferPromise)
+async function publicHandler(filename: string, injectNonce: (input: string) => string, config: RuntimeConfig): Promise<Buffer> {
+  let bufferPromise: Promise<Buffer>
+
+  if (config.ENABLE_CACHE === "true") {
+    bufferPromise = fsCache.get(filename) ?? readFile(filename)
+    fsCache.set(filename, bufferPromise)
+  } else {
+    bufferPromise = readFile(filename)
+  }
 
   // in case of html, parse variables
   if (filename.endsWith('.html')) {

src/lib/test/extract-acl-context.test.ts

@@ -32,6 +32,7 @@ describe('Extract Acl Context', () => {
     RESOURCES_DIRECTORY_PATH: '',
     SERVICE_CONFIG_PATH: '',
     USER_PROPERTIES_HEADER_KEY: 'userproperties',
+    ENABLE_CACHE: '',
   }
 
   const request = {

src/lib/test/extract-language-context.test.ts

@@ -45,6 +45,7 @@ describe('Extract Language Context', () => {
     RESOURCES_DIRECTORY_PATH: '',
     SERVICE_CONFIG_PATH: '',
     USER_PROPERTIES_HEADER_KEY: '',
+    ENABLE_CACHE: '',
   }
 
   interface Test {

src/lib/test/serve-files.test.ts

@@ -28,6 +28,7 @@ import * as evaluateAcl from '../../sdk/evaluate-acl'
 import * as evaluateLanguage from '../../sdk/evaluate-language'
 import * as resolveReferences from '../../sdk/resolve-references'
 import { baseVariables, createConfigFile, createTmpDir, setupFastify } from '../../utils/test-utils'
+import { ENABLE_CACHE } from '../../defaults'
 
 describe('Serve files', () => {
   const sandbox = createSandbox()
@@ -65,6 +66,7 @@ describe('Serve files', () => {
     fastify = await setupFastify({
       RESOURCES_DIRECTORY_PATH: configurations,
       SERVICE_CONFIG_PATH: configPath,
+      ENABLE_CACHE: '',
     })
   })
 

src/lib/test/serve-public.test.ts

@@ -60,6 +60,7 @@ describe('Serve files', () => {
       PUBLIC_DIRECTORY_PATH: publicDir,
       RESOURCES_DIRECTORY_PATH: resourcesDir,
       SERVICE_CONFIG_PATH: configPath,
+      ENABLE_CACHE: '',
     })
   })
 

src/schemas/environmentVariablesSchema.ts

@@ -39,6 +39,10 @@ export const environmentVariablesSchema = {
       description: 'service configuration file absolute path',
       type: 'string',
     },
+    ENABLE_CACHE: {
+      description: 'Enable use of cache (default: true)',
+      type: 'string',
+    }
   },
   required: [],
   type: 'object',

src/test/config.test.ts

@@ -38,6 +38,7 @@ const defaults = {
   PUBLIC_DIRECTORY_PATH: '/usr/static/public',
   RESOURCES_DIRECTORY_PATH: '/usr/static/configurations',
   USER_PROPERTIES_HEADER_KEY: 'miauserproperties',
+  ENABLE_CACHE: defaultConfigs.ENABLE_CACHE,
 }
 
 describe('config injection tests', () => {