mirror of
https://gitlab.com/MrFry/mrfrys-node-server
synced 2025-04-01 20:24:18 +02:00
Added dataLock
This commit is contained in:
parent
803cb677ba
commit
68b0dd30aa
1 changed files with 11 additions and 0 deletions
|
@ -25,6 +25,7 @@ module.exports = {
|
||||||
|
|
||||||
const dataFile = './publicDirs/qminingPublic/data.json'
|
const dataFile = './publicDirs/qminingPublic/data.json'
|
||||||
const recDataFile = './stats/recdata'
|
const recDataFile = './stats/recdata'
|
||||||
|
const dataLockFile = './data/lockData'
|
||||||
|
|
||||||
const logger = require('../utils/logger.js')
|
const logger = require('../utils/logger.js')
|
||||||
const { searchData, createQuestion } = require('../utils/classes.js')
|
const { searchData, createQuestion } = require('../utils/classes.js')
|
||||||
|
@ -41,6 +42,7 @@ var currWrites = 0
|
||||||
function ProcessIncomingRequest(recievedData, qdb, dryRun, user) {
|
function ProcessIncomingRequest(recievedData, qdb, dryRun, user) {
|
||||||
return new Promise((resolve, reject) => {
|
return new Promise((resolve, reject) => {
|
||||||
logger.DebugLog('Processing incoming request', 'actions', 1)
|
logger.DebugLog('Processing incoming request', 'actions', 1)
|
||||||
|
|
||||||
if (recievedData === undefined) {
|
if (recievedData === undefined) {
|
||||||
logger.Log('\tRecieved data is undefined!', logger.GetColor('redbg'))
|
logger.Log('\tRecieved data is undefined!', logger.GetColor('redbg'))
|
||||||
reject(new Error('Recieved data is undefined!'))
|
reject(new Error('Recieved data is undefined!'))
|
||||||
|
@ -63,6 +65,15 @@ function ProcessIncomingRequest(recievedData, qdb, dryRun, user) {
|
||||||
logger.log('Error writing recieved data.')
|
logger.log('Error writing recieved data.')
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if (utils.FileExists(dataLockFile)) {
|
||||||
|
logger.Log(
|
||||||
|
'Data lock file exists, skipping recieved data processing',
|
||||||
|
logger.GetColor('red')
|
||||||
|
)
|
||||||
|
resolve(-1)
|
||||||
|
return
|
||||||
|
}
|
||||||
|
|
||||||
try {
|
try {
|
||||||
// recievedData: { version: "", id: "", subj: "" quiz: {} }
|
// recievedData: { version: "", id: "", subj: "" quiz: {} }
|
||||||
let data = recievedData
|
let data = recievedData
|
||||||
|
|
Loading…
Add table
Add a link
Reference in a new issue