Make parse-server cloud code logging closer parse.com legacy (#2550)

* Make parse-server cloud code logging much to parse.com legacy. (fixes #2501)

1. More closely mimic the wording.  Include the user id.

2. Truncate input and result at 1k char.

3. Use more sensible metadata that would makes sense to index.  The guideline I used was: if it makes sense to filter on, put it in metadata.  If it makes sense to "free text" search on, then put it in the message.

  - file and console output, logging an object does not do what on might expect.  For example, logging a function's "params":

  ```
  expected:

    info: Ran cloud function aFunction for user qWHLVEsbEe with:
      Input: {"foo":"bar","bar":"baz"}
      Result: "it worked!" functionName=aFunction, params= { foo: "bar", "bar": baz }, user=qWHLVEsbEe

  what you actually get:

    info: Ran cloud function aFunction for user qWHLVEsbEe with:
      Input: {"foo":"bar","bar":"baz"}
      Result: "it worked!" functionName=aFunction, foo=bar, bar=baz, user=qWHLVEsbEe
  ```
  - logging highly variable metadata is pretty useless for indexing when logs are sent to a logging repository like elastic search.  In that use case, you want to index stuff you expect to filter on like user, hook type.

  - finally, putting the same input and result data in both the metadata and the message makes each message much larger with no additional value (that I know of anyway :).

4. Change some of the naming of functions in trigger.js to make future work easier.  I was confused about why there were three logging functions in trigger and it took me awhile to get that before hooks and after hooks are logged differently.  I just changed the names to make it obvious at first glance.

5. Add some try/catches to help any future futzers  see syntax errors, etc instead of just hanging.

Some log examples from unit test output:

```
info: Ran cloud function loggerTest for user YUD2os1i5B with:
  Input: {}
  Result: {} functionName=loggerTest, user=YUD2os1i5B

info: beforeSave triggered for MyObject for user nssehQ3wtz:
  Input: {}
  Result: {} className=MyObject, triggerType=beforeSave, user=nssehQ3wtz

info: afterSave triggered for MyObject for user XdznQgTD0p:
  Input: {"createdAt":"2016-08-19T01:11:31.249Z","updatedAt":"2016-08-19T01:11:31.249Z","objectId":"POoOOLL89U"} className=MyObject, triggerType=afterSave, user=XdznQgTD0p

error: beforeSave failed for MyObject for user 7JHqCZgnhf:
  Input: {}
  Error: {"code":141,"message":"uh oh!"} className=MyObject, triggerType=beforeSave, code=141, message=uh oh!, user=7JHqCZgnhf

info: Ran cloud function aFunction for user YR3nOoT3r9 with:
  Input: {"foo":"bar"}
  Result: "it worked!" functionName=aFunction, user=YR3nOoT3r9

error: Failed running cloud function aFunction for user Xm6NpOyuMC with:
  Input: {"foo":"bar"}
  Error: {"code":141,"message":"it failed!"} functionName=aFunction, code=141, message=it failed!, user=Xm6NpOyuMC

info: Ran cloud function aFunction for user CK1lvkmaLg with:
  Input: {"longString":"Lorem ipsum dolor sit amet, consectetur adipiscing elit. Vivamus lobortis semper diam, ac euismod diam pharetra sed. Etiam eget efficitur neque. Proin nec diam mi. Sed ut purus dolor. Nulla nulla nibh, ornare vitae ornare et, scelerisque rutrum eros. Mauris venenatis tincidunt turpis a mollis. Donec gravida eget enim in luctus.\n\nSed porttitor commodo orci, ut pretium eros convallis eget. Curabitur pretium velit in odio dictum luctus. Vivamus ac tristique arcu, a semper tellus. Morbi euismod purus dapibus vestibulum sagittis. Nunc dapibus vehicula leo at scelerisque. Donec porta mauris quis nulla imperdiet consectetur. Curabitur sagittis eleifend arcu eget elementum. Aenean interdum tincidunt ornare. Pellentesque sit amet interdum tortor. Pellentesque blandit nisl eget euismod consequat. Etiam feugiat felis sit amet porta pulvinar. Lorem ipsum dolor sit amet, consectetur adipiscing elit.\n\nNulla faucibus sem ipsum, at rhoncus diam pulvinar at. Vivamus consectetur, diam... (truncated)
  Result: {"longString":"Lorem ipsum dolor sit amet, consectetur adipiscing elit. Vivamus lobortis semper diam, ac euismod diam pharetra sed. Etiam eget efficitur neque. Proin nec diam mi. Sed ut purus dolor. Nulla nulla nibh, ornare vitae ornare et, scelerisque rutrum eros. Mauris venenatis tincidunt turpis a mollis. Donec gravida eget enim in luctus.\n\nSed porttitor commodo orci, ut pretium eros convallis eget. Curabitur pretium velit in odio dictum luctus. Vivamus ac tristique arcu, a semper tellus. Morbi euismod purus dapibus vestibulum sagittis. Nunc dapibus vehicula leo at scelerisque. Donec porta mauris quis nulla imperdiet consectetur. Curabitur sagittis eleifend arcu eget elementum. Aenean interdum tincidunt ornare. Pellentesque sit amet interdum tortor. Pellentesque blandit nisl eget euismod consequat. Etiam feugiat felis sit amet porta pulvinar. Lorem ipsum dolor sit amet, consectetur adipiscing elit.\n\nNulla faucibus sem ipsum, at rhoncus diam pulvinar at. Vivamus consectetur, diam... (truncated) functionName=aFunction, user=CK1lvkmaLg
```

* Implement PR comments:
- add back params to metadata and add back to the test
- use screaming snake case for conts

* fix typo
This commit is contained in:
Arthur Cinader
2016-08-19 13:39:51 -07:00
committed by Florent Vilmart
parent 277df54dc8
commit 5f67caefde
6 changed files with 247 additions and 50 deletions

View File

@@ -59,6 +59,21 @@ describe('Cloud Code', () => {
}) })
}); });
it('returns an error', (done) => {
Parse.Cloud.define('cloudCodeWithError', (req, res) => {
foo.bar();
res.success('I better throw an error.');
});
Parse.Cloud.run('cloudCodeWithError')
.then(
a => done.fail('should not succeed'),
e => {
expect(e).toEqual(new Parse.Error(1, undefined));
done();
});
});
it('beforeSave rejection with custom error code', function(done) { it('beforeSave rejection with custom error code', function(done) {
Parse.Cloud.beforeSave('BeforeSaveFailWithErrorCode', function (req, res) { Parse.Cloud.beforeSave('BeforeSaveFailWithErrorCode', function (req, res) {
res.error(999, 'Nope'); res.error(999, 'Nope');

View File

@@ -2,27 +2,48 @@
var LoggerController = require('../src/Controllers/LoggerController').LoggerController; var LoggerController = require('../src/Controllers/LoggerController').LoggerController;
var WinstonLoggerAdapter = require('../src/Adapters/Logger/WinstonLoggerAdapter').WinstonLoggerAdapter; var WinstonLoggerAdapter = require('../src/Adapters/Logger/WinstonLoggerAdapter').WinstonLoggerAdapter;
const fs = require('fs');
const loremFile = __dirname + '/support/lorem.txt';
describe("Cloud Code Logger", () => { describe("Cloud Code Logger", () => {
it("should expose log to functions", (done) => { let user;
beforeEach(done => {
Parse.User.enableUnsafeCurrentUser();
return reconfigureServer({
// useful to flip to false for fine tuning :).
silent: true,
}).then(() => {
return Parse.User.signUp('tester', 'abc')
.then(loggedInUser => user = loggedInUser)
.then(() => Parse.User.logIn(user.get('username'), 'abc'))
.then(() => done())
});
});
// Note that helpers takes care of logout.
// see helpers.js:afterEach
it("should expose log to functions", done => {
var logController = new LoggerController(new WinstonLoggerAdapter()); var logController = new LoggerController(new WinstonLoggerAdapter());
Parse.Cloud.define("loggerTest", (req, res) => { Parse.Cloud.define("loggerTest", (req, res) => {
req.log.info('logTest', 'info log', {info: 'some log' }); req.log.info('logTest', 'info log', { info: 'some log' });
req.log.error('logTest','error log', {error: 'there was an error'}); req.log.error('logTest', 'error log', { error: 'there was an error' });
res.success({}); res.success({});
}); });
Parse.Cloud.run('loggerTest').then(() => { Parse.Cloud.run('loggerTest').then(() => {
return logController.getLogs({from: Date.now() - 500, size: 1000}); return logController.getLogs({ from: Date.now() - 500, size: 1000 });
}).then((res) => { }).then((res) => {
expect(res.length).not.toBe(0); expect(res.length).not.toBe(0);
let lastLogs = res.slice(0, 3); let lastLogs = res.slice(0, 3);
let cloudFunctionMessage = lastLogs[0]; let cloudFunctionMessage = lastLogs[0];
let errorMessage = lastLogs[1]; let errorMessage = lastLogs[1];
let infoMessage = lastLogs[2]; let infoMessage = lastLogs[2];
expect(cloudFunctionMessage.level).toBe('info'); expect(cloudFunctionMessage.level).toBe('info');
expect(cloudFunctionMessage.params).toEqual({}); expect(cloudFunctionMessage.params).toEqual({});
expect(cloudFunctionMessage.message).toEqual('Ran cloud function loggerTest with:\nInput: {}\nResult: {}'); expect(cloudFunctionMessage.message).toMatch(/Ran cloud function loggerTest for user [^ ]* with:\n Input: {}\n Result: {}/);
expect(cloudFunctionMessage.functionName).toEqual('loggerTest'); expect(cloudFunctionMessage.functionName).toEqual('loggerTest');
expect(errorMessage.level).toBe('error'); expect(errorMessage.level).toBe('error');
expect(errorMessage.error).toBe('there was an error'); expect(errorMessage.error).toBe('there was an error');
@@ -38,23 +59,24 @@ describe("Cloud Code Logger", () => {
var logController = new LoggerController(new WinstonLoggerAdapter()); var logController = new LoggerController(new WinstonLoggerAdapter());
Parse.Cloud.beforeSave("MyObject", (req, res) => { Parse.Cloud.beforeSave("MyObject", (req, res) => {
req.log.info('beforeSave MyObject', 'info log', {info: 'some log' }); req.log.info('beforeSave MyObject', 'info log', { info: 'some log' });
req.log.error('beforeSave MyObject','error log', {error: 'there was an error'}); req.log.error('beforeSave MyObject', 'error log', { error: 'there was an error' });
res.success({}); res.success({});
}); });
let obj = new Parse.Object('MyObject'); let obj = new Parse.Object('MyObject');
obj.save().then(() => { obj.save().then(() => {
return logController.getLogs({from: Date.now() - 500, size: 1000}) return logController.getLogs({ from: Date.now() - 500, size: 1000 })
}).then((res) => { }).then((res) => {
expect(res.length).not.toBe(0); expect(res.length).not.toBe(0);
let lastLogs = res.slice(0, 3); let lastLogs = res.slice(0, 3);
let cloudTriggerMessage = lastLogs[0]; let cloudTriggerMessage = lastLogs[0];
let errorMessage = lastLogs[1]; let errorMessage = lastLogs[1];
let infoMessage = lastLogs[2]; let infoMessage = lastLogs[2];
expect(cloudTriggerMessage.level).toBe('info'); expect(cloudTriggerMessage.level).toBe('info');
expect(cloudTriggerMessage.input).toEqual({}); expect(cloudTriggerMessage.triggerType).toEqual('beforeSave');
expect(cloudTriggerMessage.message).toEqual('beforeSave triggered for MyObject\nInput: {}\nResult: {}'); expect(cloudTriggerMessage.message).toMatch(/beforeSave triggered for MyObject for user [^ ]*\n Input: {}\n Result: {}/);
expect(cloudTriggerMessage.user).toBe(user.id);
expect(errorMessage.level).toBe('error'); expect(errorMessage.level).toBe('error');
expect(errorMessage.error).toBe('there was an error'); expect(errorMessage.error).toBe('there was an error');
expect(errorMessage.message).toBe('beforeSave MyObject error log'); expect(errorMessage.message).toBe('beforeSave MyObject error log');
@@ -64,4 +86,126 @@ describe("Cloud Code Logger", () => {
done(); done();
}); });
}); });
it('should truncate really long lines when asked to', () => {
const logController = new LoggerController(new WinstonLoggerAdapter());
const longString = fs.readFileSync(loremFile, 'utf8');
const truncatedString = logController.truncateLogMessage(longString);
expect(truncatedString.length).toBe(1015); // truncate length + the string '... (truncated)'
});
it('should truncate input and result of long lines', done => {
const logController = new LoggerController(new WinstonLoggerAdapter());
const longString = fs.readFileSync(loremFile, 'utf8');
Parse.Cloud.define('aFunction', (req, res) => {
res.success(req.params);
});
Parse.Cloud.run('aFunction', { longString })
.then(() => logController.getLogs({ from: Date.now() - 500, size: 1000 }))
.then(logs => {
const log = logs[0];
expect(log.level).toEqual('info');
expect(log.message).toMatch(
/Ran cloud function aFunction for user [^ ]* with:\n Input: {.*?\(truncated\)$/m);
done();
})
.then(null, e => done.fail(e));
});
it('should log an afterSave', done => {
const logController = new LoggerController(new WinstonLoggerAdapter());
Parse.Cloud.afterSave("MyObject", (req) => { });
new Parse.Object('MyObject')
.save()
.then(() => logController.getLogs({ from: Date.now() - 500, size: 1000 }))
.then((logs) => {
const log = logs[0];
expect(log.triggerType).toEqual('afterSave');
done();
})
// catch errors - not that the error is actually useful :(
.then(null, e => done.fail(e));
});
it('should log a denied beforeSave', done => {
const logController = new LoggerController(new WinstonLoggerAdapter());
Parse.Cloud.beforeSave("MyObject", (req, res) => {
res.error('uh oh!');
});
new Parse.Object('MyObject')
.save()
.then(
() => done.fail('this is not supposed to succeed'),
e => logController.getLogs({ from: Date.now() - 500, size: 1000 })
)
.then(logs => {
const log = logs[1]; // 0 is the 'uh oh!' from rejection...
expect(log.level).toEqual('error');
expect(log.error).toEqual({ code: 141, message: 'uh oh!' });
done()
});
});
it('should log cloud function success', done => {
const logController = new LoggerController(new WinstonLoggerAdapter());
Parse.Cloud.define('aFunction', (req, res) => {
res.success('it worked!');
});
Parse.Cloud.run('aFunction', { foo: 'bar' })
.then(() => logController.getLogs({ from: Date.now() - 500, size: 1000 }))
.then(logs => {
const log = logs[0];
expect(log.level).toEqual('info');
expect(log.message).toMatch(
/Ran cloud function aFunction for user [^ ]* with:\n Input: {"foo":"bar"}\n Result: "it worked!/);
done();
});
});
it('should log cloud function failure', done => {
const logController = new LoggerController(new WinstonLoggerAdapter());
Parse.Cloud.define('aFunction', (req, res) => {
res.error('it failed!');
});
Parse.Cloud.run('aFunction', { foo: 'bar' })
.then(null, () => logController.getLogs({ from: Date.now() - 500, size: 1000 }))
.then(logs => {
const log = logs[1];
expect(log.level).toEqual('error');
expect(log.message).toMatch(
/Failed running cloud function aFunction for user [^ ]* with:\n Input: {"foo":"bar"}\n Error: {"code":141,"message":"it failed!"}/);
done();
});
});
xit('should log a changed beforeSave indicating a change', done => {
const logController = new LoggerController(new WinstonLoggerAdapter());
Parse.Cloud.beforeSave("MyObject", (req, res) => {
const myObj = req.object;
myObj.set('aChange', true);
res.success(myObj);
});
new Parse.Object('MyObject')
.save()
.then(() => logController.getLogs({ from: Date.now() - 500, size: 1000 }))
.then(logs => {
// expect the log to indicate that it has changed
/*
Here's what it looks like on parse.com...
Input: {"original":{"clientVersion":"1","createdAt":"2016-06-02T05:29:08.694Z","image":{"__type":"File","name":"tfss-xxxxxxxx.png","url":"http://files.parsetfss.com/xxxxxxxx.png"},"lastScanDate":{"__type":"Date","iso":"2016-06-02T05:28:58.135Z"},"localIdentifier":"XXXXX","objectId":"OFHMX7ZUcI","status":... (truncated)
Result: Update changed to {"object":{"__type":"Pointer","className":"Emoticode","objectId":"ksrq7z3Ehc"},"imageThumb":{"__type":"File","name":"tfss-xxxxxxx.png","url":"http://files.parsetfss.com/xxxxx.png"},"status":"success"}
*/
done();
})
.then(null, e => done.fail(JSON.stringify(e)));
}).pend('needs more work.....');
}); });

5
spec/support/lorem.txt Normal file
View File

@@ -0,0 +1,5 @@
Lorem ipsum dolor sit amet, consectetur adipiscing elit. Vivamus lobortis semper diam, ac euismod diam pharetra sed. Etiam eget efficitur neque. Proin nec diam mi. Sed ut purus dolor. Nulla nulla nibh, ornare vitae ornare et, scelerisque rutrum eros. Mauris venenatis tincidunt turpis a mollis. Donec gravida eget enim in luctus.
Sed porttitor commodo orci, ut pretium eros convallis eget. Curabitur pretium velit in odio dictum luctus. Vivamus ac tristique arcu, a semper tellus. Morbi euismod purus dapibus vestibulum sagittis. Nunc dapibus vehicula leo at scelerisque. Donec porta mauris quis nulla imperdiet consectetur. Curabitur sagittis eleifend arcu eget elementum. Aenean interdum tincidunt ornare. Pellentesque sit amet interdum tortor. Pellentesque blandit nisl eget euismod consequat. Etiam feugiat felis sit amet porta pulvinar. Lorem ipsum dolor sit amet, consectetur adipiscing elit.
Nulla faucibus sem ipsum, at rhoncus diam pulvinar at. Vivamus consectetur, diam at aliquet vestibulum, sem purus elementum nulla, eget tincidunt nullam.

View File

@@ -4,6 +4,8 @@ import AdaptableController from './AdaptableController';
import { LoggerAdapter } from '../Adapters/Logger/LoggerAdapter'; import { LoggerAdapter } from '../Adapters/Logger/LoggerAdapter';
const MILLISECONDS_IN_A_DAY = 24 * 60 * 60 * 1000; const MILLISECONDS_IN_A_DAY = 24 * 60 * 60 * 1000;
const LOG_STRING_TRUNCATE_LENGTH = 1000;
const truncationMarker = '... (truncated)';
export const LogLevel = { export const LogLevel = {
INFO: 'info', INFO: 'info',
@@ -16,7 +18,7 @@ export const LogOrder = {
} }
export class LoggerController extends AdaptableController { export class LoggerController extends AdaptableController {
log(level, args) { log(level, args) {
args = [].concat(level, [...args]); args = [].concat(level, [...args]);
this.adapter.log.apply(this.adapter, args); this.adapter.log.apply(this.adapter, args);
@@ -25,7 +27,7 @@ export class LoggerController extends AdaptableController {
info() { info() {
return this.log('info', arguments); return this.log('info', arguments);
} }
error() { error() {
return this.log('error', arguments); return this.log('error', arguments);
} }
@@ -59,6 +61,15 @@ export class LoggerController extends AdaptableController {
return null; return null;
} }
truncateLogMessage(string) {
if (string && string.length > LOG_STRING_TRUNCATE_LENGTH) {
const truncated = string.substring(0, LOG_STRING_TRUNCATE_LENGTH) + truncationMarker;
return truncated;
}
return string;
}
static parseOptions(options = {}) { static parseOptions(options = {}) {
let from = LoggerController.validDateTime(options.from) || let from = LoggerController.validDateTime(options.from) ||
new Date(Date.now() - 7 * MILLISECONDS_IN_A_DAY); new Date(Date.now() - 7 * MILLISECONDS_IN_A_DAY);

View File

@@ -78,20 +78,35 @@ export class FunctionsRouter extends PromiseRouter {
} }
return new Promise(function (resolve, reject) { return new Promise(function (resolve, reject) {
var response = FunctionsRouter.createResponseObject((result) => { const userString = (req.auth && req.auth.user) ? req.auth.user.id : undefined;
logger.info(`Ran cloud function ${req.params.functionName} with:\nInput: ${JSON.stringify(params)}\nResult: ${JSON.stringify(result.response.result)}`, { const cleanInput = logger.truncateLogMessage(JSON.stringify(params));
functionName: req.params.functionName, var response = FunctionsRouter.createResponseObject((result) => {
params, try {
result: result.response.result const cleanResult = logger.truncateLogMessage(JSON.stringify(result.response.result));
}); logger.info(`Ran cloud function ${req.params.functionName} for user ${userString} `
resolve(result); + `with:\n Input: ${cleanInput }\n Result: ${cleanResult }`, {
}, (error) => { functionName: req.params.functionName,
logger.error(`Failed running cloud function ${req.params.functionName} with:\nInput: ${JSON.stringify(params)}\Error: ${JSON.stringify(error)}`, { params,
functionName: req.params.functionName, user: userString,
params, });
error resolve(result);
}); } catch (e) {
reject(error); reject(e);
}
}, (error) => {
try {
logger.error(`Failed running cloud function ${req.params.functionName} for `
+ `user ${userString} with:\n Input: ${cleanInput}\n Error: `
+ JSON.stringify(error), {
functionName: req.params.functionName,
error,
params,
user: userString
});
reject(error);
} catch (e) {
reject(e);
}
}); });
// Force the keys before the function calls. // Force the keys before the function calls.
Parse.applicationId = req.config.applicationId; Parse.applicationId = req.config.applicationId;

View File

@@ -153,32 +153,36 @@ export function getResponseObject(request, resolve, reject) {
} }
}; };
function logTrigger(triggerType, className, input) { function userIdForLog(auth) {
if (triggerType.indexOf('after') != 0) { return (auth && auth.user) ? auth.user.id : undefined;
return; }
}
logger.info(`${triggerType} triggered for ${className}\nInput: ${JSON.stringify(input)}`, { function logTriggerAfterHook(triggerType, className, input, auth) {
const cleanInput = logger.truncateLogMessage(JSON.stringify(input));
logger.info(`${triggerType} triggered for ${className} for user ${userIdForLog(auth)}:\n Input: ${cleanInput}`, {
className, className,
triggerType, triggerType,
input user: userIdForLog(auth)
}); });
} }
function logTriggerSuccess(triggerType, className, input, result) { function logTriggerSuccessBeforeHook(triggerType, className, input, result, auth) {
logger.info(`${triggerType} triggered for ${className}\nInput: ${JSON.stringify(input)}\nResult: ${JSON.stringify(result)}`, { const cleanInput = logger.truncateLogMessage(JSON.stringify(input));
const cleanResult = logger.truncateLogMessage(JSON.stringify(result));
logger.info(`${triggerType} triggered for ${className} for user ${userIdForLog(auth)}:\n Input: ${cleanInput}\n Result: ${cleanResult}`, {
className, className,
triggerType, triggerType,
input, user: userIdForLog(auth)
result
}); });
} }
function logTriggerError(triggerType, className, input, error) { function logTriggerErrorBeforeHook(triggerType, className, input, auth, error) {
logger.error(`${triggerType} failed for ${className}\nInput: ${JSON.stringify(input)}\Error: ${JSON.stringify(error)}`, { const cleanInput = logger.truncateLogMessage(JSON.stringify(input));
logger.error(`${triggerType} failed for ${className} for user ${userIdForLog(auth)}:\n Input: ${cleanInput}\n Error: ${JSON.stringify(error)}`, {
className, className,
triggerType, triggerType,
input, error,
error user: userIdForLog(auth)
}); });
} }
@@ -187,7 +191,7 @@ function logTriggerError(triggerType, className, input, error) {
// Will resolve successfully if no trigger is configured // Will resolve successfully if no trigger is configured
// Resolves to an object, empty or containing an object key. A beforeSave // 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. // trigger will set the object key to the rest format object to save.
// originalParseObject is optional, we only need that for befote/afterSave functions // originalParseObject is optional, we only need that for before/afterSave functions
export function maybeRunTrigger(triggerType, auth, parseObject, originalParseObject, config) { export function maybeRunTrigger(triggerType, auth, parseObject, originalParseObject, config) {
if (!parseObject) { if (!parseObject) {
return Promise.resolve({}); return Promise.resolve({});
@@ -197,25 +201,28 @@ export function maybeRunTrigger(triggerType, auth, parseObject, originalParseObj
if (!trigger) return resolve(); if (!trigger) return resolve();
var request = getRequestObject(triggerType, auth, parseObject, originalParseObject, config); var request = getRequestObject(triggerType, auth, parseObject, originalParseObject, config);
var response = getResponseObject(request, (object) => { var response = getResponseObject(request, (object) => {
logTriggerSuccess(triggerType, parseObject.className, parseObject.toJSON(), object); logTriggerSuccessBeforeHook(
triggerType, parseObject.className, parseObject.toJSON(), object, auth);
resolve(object); resolve(object);
}, (error) => { }, (error) => {
logTriggerError(triggerType, parseObject.className, parseObject.toJSON(), error); logTriggerErrorBeforeHook(
triggerType, parseObject.className, parseObject.toJSON(), auth, error);
reject(error); reject(error);
}); });
// Force the current Parse app before the trigger // Force the current Parse app before the trigger
Parse.applicationId = config.applicationId; Parse.applicationId = config.applicationId;
Parse.javascriptKey = config.javascriptKey || ''; Parse.javascriptKey = config.javascriptKey || '';
Parse.masterKey = config.masterKey; Parse.masterKey = config.masterKey;
// For the afterSuccess / afterDelete
logTrigger(triggerType, parseObject.className, parseObject.toJSON());
//AfterSave and afterDelete triggers can return a promise, which if they do, needs to be resolved before this promise is resolved, // AfterSave and afterDelete triggers can return a promise, which if they
//so trigger execution is synced with RestWrite.execute() call. // do, needs to be resolved before this promise is resolved,
//If triggers do not return a promise, they can run async code parallel to the RestWrite.execute() call. // so trigger execution is synced with RestWrite.execute() call.
// If triggers do not return a promise, they can run async code parallel
// to the RestWrite.execute() call.
var triggerPromise = trigger(request, response); var triggerPromise = trigger(request, response);
if(triggerType === Types.afterSave || triggerType === Types.afterDelete) if(triggerType === Types.afterSave || triggerType === Types.afterDelete)
{ {
logTriggerAfterHook(triggerType, parseObject.className, parseObject.toJSON(), auth);
if(triggerPromise && typeof triggerPromise.then === "function") { if(triggerPromise && typeof triggerPromise.then === "function") {
return triggerPromise.then(resolve, resolve); return triggerPromise.then(resolve, resolve);
} }