Merge pull request #488 from ZIMkaRU/feature/separate-db-files-for-prod-and-staging

Separate db files for prod and staging

Author: tarcisiozf

workers/api.framework.report.wrk.js

@@ -42,6 +42,7 @@ const {
 const appDeps = require('./loc.api/di/app.deps')
 const TYPES = require('./loc.api/di/types')
 const fwDataValidator = require('./loc.api/data-validator')
+const { isBfxApiStaging } = require('./loc.api/helpers')
 
 class WrkReportFrameWorkApi extends WrkReportServiceApi {
   loadCoreDeps (...args) {
@@ -128,8 +129,12 @@ class WrkReportFrameWorkApi extends WrkReportServiceApi {
       syncMode,
       dbDriver,
       verboseSql,
-      dbPathAbsolute
+      dbPathAbsolute,
+      restUrl
     } = this.conf[this.group]
+    const stagingDbLabel = isBfxApiStaging(restUrl)
+      ? '-staging'
+      : ''
     const facs = []
 
     if (syncMode) {
@@ -147,7 +152,7 @@ class WrkReportFrameWorkApi extends WrkReportServiceApi {
           'm0',
           'm0',
           {
-            name: 'sync',
+            name: `sync${stagingDbLabel}`,
             dbPathAbsolute,
             workerPathAbsolute,
             verbose: verboseSql,

workers/loc.api/helpers/index.js

@@ -18,6 +18,7 @@ const {
   getAuthFromSubAccountAuth,
   getSubAccountAuthFromAuth
 } = require('./sub-account-auth')
+const isBfxApiStaging = require('./is-bfx-api-staging')
 
 module.exports = {
   checkParamsAuth,
@@ -33,5 +34,6 @@ module.exports = {
   sumAllObjectsNumbers,
   pickAllLowerObjectsNumbers,
   sumArrayVolumes,
-  pushLargeArr
+  pushLargeArr,
+  isBfxApiStaging
 }

workers/loc.api/helpers/is-bfx-api-staging.js

@@ -0,0 +1,11 @@
+'use strict'
+
+const pattern = /(staging)|(test)/i
+
+module.exports = (restUrl) => {
+  return !!(
+    restUrl &&
+    typeof restUrl === 'string' &&
+    pattern.test(restUrl)
+  )
+}

workers/loc.api/sync/dao/db.backup.manager/index.js

@@ -6,6 +6,8 @@ const path = require('path')
 const moment = require('moment')
 const { orderBy } = require('lodash')
 
+const { isBfxApiStaging } = require('../../../helpers')
+
 const { decorateInjectable } = require('../../../di/utils')
 
 const depsTypes = (TYPES) => [
@@ -39,7 +41,10 @@ class DBBackupManager {
       this.conf.dbPathAbsolute,
       'backups'
     )
-    this._dbFileName = 'db-sqlite_sync_m0.db'
+    const stagingDbLabel = isBfxApiStaging(this.conf.restUrl)
+      ? '-staging'
+      : ''
+    this._dbFileName = `db-sqlite_sync${stagingDbLabel}_m0.db`
     this._dbDestination = path.join(
       this.conf.dbPathAbsolute,
       this._dbFileName