joe/kami-parse-server
Public Access
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Factor out checking for triggers/liveQuery in rest.js (#3539)

Browse Source
This commit is contained in:
Tyler Brock
2017-02-20 12:25:25 -08:00
committed by GitHub
parent 411daf4d41
commit 67260b5fe0
1 changed files with 16 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
src/rest.js
View File

@@ -14,6 +14,16 @@ var RestQuery = require('./RestQuery');
var RestWrite = require('./RestWrite'); var RestWrite = require('./RestWrite');
var triggers = require('./triggers'); var triggers = require('./triggers');
function checkTriggers(className, config, types) {
return types.some((triggerType) => {
return triggers.getTrigger(className, triggers.Types[triggerType], config.applicationId);
});
}
function checkLiveQuery(className, config) {
return config.liveQueryController && config.liveQueryController.hasLiveQuery(className)
}
// Returns a promise for an object with optional keys 'results' and 'count'. // Returns a promise for an object with optional keys 'results' and 'count'.
function find(config, auth, className, restWhere, restOptions, clientSDK) { function find(config, auth, className, restWhere, restOptions, clientSDK) {
enforceRoleSecurity('find', className, auth); enforceRoleSecurity('find', className, auth);
@@ -49,10 +59,9 @@ function del(config, auth, className, objectId) {
var inflatedObject; var inflatedObject;
return Promise.resolve().then(() => { return Promise.resolve().then(() => {
if (triggers.getTrigger(className, triggers.Types.beforeDelete, config.applicationId) || const hasTriggers = checkTriggers(className, config, ['beforeDelete', 'afterDelete']);
triggers.getTrigger(className, triggers.Types.afterDelete, config.applicationId) || const hasLiveQuery = checkLiveQuery(className, config);
(config.liveQueryController && config.liveQueryController.hasLiveQuery(className)) || if (hasTriggers || hasLiveQuery || className == '_Session') {
className == '_Session') {
return find(config, Auth.master(config), className, {objectId: objectId}) return find(config, Auth.master(config), className, {objectId: objectId})
.then((response) => { .then((response) => {
if (response && response.results && response.results.length) { if (response && response.results && response.results.length) {
@@ -108,9 +117,9 @@ function update(config, auth, className, objectId, restObject, clientSDK) {
enforceRoleSecurity('update', className, auth); enforceRoleSecurity('update', className, auth);
return Promise.resolve().then(() => { return Promise.resolve().then(() => {
if (triggers.getTrigger(className, triggers.Types.beforeSave, config.applicationId) || const hasTriggers = checkTriggers(className, config, ['beforeSave', 'afterSave']);
triggers.getTrigger(className, triggers.Types.afterSave, config.applicationId) || const hasLiveQuery = checkLiveQuery(className, config);
(config.liveQueryController && config.liveQueryController.hasLiveQuery(className))) { if (hasTriggers || hasLiveQuery) {
return find(config, Auth.master(config), className, {objectId: objectId}); return find(config, Auth.master(config), className, {objectId: objectId});
} }
return Promise.resolve({}); return Promise.resolve({});