"Fossies" - the Fresh Open Source Software Archive  

Source code changes of the file "api/utils/requestProcessor.js" between
countly-server-20.04.1.4.tar.gz and countly-server-20.04.1.5.tar.gz

About: countly-server is a mobile & web analytics, push notifications and crash reporting platform. This is the server part that collects and analyzes data while individual client SDKs (mobile, web or desktop) send the data. Community Edition (commercial Enterprise Edition also available).

requestProcessor.js  (countly-server-20.04.1.4):requestProcessor.js  (countly-server-20.04.1.5)
skipping to change at line 209 skipping to change at line 209
} }
catch (SyntaxError) { catch (SyntaxError) {
console.log('Parse bulk JSON failed', requests, params.r eq.url, params.req.body); console.log('Parse bulk JSON failed', requests, params.r eq.url, params.req.body);
requests = null; requests = null;
} }
} }
if (!requests) { if (!requests) {
common.returnMessage(params, 400, 'Missing parameter "reques ts"'); common.returnMessage(params, 400, 'Missing parameter "reques ts"');
return false; return false;
} }
if (!Array.isArray(requests)) {
console.log("Passed invalid param for request. Expected Arra
y, got " + typeof requests);
common.returnMessage(params, 400, 'Invalid parameter "reques
ts"');
return false;
}
if (!plugins.getConfig("api", params.app && params.app.plugins, true).safe && !params.res.finished) { if (!plugins.getConfig("api", params.app && params.app.plugins, true).safe && !params.res.finished) {
common.returnMessage(params, 200, 'Success'); common.returnMessage(params, 200, 'Success');
} }
common.blockResponses(params); common.blockResponses(params);
processBulkRequest(0, requests, params); processBulkRequest(0, requests, params);
break; break;
} }
case '/i/users': { case '/i/users': {
if (params.qstring.args) { if (params.qstring.args) {
skipping to change at line 2477 skipping to change at line 2482
if ((params.populator || params.qstring.populator) && app.locked) { if ((params.populator || params.qstring.populator) && app.locked) {
log.d("App is locked"); log.d("App is locked");
processThisUser = false; processThisUser = false;
} }
if (!processThisUser) { if (!processThisUser) {
parallelTasks.push(fetchAppUser(params)); parallelTasks.push(fetchAppUser(params));
} }
else { else {
parallelTasks.push(fetchAppUser(params).then(() => { parallelTasks.push(fetchAppUser(params).then(() => {
processUser(params, validateAppForFetchAPI, done, try_times); return processUser(params, validateAppForFetchAPI, done, try_tim es);
})); }));
} }
Promise.all( Promise.all(
parallelTasks parallelTasks
) )
.catch((error) => { .catch((error) => {
console.error(error); console.error(error);
}) })
.finally(() => { .finally(() => {
 End of changes. 2 change blocks. 
1 lines changed or deleted 8 lines changed or added

Home  |  About  |  Features  |  All  |  Newest  |  Dox  |  Diffs  |  RSS Feeds  |  Screenshots  |  Comments  |  Imprint  |  Privacy  |  HTTP(S)