499 lines
16 KiB
JavaScript
499 lines
16 KiB
JavaScript
"use strict";
|
|
/* global describe, it, expect, fail, Parse */
|
|
var request = require('request');
|
|
var triggers = require('../src/triggers');
|
|
var HooksController = require('../src/Controllers/HooksController').default;
|
|
var express = require("express");
|
|
var bodyParser = require('body-parser');
|
|
|
|
var port = 12345;
|
|
var hookServerURL = "http://localhost:" + port;
|
|
const AppCache = require('../src/cache').AppCache;
|
|
|
|
var app = express();
|
|
app.use(bodyParser.json({ 'type': '*/*' }))
|
|
app.listen(12345);
|
|
|
|
describe('Hooks', () => {
|
|
it("should have no hooks registered", (done) => {
|
|
Parse.Hooks.getFunctions().then((res) => {
|
|
expect(res.constructor).toBe(Array.prototype.constructor);
|
|
done();
|
|
}, (err) => {
|
|
jfail(err);
|
|
done();
|
|
});
|
|
});
|
|
|
|
it("should have no triggers registered", (done) => {
|
|
Parse.Hooks.getTriggers().then((res) => {
|
|
expect(res.constructor).toBe(Array.prototype.constructor);
|
|
done();
|
|
}, (err) => {
|
|
jfail(err);
|
|
done();
|
|
});
|
|
});
|
|
|
|
it("should CRUD a function registration", (done) => {
|
|
// Create
|
|
Parse.Hooks.createFunction("My-Test-Function", "http://someurl")
|
|
.then(response => {
|
|
expect(response.functionName).toBe("My-Test-Function");
|
|
expect(response.url).toBe("http://someurl")
|
|
// Find
|
|
return Parse.Hooks.getFunction("My-Test-Function")
|
|
}).then(response => {
|
|
expect(response.objectId).toBeUndefined();
|
|
expect(response.url).toBe("http://someurl");
|
|
return Parse.Hooks.updateFunction("My-Test-Function", "http://anotherurl");
|
|
})
|
|
.then((res) => {
|
|
expect(res.objectId).toBeUndefined();
|
|
expect(res.functionName).toBe("My-Test-Function");
|
|
expect(res.url).toBe("http://anotherurl")
|
|
// delete
|
|
return Parse.Hooks.removeFunction("My-Test-Function")
|
|
})
|
|
.then(() => {
|
|
// Find again! but should be deleted
|
|
return Parse.Hooks.getFunction("My-Test-Function")
|
|
.then(res => {
|
|
fail("Failed to delete hook")
|
|
fail(res)
|
|
done();
|
|
return Promise.resolve();
|
|
}, (err) => {
|
|
expect(err.code).toBe(143);
|
|
expect(err.message).toBe("no function named: My-Test-Function is defined")
|
|
done();
|
|
return Promise.resolve();
|
|
})
|
|
})
|
|
.catch(error => {
|
|
jfail(error);
|
|
done();
|
|
})
|
|
});
|
|
|
|
it("should CRUD a trigger registration", (done) => {
|
|
// Create
|
|
Parse.Hooks.createTrigger("MyClass","beforeDelete", "http://someurl").then((res) => {
|
|
expect(res.className).toBe("MyClass");
|
|
expect(res.triggerName).toBe("beforeDelete");
|
|
expect(res.url).toBe("http://someurl")
|
|
// Find
|
|
return Parse.Hooks.getTrigger("MyClass","beforeDelete");
|
|
}, (err) => {
|
|
fail(err);
|
|
done();
|
|
}).then((res) => {
|
|
expect(res).not.toBe(null);
|
|
expect(res).not.toBe(undefined);
|
|
expect(res.objectId).toBeUndefined();
|
|
expect(res.url).toBe("http://someurl");
|
|
// delete
|
|
return Parse.Hooks.updateTrigger("MyClass","beforeDelete", "http://anotherurl");
|
|
}, (err) => {
|
|
jfail(err);
|
|
done();
|
|
}).then((res) => {
|
|
expect(res.className).toBe("MyClass");
|
|
expect(res.url).toBe("http://anotherurl")
|
|
expect(res.objectId).toBeUndefined();
|
|
|
|
return Parse.Hooks.removeTrigger("MyClass","beforeDelete");
|
|
}, (err) => {
|
|
jfail(err);
|
|
done();
|
|
}).then(() => {
|
|
// Find again! but should be deleted
|
|
return Parse.Hooks.getTrigger("MyClass","beforeDelete");
|
|
}, (err) => {
|
|
jfail(err);
|
|
done();
|
|
}).then(function(){
|
|
fail("should not succeed");
|
|
done();
|
|
}, (err) => {
|
|
if (err) {
|
|
expect(err).not.toBe(null);
|
|
expect(err).not.toBe(undefined);
|
|
expect(err.code).toBe(143);
|
|
expect(err.message).toBe("class MyClass does not exist")
|
|
} else {
|
|
fail('should have errored');
|
|
}
|
|
done();
|
|
});
|
|
});
|
|
|
|
it("should fail to register hooks without Master Key", (done) => {
|
|
request.post(Parse.serverURL + "/hooks/functions", {
|
|
headers: {
|
|
"X-Parse-Application-Id": Parse.applicationId,
|
|
"X-Parse-REST-API-Key": Parse.restKey,
|
|
},
|
|
body: JSON.stringify({ url: "http://hello.word", functionName: "SomeFunction"})
|
|
}, (err, res, body) => {
|
|
body = JSON.parse(body);
|
|
expect(body.error).toBe("unauthorized");
|
|
done();
|
|
})
|
|
});
|
|
|
|
it("should fail trying to create two times the same function", (done) => {
|
|
Parse.Hooks.createFunction("my_new_function", "http://url.com")
|
|
.then(() => new Promise(resolve => setTimeout(resolve, 100)))
|
|
.then(() => {
|
|
return Parse.Hooks.createFunction("my_new_function", "http://url.com")
|
|
}, () => {
|
|
fail("should create a new function");
|
|
}).then(() => {
|
|
fail("should not be able to create the same function");
|
|
}, (err) => {
|
|
expect(err).not.toBe(undefined);
|
|
expect(err).not.toBe(null);
|
|
if (err) {
|
|
expect(err.code).toBe(143);
|
|
expect(err.message).toBe('function name: my_new_function already exits')
|
|
}
|
|
return Parse.Hooks.removeFunction("my_new_function");
|
|
}).then(() => {
|
|
done();
|
|
}, (err) => {
|
|
jfail(err);
|
|
done();
|
|
})
|
|
});
|
|
|
|
it("should fail trying to create two times the same trigger", (done) => {
|
|
Parse.Hooks.createTrigger("MyClass", "beforeSave", "http://url.com").then(() => {
|
|
return Parse.Hooks.createTrigger("MyClass", "beforeSave", "http://url.com")
|
|
}, () => {
|
|
fail("should create a new trigger");
|
|
}).then(() => {
|
|
fail("should not be able to create the same trigger");
|
|
}, (err) => {
|
|
expect(err).not.toBe(undefined);
|
|
expect(err).not.toBe(null);
|
|
if (err) {
|
|
expect(err.code).toBe(143);
|
|
expect(err.message).toBe('class MyClass already has trigger beforeSave')
|
|
}
|
|
return Parse.Hooks.removeTrigger("MyClass", "beforeSave");
|
|
}).then(() => {
|
|
done();
|
|
}, (err) => {
|
|
jfail(err);
|
|
done();
|
|
})
|
|
});
|
|
|
|
it("should fail trying to update a function that don't exist", (done) => {
|
|
Parse.Hooks.updateFunction("A_COOL_FUNCTION", "http://url.com").then(() => {
|
|
fail("Should not succeed")
|
|
}, (err) => {
|
|
expect(err).not.toBe(undefined);
|
|
expect(err).not.toBe(null);
|
|
if (err) {
|
|
expect(err.code).toBe(143);
|
|
expect(err.message).toBe('no function named: A_COOL_FUNCTION is defined');
|
|
}
|
|
return Parse.Hooks.getFunction("A_COOL_FUNCTION")
|
|
}).then(() => {
|
|
fail("the function should not exist");
|
|
done();
|
|
}, (err) => {
|
|
expect(err).not.toBe(undefined);
|
|
expect(err).not.toBe(null);
|
|
if (err) {
|
|
expect(err.code).toBe(143);
|
|
expect(err.message).toBe('no function named: A_COOL_FUNCTION is defined');
|
|
}
|
|
done();
|
|
});
|
|
});
|
|
|
|
it("should fail trying to update a trigger that don't exist", (done) => {
|
|
Parse.Hooks.updateTrigger("AClassName","beforeSave", "http://url.com").then(() => {
|
|
fail("Should not succeed")
|
|
}, (err) => {
|
|
expect(err).not.toBe(undefined);
|
|
expect(err).not.toBe(null);
|
|
if (err) {
|
|
expect(err.code).toBe(143);
|
|
expect(err.message).toBe('class AClassName does not exist');
|
|
}
|
|
return Parse.Hooks.getTrigger("AClassName","beforeSave")
|
|
}).then(() => {
|
|
fail("the function should not exist");
|
|
done();
|
|
}, (err) => {
|
|
expect(err).not.toBe(undefined);
|
|
expect(err).not.toBe(null);
|
|
if (err) {
|
|
expect(err.code).toBe(143);
|
|
expect(err.message).toBe('class AClassName does not exist');
|
|
}
|
|
done();
|
|
});
|
|
});
|
|
|
|
|
|
it("should fail trying to create a malformed function", (done) => {
|
|
Parse.Hooks.createFunction("MyFunction").then((res) => {
|
|
fail(res);
|
|
}, (err) => {
|
|
expect(err).not.toBe(undefined);
|
|
expect(err).not.toBe(null);
|
|
if (err) {
|
|
expect(err.code).toBe(143);
|
|
expect(err.error).toBe("invalid hook declaration");
|
|
}
|
|
done();
|
|
});
|
|
});
|
|
|
|
it("should fail trying to create a malformed function (REST)", (done) => {
|
|
request.post(Parse.serverURL + "/hooks/functions", {
|
|
headers: {
|
|
"X-Parse-Application-Id": Parse.applicationId,
|
|
"X-Parse-Master-Key": Parse.masterKey,
|
|
},
|
|
body: JSON.stringify({ functionName: "SomeFunction"})
|
|
}, (err, res, body) => {
|
|
body = JSON.parse(body);
|
|
expect(body.error).toBe("invalid hook declaration");
|
|
expect(body.code).toBe(143);
|
|
done();
|
|
})
|
|
});
|
|
|
|
|
|
it("should create hooks and properly preload them", (done) => {
|
|
|
|
var promises = [];
|
|
for (var i = 0; i < 5; i++) {
|
|
promises.push(Parse.Hooks.createTrigger("MyClass" + i, "beforeSave", "http://url.com/beforeSave/" + i));
|
|
promises.push(Parse.Hooks.createFunction("AFunction" + i, "http://url.com/function" + i));
|
|
}
|
|
|
|
Parse.Promise.when(promises).then(function(){
|
|
for (var i = 0; i < 5; i++) {
|
|
// Delete everything from memory, as the server just started
|
|
triggers.removeTrigger("beforeSave", "MyClass" + i, Parse.applicationId);
|
|
triggers.removeFunction("AFunction" + i, Parse.applicationId);
|
|
expect(triggers.getTrigger("MyClass" + i, "beforeSave", Parse.applicationId)).toBeUndefined();
|
|
expect(triggers.getFunction("AFunction" + i, Parse.applicationId)).toBeUndefined();
|
|
}
|
|
const hooksController = new HooksController(Parse.applicationId, AppCache.get('test').databaseController);
|
|
return hooksController.load()
|
|
}, (err) => {
|
|
jfail(err);
|
|
fail('Should properly create all hooks');
|
|
done();
|
|
}).then(function() {
|
|
for (var i = 0; i < 5; i++) {
|
|
expect(triggers.getTrigger("MyClass" + i, "beforeSave", Parse.applicationId)).not.toBeUndefined();
|
|
expect(triggers.getFunction("AFunction" + i, Parse.applicationId)).not.toBeUndefined();
|
|
}
|
|
done();
|
|
}, (err) => {
|
|
jfail(err);
|
|
fail('should properly load all hooks');
|
|
done();
|
|
})
|
|
});
|
|
|
|
it("should run the function on the test server", (done) => {
|
|
|
|
app.post("/SomeFunction", function(req, res) {
|
|
res.json({success:"OK!"});
|
|
});
|
|
|
|
Parse.Hooks.createFunction("SOME_TEST_FUNCTION", hookServerURL + "/SomeFunction").then(function(){
|
|
return Parse.Cloud.run("SOME_TEST_FUNCTION")
|
|
}, (err) => {
|
|
jfail(err);
|
|
fail("Should not fail creating a function");
|
|
done();
|
|
}).then(function(res){
|
|
expect(res).toBe("OK!");
|
|
done();
|
|
}, (err) => {
|
|
jfail(err);
|
|
fail("Should not fail calling a function");
|
|
done();
|
|
});
|
|
});
|
|
|
|
it("should run the function on the test server", (done) => {
|
|
|
|
app.post("/SomeFunctionError", function(req, res) {
|
|
res.json({error: {code: 1337, error: "hacking that one!"}});
|
|
});
|
|
// The function is deleted as the DB is dropped between calls
|
|
Parse.Hooks.createFunction("SOME_TEST_FUNCTION", hookServerURL + "/SomeFunctionError").then(function(){
|
|
return Parse.Cloud.run("SOME_TEST_FUNCTION")
|
|
}, (err) => {
|
|
jfail(err);
|
|
fail("Should not fail creating a function");
|
|
done();
|
|
}).then(function() {
|
|
fail("Should not succeed calling that function");
|
|
done();
|
|
}, (err) => {
|
|
expect(err).not.toBe(undefined);
|
|
expect(err).not.toBe(null);
|
|
if (err) {
|
|
expect(err.code).toBe(141);
|
|
expect(err.message.code).toEqual(1337)
|
|
expect(err.message.error).toEqual("hacking that one!");
|
|
}
|
|
done();
|
|
});
|
|
});
|
|
|
|
it("should provide X-Parse-Webhook-Key when defined", (done) => {
|
|
app.post("/ExpectingKey", function(req, res) {
|
|
if (req.get('X-Parse-Webhook-Key') === 'hook') {
|
|
res.json({success: "correct key provided"});
|
|
} else {
|
|
res.json({error: "incorrect key provided"});
|
|
}
|
|
});
|
|
|
|
Parse.Hooks.createFunction("SOME_TEST_FUNCTION", hookServerURL + "/ExpectingKey").then(function(){
|
|
return Parse.Cloud.run("SOME_TEST_FUNCTION")
|
|
}, (err) => {
|
|
jfail(err);
|
|
fail("Should not fail creating a function");
|
|
done();
|
|
}).then(function(res){
|
|
expect(res).toBe("correct key provided");
|
|
done();
|
|
}, (err) => {
|
|
jfail(err);
|
|
fail("Should not fail calling a function");
|
|
done();
|
|
});
|
|
});
|
|
|
|
it("should not pass X-Parse-Webhook-Key if not provided", (done) => {
|
|
reconfigureServer({ webhookKey: undefined })
|
|
.then(() => {
|
|
app.post("/ExpectingKeyAlso", function(req, res) {
|
|
if (req.get('X-Parse-Webhook-Key') === 'hook') {
|
|
res.json({success: "correct key provided"});
|
|
} else {
|
|
res.json({error: "incorrect key provided"});
|
|
}
|
|
});
|
|
|
|
Parse.Hooks.createFunction("SOME_TEST_FUNCTION", hookServerURL + "/ExpectingKeyAlso").then(function(){
|
|
return Parse.Cloud.run("SOME_TEST_FUNCTION")
|
|
}, (err) => {
|
|
jfail(err);
|
|
fail("Should not fail creating a function");
|
|
done();
|
|
}).then(function(){
|
|
fail("Should not succeed calling that function");
|
|
done();
|
|
}, (err) => {
|
|
expect(err).not.toBe(undefined);
|
|
expect(err).not.toBe(null);
|
|
if (err) {
|
|
expect(err.code).toBe(141);
|
|
expect(err.message).toEqual("incorrect key provided");
|
|
}
|
|
done();
|
|
});
|
|
});
|
|
});
|
|
|
|
|
|
it("should run the beforeSave hook on the test server", (done) => {
|
|
var triggerCount = 0;
|
|
app.post("/BeforeSaveSome", function(req, res) {
|
|
triggerCount++;
|
|
var object = req.body.object;
|
|
object.hello = "world";
|
|
// Would need parse cloud express to set much more
|
|
// But this should override the key upon return
|
|
res.json({success: object});
|
|
});
|
|
// The function is deleted as the DB is dropped between calls
|
|
Parse.Hooks.createTrigger("SomeRandomObject", "beforeSave", hookServerURL + "/BeforeSaveSome").then(function () {
|
|
const obj = new Parse.Object("SomeRandomObject");
|
|
return obj.save();
|
|
}).then(function(res) {
|
|
expect(triggerCount).toBe(1);
|
|
return res.fetch();
|
|
}).then(function(res) {
|
|
expect(res.get("hello")).toEqual("world");
|
|
done();
|
|
}).fail((err) => {
|
|
jfail(err);
|
|
fail("Should not fail creating a function");
|
|
done();
|
|
});
|
|
});
|
|
|
|
it("beforeSave hooks should correctly handle responses containing entire object", (done) => {
|
|
app.post("/BeforeSaveSome2", function(req, res) {
|
|
var object = Parse.Object.fromJSON(req.body.object);
|
|
object.set('hello', "world");
|
|
res.json({success: object});
|
|
});
|
|
Parse.Hooks.createTrigger("SomeRandomObject2", "beforeSave", hookServerURL + "/BeforeSaveSome2").then(function(){
|
|
const obj = new Parse.Object("SomeRandomObject2");
|
|
return obj.save();
|
|
}).then(function(res) {
|
|
return res.save();
|
|
}).then(function(res) {
|
|
expect(res.get("hello")).toEqual("world");
|
|
done();
|
|
}).fail((err) => {
|
|
fail(`Should not fail: ${JSON.stringify(err)}`);
|
|
done();
|
|
});
|
|
});
|
|
|
|
it("should run the afterSave hook on the test server", (done) => {
|
|
var triggerCount = 0;
|
|
var newObjectId;
|
|
app.post("/AfterSaveSome", function(req, res) {
|
|
triggerCount++;
|
|
var obj = new Parse.Object("AnotherObject");
|
|
obj.set("foo", "bar");
|
|
obj.save().then(function(obj){
|
|
newObjectId = obj.id;
|
|
res.json({success: {}});
|
|
})
|
|
});
|
|
// The function is deleted as the DB is dropped between calls
|
|
Parse.Hooks.createTrigger("SomeRandomObject", "afterSave", hookServerURL + "/AfterSaveSome").then(function(){
|
|
const obj = new Parse.Object("SomeRandomObject");
|
|
return obj.save();
|
|
}).then(function() {
|
|
var promise = new Parse.Promise();
|
|
// Wait a bit here as it's an after save
|
|
setTimeout(() => {
|
|
expect(triggerCount).toBe(1);
|
|
new Parse.Query("AnotherObject")
|
|
.get(newObjectId)
|
|
.then((r) => promise.resolve(r));
|
|
}, 500);
|
|
return promise;
|
|
}).then(function(res){
|
|
expect(res.get("foo")).toEqual("bar");
|
|
done();
|
|
}).fail((err) => {
|
|
jfail(err);
|
|
fail("Should not fail creating a function");
|
|
done();
|
|
});
|
|
});
|
|
});
|