feat(mojaloop/#3885): extend fxquote functionality to persistant mode

docker-compose.yml

@@ -9,6 +9,7 @@ x-depends-on: &dependsOnMysqlAndKafka
     condition: service_completed_successfully
 
 x-quoting-service: &quotingServiceBase
+  image: mojaloop/quoting-service:local
   build:
     context: .
     cache_from:
@@ -63,7 +64,7 @@ services:
 
 
   central-ledger:
-    image: mojaloop/central-ledger:v17.7.0-snapshot.20
+    image: mojaloop/central-ledger:v17.8.0-snapshot.7
     container_name: qs_central-ledger
     ports:
       - "3001:3001"

docker/central-ledger/default.json

@@ -67,6 +67,14 @@
       }
     }
   },
+  "PROXY_CACHE": {
+    "enabled": false,
+    "type": "redis",
+    "proxyConfig": {
+      "host": "localhost",
+      "port": 6379
+    }
+  },
   "PARTICIPANT_INITIAL_POSITION": 0,
   "HUB_PARTICIPANT": {
     "ID": 1,

src/data/cachedDatabase.js

@@ -30,21 +30,22 @@
  --------------
  ******/
 
-const util = require('util')
 const Database = require('./database.js')
 const Cache = require('memory-cache').Cache
 const ErrorHandler = require('@mojaloop/central-services-error-handling')
 const Metrics = require('@mojaloop/central-services-metrics')
 
-const { getStackOrInspect } = require('../lib/util')
+const { loggerFactory } = require('../lib/index.js')
 
 /**
  * An extension of the Database class that caches enum values in memory
  */
 class CachedDatabase extends Database {
-  constructor (config) {
+  constructor (config, logger) {
     super(config)
-
+    this.log = logger || loggerFactory({
+      context: this.constructor.name
+    })
     this.cache = new Cache()
   }
 
@@ -112,7 +113,7 @@ class CachedDatabase extends Database {
 
       if (!value) {
         // we need to get the value from the db and cache it
-        this.writeLog(`Cache miss for ${type}: ${util.inspect(params)}`)
+        this.log.debug('Cache miss for: ', { type, params })
         value = await super[type].apply(this, params)
         // cache participant with a shorter TTL than enums (participant data is more likely to change)
         if (
@@ -126,13 +127,13 @@ class CachedDatabase extends Database {
         }
         histTimer({ success: true, queryName: type, hit: false })
       } else {
-        this.writeLog(`Cache hit for ${type} ${util.inspect(params)}: ${value}`)
+        this.log.error('Cache hit for : ', { type, params, value })
         histTimer({ success: true, queryName: type, hit: true })
       }
 
       return value
     } catch (err) {
-      this.writeLog(`Error in getCacheValue: ${getStackOrInspect(err)}`)
+      this.log.error('Error in getCacheValue: ', err)
       histTimer({ success: false, queryName: type, hit: false })
       throw ErrorHandler.Factory.reformatFSPIOPError(err)
     }