kami-parse-server/src/triggers.js

// triggers.js
var Parse = require('parse/node').Parse,
    cache = require('./cache');

var Types = {
  beforeSave: 'beforeSave',
  afterSave: 'afterSave',
  beforeDelete: 'beforeDelete',
  afterDelete: 'afterDelete'
};

var BaseStore = function() {
  this.Functions = {}
  this.Validators = {}
  this.Triggers = Object.keys(Types).reduce(function(base, key){
    base[key] = {};
    return base;
  }, {});
}

var _triggerStore = {};

function addFunction(functionName, handler, validationHandler, applicationId) {
  applicationId = applicationId || Parse.applicationId;
  _triggerStore[applicationId] =  _triggerStore[applicationId] || new BaseStore();
  _triggerStore[applicationId].Functions[functionName] = handler;
  _triggerStore[applicationId].Validators[functionName] = validationHandler;
}

function addTrigger(type, className, handler, applicationId) {
  applicationId = applicationId || Parse.applicationId;
  _triggerStore[applicationId] =  _triggerStore[applicationId] || new BaseStore();
  _triggerStore[applicationId].Triggers[type][className] = handler;
}

function removeFunction(functionName, applicationId) {
   applicationId = applicationId || Parse.applicationId;
   delete _triggerStore[applicationId].Functions[functionName]
}

function removeTrigger(type, className, applicationId) {
   applicationId = applicationId || Parse.applicationId;
   delete _triggerStore[applicationId].Triggers[type][className]
}

function _unregister(a,b,c,d) {
  if (d) {
    removeTrigger(c,d,a);
    delete _triggerStore[a][b][c][d];
  } else {
    delete _triggerStore[a][b][c];
  }
}


var getTrigger = function(className, triggerType, applicationId) {
  if (!applicationId) {
    throw "Missing ApplicationID";
  }
  var manager = _triggerStore[applicationId]
  if (manager 
    && manager.Triggers
    && manager.Triggers[triggerType]
    && manager.Triggers[triggerType][className]) {
    return manager.Triggers[triggerType][className];
  }
  return undefined;
};

function triggerExists(className: string, type: string): boolean {
  return (getTrigger(className, type) != undefined);
}

var getFunction = function(functionName, applicationId) {
  var manager = _triggerStore[applicationId];
  if (manager && manager.Functions) {
    return manager.Functions[functionName];
  };
  return undefined;
}

var getValidator = function(functionName, applicationId) {
  var manager = _triggerStore[applicationId];
  if (manager && manager.Validators) {
    return manager.Validators[functionName];
  };
  return undefined;
}

var getRequestObject = function(triggerType, auth, parseObject, originalParseObject) {
  var request = {
    triggerName: triggerType,
    object: parseObject,
    master: false
  };
  if (originalParseObject) {
    request.original = originalParseObject;
  }
  if (!auth) {
    return request;
  }
  if (auth.isMaster) {
    request['master'] = true;
  }
  if (auth.user) {
    request['user'] = auth.user;
  }
  // TODO: Add installation to Auth?
  if (auth.installationId) {
    request['installationId'] = auth.installationId;
  }
  return request;
};

// Creates the response object, and uses the request object to pass data
// The API will call this with REST API formatted objects, this will
// transform them to Parse.Object instances expected by Cloud Code.
// Any changes made to the object in a beforeSave will be included.
var getResponseObject = function(request, resolve, reject) {
  return {
    success: function(response) {
      // Use the JSON response
      if (response && request.triggerName === Types.beforeSave) {
        return resolve(response);
      }
      response = {};
      if (request.triggerName === Types.beforeSave) {
        response['object'] = request.object._getSaveJSON();
      }
      return resolve(response);
    },
    error: function(error) {
      var scriptError = new Parse.Error(Parse.Error.SCRIPT_FAILED, error);
      return reject(scriptError);
    }
  }
};

// To be used as part of the promise chain when saving/deleting an object
// Will resolve successfully if no trigger is configured
// Resolves to an object, empty or containing an object key. A beforeSave
// trigger will set the object key to the rest format object to save.
// originalParseObject is optional, we only need that for befote/afterSave functions
var maybeRunTrigger = function(triggerType, auth, parseObject, originalParseObject, applicationId) {
  if (!parseObject) {
    return Promise.resolve({});
  }
  return new Promise(function (resolve, reject) {
    var trigger = getTrigger(parseObject.className, triggerType, applicationId);
    if (!trigger) return resolve();
    var request = getRequestObject(triggerType, auth, parseObject, originalParseObject);
    var response = getResponseObject(request, resolve, reject);
    // Force the current Parse app before the trigger
    Parse.applicationId = applicationId;
    Parse.javascriptKey = cache.apps[applicationId].javascriptKey || '';
    Parse.masterKey = cache.apps[applicationId].masterKey;
    trigger(request, response);
  });
};

// Converts a REST-format object to a Parse.Object
// data is either className or an object
function inflate(data, restObject) {
  var copy = typeof data == 'object' ? data : {className: data};
  for (var key in restObject) {
    copy[key] = restObject[key];
  }
  return Parse.Object.fromJSON(copy);
}

<<<<<<< 5fae41183ed476976ff29a4c247aa78b00b83a9e
module.exports = {
  getTrigger: getTrigger,
  getRequestObject: getRequestObject,
  inflate: inflate,
  maybeRunTrigger: maybeRunTrigger,
  triggerExists: triggerExists,
  Types: Types
};
=======
var TriggerManager = {};

TriggerManager.getTrigger = getTrigger;
TriggerManager.getRequestObject = getRequestObject;
TriggerManager.inflate = inflate;
TriggerManager.maybeRunTrigger = maybeRunTrigger;
TriggerManager.Types = Types;
TriggerManager.addFunction = addFunction;
TriggerManager.getFunction = getFunction;
TriggerManager.removeTrigger = removeTrigger;
TriggerManager.removeFunction = removeFunction;
TriggerManager.getValidator = getValidator;
TriggerManager.addTrigger = addTrigger;
TriggerManager._unregister = _unregister;

module.exports = TriggerManager;
>>>>>>> Adds Hooks API