Feat: make compute schema middleware for 'db' changing
This commit is contained in:
parent
7bbf2829de
commit
cbf0165893
2 changed files with 15 additions and 0 deletions
12
lib/compute-schema.js
Normal file
12
lib/compute-schema.js
Normal file
|
|
@ -0,0 +1,12 @@
|
||||||
|
const { asyncLocalStorage } = require('./async-storage')
|
||||||
|
|
||||||
|
const computeSchema = (req, res, next) => {
|
||||||
|
const store = new Map()
|
||||||
|
store.set('schema', 'public')
|
||||||
|
store.set('defaultSchema', 'ERROR_SCHEMA')
|
||||||
|
asyncLocalStorage.run(store, () => {
|
||||||
|
next()
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|
||||||
|
module.exports = computeSchema
|
||||||
|
|
@ -8,6 +8,8 @@ const nocache = require('nocache')
|
||||||
const authorize = require('./middlewares/authorize')
|
const authorize = require('./middlewares/authorize')
|
||||||
const errorHandler = require('./middlewares/errorHandler')
|
const errorHandler = require('./middlewares/errorHandler')
|
||||||
const filterOldRequests = require('./middlewares/filterOldRequests')
|
const filterOldRequests = require('./middlewares/filterOldRequests')
|
||||||
|
const computeSchema = require('./compute-schema')
|
||||||
|
const dbErrorCodes = require('./db-error-codes')
|
||||||
const logger = require('./logger')
|
const logger = require('./logger')
|
||||||
const options = require('./options')
|
const options = require('./options')
|
||||||
const findOperatorId = require('./middlewares/operatorId')
|
const findOperatorId = require('./middlewares/operatorId')
|
||||||
|
|
@ -56,6 +58,7 @@ app.use('/', pairingRoutes)
|
||||||
|
|
||||||
app.use(findOperatorId)
|
app.use(findOperatorId)
|
||||||
app.use(populateDeviceId)
|
app.use(populateDeviceId)
|
||||||
|
app.use(computeSchema)
|
||||||
if (!devMode) app.use(authorize)
|
if (!devMode) app.use(authorize)
|
||||||
app.use(configRequiredRoutes, populateSettings)
|
app.use(configRequiredRoutes, populateSettings)
|
||||||
app.use(filterOldRequests)
|
app.use(filterOldRequests)
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue