move database scripts
parent
360e5e2565
commit
184cdd3fb7
|
|
@ -23,8 +23,8 @@ for (let index = 0; index < processCount; index += 1) {
|
||||||
activeWorkers.set(worker.process.pid, worker);
|
activeWorkers.set(worker.process.pid, worker);
|
||||||
}
|
}
|
||||||
cluster.on('message', (worker, message) => {
|
cluster.on('message', (worker, message) => {
|
||||||
for (const [pid, worker] of activeWorkers.entries()) {
|
for (const [pid, activeWorker] of activeWorkers.entries()) {
|
||||||
if (worker === undefined || pid === message.pid) {
|
if (activeWorker === undefined || pid === message.pid) {
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
debug(`Relaying message to worker: ${pid}`);
|
debug(`Relaying message to worker: ${pid}`);
|
||||||
|
|
|
||||||
|
|
@ -41,8 +41,8 @@ for (let index = 0; index < processCount; index += 1) {
|
||||||
}
|
}
|
||||||
|
|
||||||
cluster.on('message', (worker, message: WorkerMessage) => {
|
cluster.on('message', (worker, message: WorkerMessage) => {
|
||||||
for (const [pid, worker] of activeWorkers.entries()) {
|
for (const [pid, activeWorker] of activeWorkers.entries()) {
|
||||||
if (worker === undefined || pid === message.pid) {
|
if (activeWorker === undefined || pid === message.pid) {
|
||||||
continue
|
continue
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { calculateFeeAmount, calculateTaxAmount } from '../functions.fee.js';
|
import { calculateFeeAmount, calculateTaxAmount } from '../helpers/functions.fee.js';
|
||||||
import { getFee } from './getFee.js';
|
import { getFee } from './getFee.js';
|
||||||
import { getLotOccupancy } from './getLotOccupancy.js';
|
import { getLotOccupancy } from './getLotOccupancy.js';
|
||||||
import { acquireConnection } from './pool.js';
|
import { acquireConnection } from './pool.js';
|
||||||
|
|
@ -1,5 +1,5 @@
|
||||||
import type { LotOccupancy } from '../../types/recordTypes.js'
|
import type { LotOccupancy } from '../types/recordTypes.js'
|
||||||
import { calculateFeeAmount, calculateTaxAmount } from '../functions.fee.js'
|
import { calculateFeeAmount, calculateTaxAmount } from '../helpers/functions.fee.js'
|
||||||
|
|
||||||
import { getFee } from './getFee.js'
|
import { getFee } from './getFee.js'
|
||||||
import { getLotOccupancy } from './getLotOccupancy.js'
|
import { getLotOccupancy } from './getLotOccupancy.js'
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js';
|
import { clearCacheByTableName } from '../helpers/functions.cache.js';
|
||||||
import { acquireConnection } from './pool.js';
|
import { acquireConnection } from './pool.js';
|
||||||
export async function addLotOccupantType(lotOccupantTypeForm, user) {
|
export async function addLotOccupantType(lotOccupantTypeForm, user) {
|
||||||
const database = await acquireConnection();
|
const database = await acquireConnection();
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js'
|
import { clearCacheByTableName } from '../helpers/functions.cache.js'
|
||||||
|
|
||||||
import { acquireConnection } from './pool.js'
|
import { acquireConnection } from './pool.js'
|
||||||
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js';
|
import { clearCacheByTableName } from '../helpers/functions.cache.js';
|
||||||
import { acquireConnection } from './pool.js';
|
import { acquireConnection } from './pool.js';
|
||||||
export async function addLotTypeField(lotTypeFieldForm, user) {
|
export async function addLotTypeField(lotTypeFieldForm, user) {
|
||||||
const database = await acquireConnection();
|
const database = await acquireConnection();
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js'
|
import { clearCacheByTableName } from '../helpers/functions.cache.js'
|
||||||
|
|
||||||
import { acquireConnection } from './pool.js'
|
import { acquireConnection } from './pool.js'
|
||||||
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js';
|
import { clearCacheByTableName } from '../helpers/functions.cache.js';
|
||||||
import { acquireConnection } from './pool.js';
|
import { acquireConnection } from './pool.js';
|
||||||
export async function addOccupancyTypeField(occupancyTypeFieldForm, user) {
|
export async function addOccupancyTypeField(occupancyTypeFieldForm, user) {
|
||||||
const database = await acquireConnection();
|
const database = await acquireConnection();
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js'
|
import { clearCacheByTableName } from '../helpers/functions.cache.js'
|
||||||
|
|
||||||
import { acquireConnection } from './pool.js'
|
import { acquireConnection } from './pool.js'
|
||||||
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js';
|
import { clearCacheByTableName } from '../helpers/functions.cache.js';
|
||||||
import { acquireConnection } from './pool.js';
|
import { acquireConnection } from './pool.js';
|
||||||
export async function addOccupancyTypePrint(occupancyTypePrintForm, user) {
|
export async function addOccupancyTypePrint(occupancyTypePrintForm, user) {
|
||||||
const database = await acquireConnection();
|
const database = await acquireConnection();
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js'
|
import { clearCacheByTableName } from '../helpers/functions.cache.js'
|
||||||
|
|
||||||
import { acquireConnection } from './pool.js'
|
import { acquireConnection } from './pool.js'
|
||||||
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js';
|
import { clearCacheByTableName } from '../helpers/functions.cache.js';
|
||||||
import { acquireConnection } from './pool.js';
|
import { acquireConnection } from './pool.js';
|
||||||
const recordNameColumns = new Map();
|
const recordNameColumns = new Map();
|
||||||
recordNameColumns.set('FeeCategories', 'feeCategory');
|
recordNameColumns.set('FeeCategories', 'feeCategory');
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js'
|
import { clearCacheByTableName } from '../helpers/functions.cache.js'
|
||||||
|
|
||||||
import { acquireConnection } from './pool.js'
|
import { acquireConnection } from './pool.js'
|
||||||
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import * as configFunctions from '../functions.config.js';
|
import * as configFunctions from '../helpers/functions.config.js';
|
||||||
import { acquireConnection } from './pool.js';
|
import { acquireConnection } from './pool.js';
|
||||||
export async function cleanupDatabase(user) {
|
export async function cleanupDatabase(user) {
|
||||||
const database = await acquireConnection();
|
const database = await acquireConnection();
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import * as configFunctions from '../functions.config.js'
|
import * as configFunctions from '../helpers/functions.config.js'
|
||||||
|
|
||||||
import { acquireConnection } from './pool.js'
|
import { acquireConnection } from './pool.js'
|
||||||
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js';
|
import { clearCacheByTableName } from '../helpers/functions.cache.js';
|
||||||
import { acquireConnection } from './pool.js';
|
import { acquireConnection } from './pool.js';
|
||||||
export async function deleteOccupancyTypePrint(occupancyTypeId, printEJS, user) {
|
export async function deleteOccupancyTypePrint(occupancyTypeId, printEJS, user) {
|
||||||
const database = await acquireConnection();
|
const database = await acquireConnection();
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js'
|
import { clearCacheByTableName } from '../helpers/functions.cache.js'
|
||||||
|
|
||||||
import { acquireConnection } from './pool.js'
|
import { acquireConnection } from './pool.js'
|
||||||
|
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js';
|
import { clearCacheByTableName } from '../helpers/functions.cache.js';
|
||||||
import { acquireConnection } from './pool.js';
|
import { acquireConnection } from './pool.js';
|
||||||
const recordIdColumns = new Map();
|
const recordIdColumns = new Map();
|
||||||
recordIdColumns.set('FeeCategories', 'feeCategoryId');
|
recordIdColumns.set('FeeCategories', 'feeCategoryId');
|
||||||
|
|
@ -1,4 +1,4 @@
|
||||||
import { clearCacheByTableName } from '../functions.cache.js'
|
import { clearCacheByTableName } from '../helpers/functions.cache.js'
|
||||||
|
|
||||||
import { acquireConnection } from './pool.js'
|
import { acquireConnection } from './pool.js'
|
||||||
|
|
||||||
Some files were not shown because too many files have changed in this diff Show More
Loading…
Reference in New Issue