Support Idempotency

integration/cloud/main.js

@@ -21,6 +21,11 @@ Parse.Cloud.define('UpdateUser', function (request) {
   return user.save(null, { useMasterKey: true });
 });
 
+Parse.Cloud.define('CloudFunctionIdempotency', function () {
+  const object = new Parse.Object('IdempotencyItem');
+  return object.save(null, { useMasterKey: true });
+});
+
 Parse.Cloud.define('CloudFunctionUndefined', function() {
   return undefined;
 });

integration/server.js

@@ -29,14 +29,19 @@ const api = new ParseServer({
   },
   verbose: false,
   silent: true,
+  idempotencyOptions: {
+    paths: ['functions/CloudFunctionIdempotency'],
+    ttl: 120
+  }
 });
 
 app.use('/parse', api);
 
 const TestUtils = require('parse-server').TestUtils;
 
-app.get('/clear', (req, res) => {
-  TestUtils.destroyAllDataPermanently().then(() => {
+app.get('/clear/:fast', (req, res) => {
+  const { fast } = req.params;
+  TestUtils.destroyAllDataPermanently(fast).then(() => {
     res.send('{}');
   });
 });

integration/test/IdempotencyTest.js

@@ -0,0 +1,49 @@
+'use strict';
+
+const assert = require('assert');
+const clear = require('./clear');
+const Parse = require('../../node');
+
+const Item = Parse.Object.extend('IdempotencyItem');
+
+describe('Idempotency', () => {
+  beforeEach((done) => {
+    Parse.initialize('integration', null, 'notsosecret');
+    Parse.CoreManager.set('SERVER_URL', 'http://localhost:1337/parse');
+    Parse.Storage._clear();
+    clear().then(() => {
+      done();
+    });
+  });
+
+  it('duplicate cloud code function request', async () => {
+    const restController = Parse.CoreManager.getRESTController();
+    const XHR = restController._getXHR();
+    function DuplicateXHR() {
+      const xhr = new XHR();
+      const send = xhr.send;
+      xhr.send = function () {
+        this.setRequestHeader('X-Parse-Request-Id', '1234');
+        send.apply(this, arguments);
+      }
+      return xhr;
+    }
+    restController._setXHR(DuplicateXHR);
+    await Parse.Cloud.run('CloudFunctionIdempotency');
+    try {
+      await Parse.Cloud.run('CloudFunctionIdempotency');
+    } catch (e) {
+      assert.equal(e.code, Parse.Error.DUPLICATE_REQUEST);
+    }
+    try {
+      await Parse.Cloud.run('CloudFunctionIdempotency');
+    } catch (e) {
+      assert.equal(e.code, Parse.Error.DUPLICATE_REQUEST);
+    }
+    const query = new Parse.Query(Item);
+    const results = await query.find();
+    assert.equal(results.length, 1);
+
+    restController._setXHR(XHR);
+  });
+});

integration/test/ParseQueryTest.js

@@ -1804,12 +1804,12 @@ describe('Parse Query', () => {
     ];
     const objects = [];
     for (const i in subjects) {
-      const obj = new TestObject({ comment: subjects[i] });
+      const obj = new TestObject({ subject: subjects[i] });
       objects.push(obj);
     }
     return Parse.Object.saveAll(objects).then(() => {
       const q = new Parse.Query(TestObject);
-      q.fullText('comment', 'coffee');
+      q.fullText('subject', 'coffee');
       q.ascending('$score');
       q.select('$score');
       return q.find();

integration/test/clear.js

@@ -1,5 +1,11 @@
 const Parse = require('../../node');
 
-module.exports = function() {
-  return Parse._ajax('GET', 'http://localhost:1337/clear', '');
+/**
+ * Destroys all data in the database
+ * Calls /clear route in integration/test/server.js
+ *
+ * @param {boolean} fast set to true if it's ok to just drop objects and not indexes.
+ */
+module.exports = function(fast = true) {
+  return Parse._ajax('GET', `http://localhost:1337/clear/${fast}`, '');
 };