|
|
@ -71,7 +71,9 @@ exports.doInTenant = (tenantId, task) => { |
|
|
// set the tenant id
|
|
|
// set the tenant id
|
|
|
if (!opts.existing) { |
|
|
if (!opts.existing) { |
|
|
cls.setOnContext(ContextKeys.TENANT_ID, tenantId) |
|
|
cls.setOnContext(ContextKeys.TENANT_ID, tenantId) |
|
|
exports.setGlobalDB(tenantId) |
|
|
if (env.USE_COUCH) { |
|
|
|
|
|
exports.setGlobalDB(tenantId) |
|
|
|
|
|
} |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
try { |
|
|
try { |
|
|
@ -80,7 +82,9 @@ exports.doInTenant = (tenantId, task) => { |
|
|
} finally { |
|
|
} finally { |
|
|
const using = cls.getFromContext(ContextKeys.IN_USE) |
|
|
const using = cls.getFromContext(ContextKeys.IN_USE) |
|
|
if (!using || using <= 1) { |
|
|
if (!using || using <= 1) { |
|
|
await closeDB(exports.getGlobalDB()) |
|
|
if (env.USE_COUCH) { |
|
|
|
|
|
await closeDB(exports.getGlobalDB()) |
|
|
|
|
|
} |
|
|
// clear from context now that database is closed/task is finished
|
|
|
// clear from context now that database is closed/task is finished
|
|
|
cls.setOnContext(ContextKeys.TENANT_ID, null) |
|
|
cls.setOnContext(ContextKeys.TENANT_ID, null) |
|
|
cls.setOnContext(ContextKeys.GLOBAL_DB, null) |
|
|
cls.setOnContext(ContextKeys.GLOBAL_DB, null) |
|
|
@ -167,6 +171,7 @@ exports.doInAppContext = (appId, task) => { |
|
|
|
|
|
|
|
|
exports.updateTenantId = tenantId => { |
|
|
exports.updateTenantId = tenantId => { |
|
|
cls.setOnContext(ContextKeys.TENANT_ID, tenantId) |
|
|
cls.setOnContext(ContextKeys.TENANT_ID, tenantId) |
|
|
|
|
|
exports.setGlobalDB(tenantId) |
|
|
} |
|
|
} |
|
|
|
|
|
|
|
|
exports.updateAppId = async appId => { |
|
|
exports.updateAppId = async appId => { |
|
|
|