Initial Commit

Author: dblythy

spec/CloudCode.spec.js

@@ -38,6 +38,62 @@ describe('Cloud Code', () => {
       });
     });
   });
+  const masterKeyHeaders = {
+    'X-Parse-Application-Id': 'test',
+    'X-Parse-Rest-API-Key': 'rest',
+    'X-Parse-Master-Key': 'test',
+    'Content-Type': 'application/json',
+  };
+  const masterKeyOptions = {
+    headers: masterKeyHeaders,
+    json: true,
+  };
+  it('can load cloud code file from dashboard', async done => {
+    const cloudDir = './spec/cloud/cloudCodeAbsoluteFile.js';
+    await reconfigureServer({ cloud: cloudDir });
+    const options = Object.assign({}, masterKeyOptions, {
+      method: 'GET',
+      url: Parse.serverURL + '/releases/latest',
+    });
+    request(options)
+      .then(res => {
+        expect(Array.isArray(res.data)).toBe(true);
+        const first = res.data[0];
+        expect(first.userFiles).toBeDefined();
+        expect(first.checksums).toBeDefined();
+        expect(first.userFiles).toContain(cloudDir);
+        expect(first.checksums).toContain(cloudDir);
+        options.url = Parse.serverURL + '/scripts/spec/cloud/cloudCodeAbsoluteFile.js';
+        return request(options);
+      })
+      .then(res => {
+        const response = res.data;
+        expect(response).toContain('It is possible to define cloud code in a file.');
+        done();
+      });
+  });
+
+  it('can load multiple cloud code files from dashboard', async done => {
+    const cloudDir = './spec/cloud/cloudCodeRequireFiles.js';
+    await reconfigureServer({ cloud: cloudDir });
+    const options = Object.assign({}, masterKeyOptions, {
+      method: 'GET',
+      url: Parse.serverURL + '/releases/latest',
+    });
+    request(options).then(res => {
+      expect(Array.isArray(res.data)).toBe(true);
+      const first = res.data[0];
+      expect(first.userFiles).toBeDefined();
+      expect(first.checksums).toBeDefined();
+      expect(first.userFiles).toContain(cloudDir);
+      expect(first.checksums).toContain(cloudDir);
+      expect(first.userFiles).toContain('spec/cloud/cloudCodeAbsoluteFile.js');
+      expect(first.checksums).toContain('spec/cloud/cloudCodeAbsoluteFile.js');
+      expect(first.userFiles).toContain('spec/cloud/cloudCodeRelativeFile.js');
+      expect(first.checksums).toContain('spec/cloud/cloudCodeRelativeFile.js');
+      done();
+    });
+  });
 
   it('can create functions', done => {
     Parse.Cloud.define('hello', () => {

spec/cloud/cloudCodeRequireFiles.js

@@ -0,0 +1,2 @@
+require('./cloudCodeAbsoluteFile.js');
+require('./cloudCodeRelativeFile.js');

src/Routers/CloudCodeRouter.js

@@ -3,6 +3,8 @@ import Parse from 'parse/node';
 import rest from '../rest';
 const triggers = require('../triggers');
 const middleware = require('../middlewares');
+const fs = require('fs');
+const path = require('path');
 
 function formatJobSchedule(job_schedule) {
   if (typeof job_schedule.startAfter === 'undefined') {
@@ -53,6 +55,18 @@ export class CloudCodeRouter extends PromiseRouter {
       middleware.promiseEnforceMasterKeyAccess,
       CloudCodeRouter.deleteJob
     );
+    this.route(
+      'GET',
+      '/releases/latest',
+      middleware.promiseEnforceMasterKeyAccess,
+      CloudCodeRouter.getCloudCode
+    );
+    this.route(
+      'GET',
+      '/scripts/*',
+      middleware.promiseEnforceMasterKeyAccess,
+      CloudCodeRouter.getCloudFile
+    );
   }
 
   static getJobs(req) {
@@ -120,4 +134,56 @@ export class CloudCodeRouter extends PromiseRouter {
         };
       });
   }
+  static getCloudFile(req) {
+    const file = req.url.replace('/scripts', '');
+    const dirName = __dirname.split('lib')[0];
+    const filePath = path.join(dirName, file);
+    if (!fs.existsSync(filePath) || !fs.lstatSync(filePath).isFile()) {
+      throw new Parse.Error(Parse.Error.INTERNAL_SERVER_ERROR, 'Invalid file url.');
+    }
+    return {
+      response: fs.readFileSync(filePath, 'utf8'),
+    };
+  }
+  static getCloudCode(req) {
+    const config = req.config;
+    const dirName = __dirname.split('node_modules')[0];
+    const cloudLocation = ('' + config.cloud).replace(dirName, '');
+    const cloudFiles = [];
+    const getRequiredFromFile = (file, directory) => {
+      try {
+        const fileData = fs.readFileSync(file, 'utf8');
+        const requireStatements = fileData.split('require(');
+        for (let reqStatement of requireStatements) {
+          reqStatement = reqStatement.split(')')[0].slice(1, -1);
+          const filePath = path.join(directory, reqStatement);
+          if (!fs.existsSync(filePath) || !fs.lstatSync(filePath).isFile()) {
+            continue;
+          }
+          const requireData = fs.readFileSync(filePath, 'utf8');
+          const newFilePath = filePath.replace(dirName, '');
+          cloudFiles.push(newFilePath);
+          if (requireData.includes('require(')) {
+            getRequiredFromFile(newFilePath, path.dirname(filePath));
+          }
+        }
+      } catch (e) {
+        /* */
+      }
+    };
+    cloudFiles.push(cloudLocation);
+    getRequiredFromFile(cloudLocation, path.dirname(config.cloud));
+    const response = {};
+    for (const file of cloudFiles) {
+      response[file] = new Date();
+    }
+    return {
+      response: [
+        {
+          checksums: JSON.stringify({ cloud: response }),
+          userFiles: JSON.stringify({ cloud: response }),
+        },
+      ],
+    };
+  }
 }

src/Routers/FeaturesRouter.js

@@ -21,6 +21,7 @@ export class FeaturesRouter extends PromiseRouter {
         },
         cloudCode: {
           jobs: true,
+          viewCode: true,
         },
         logs: {
           level: true,