check params in job message

Author: mtrezza

integration/test/IdempotencyTest.js

@@ -34,8 +34,9 @@ describe('Idempotency', () => {
 
   it('handle duplicate job request', async () => {
     DuplicateRequestId('1234');
-    const jobStatusId = await Parse.Cloud.startJob('CloudJob1', {});
-    await expectAsync(Parse.Cloud.startJob('CloudJob1', {})).toBeRejectedWithError(
+    const params = { startedBy: 'Monty Python' };
+    const jobStatusId = await Parse.Cloud.startJob('CloudJobParamsInMessage', params);
+    await expectAsync(Parse.Cloud.startJob('CloudJobParamsInMessage', params)).toBeRejectedWithError(
       'Duplicate request'
     );
 
@@ -48,6 +49,7 @@ describe('Idempotency', () => {
     }
     const jobStatus = await Parse.Cloud.getJobStatus(jobStatusId);
     expect(jobStatus.get('status')).toBe('succeeded');
+    expect(JSON.parse(jobStatus.get('message'))).toEqual(params);
   });
 
   it('handle duplicate POST / PUT request', async () => {

integration/test/ParseCloudTest.js

@@ -94,12 +94,14 @@ describe('Parse Cloud', () => {
   });
 
   it('run job', async () => {
-    const jobStatusId = await Parse.Cloud.startJob('CloudJob1', {});
+    const params = { startedBy: 'Monty Python' };
+    const jobStatusId = await Parse.Cloud.startJob('CloudJobParamsInMessage', params);
     expect(jobStatusId).toBeDefined();
     await waitForJobStatus(jobStatusId, 'succeeded');
 
     const jobStatus = await Parse.Cloud.getJobStatus(jobStatusId);
-    assert.equal(jobStatus.get('status'), 'succeeded');
+    expect(jobStatus.get('status')).toBe('succeeded');
+    expect(JSON.parse(jobStatus.get('message'))).toEqual(params);
   });
 
   it('run long job', async () => {

integration/test/cloud/main.js

@@ -45,6 +45,10 @@ Parse.Cloud.job('CloudJob2', function () {
   });
 });
 
+Parse.Cloud.job('CloudJobParamsInMessage', request => {
+  request.message(JSON.stringify(request.params));
+});
+
 Parse.Cloud.job('CloudJobFailing', function () {
   throw 'cloud job failed';
 });

integration/test/helper.js

@@ -74,7 +74,7 @@ const defaultConfiguration = {
     },
   },
   idempotencyOptions: {
-    paths: ['functions/CloudFunctionIdempotency', 'jobs/CloudJob1', 'classes/IdempotentTest'],
+    paths: ['functions/CloudFunctionIdempotency', 'jobs/CloudJob1', 'jobs/CloudJobParamsInMessage', 'classes/IdempotentTest'],
     ttl: 120,
   },
   fileUpload: {