feat: Add support for asynchronous invocation of FilesAdapter.getFileLocation

spec/FilesController.spec.js

@@ -21,11 +21,11 @@ const mockAdapter = {
 
 // Small additional tests to improve overall coverage
 describe('FilesController', () => {
-  it('should properly expand objects', done => {
+  it('should properly expand objects', async done => {
     const config = Config.get(Parse.applicationId);
     const gridFSAdapter = new GridFSBucketAdapter('mongodb://localhost:27017/parse');
     const filesController = new FilesController(gridFSAdapter);
-    const result = filesController.expandFilesInObject(config, function () {});
+    const result = await filesController.expandFilesInObject(config, function () { });
 
     expect(result).toBeUndefined();
 
@@ -37,7 +37,7 @@ describe('FilesController', () => {
     const anObject = {
       aFile: fullFile,
     };
-    filesController.expandFilesInObject(config, anObject);
+    await filesController.expandFilesInObject(config, anObject);
     expect(anObject.aFile.url).toEqual('http://an.url');
 
     done();

src/Adapters/Files/FilesAdapter.js

@@ -59,9 +59,9 @@ export class FilesAdapter {
    * @param {Config} config - server configuration
    * @param {string} filename
    *
-   * @return {string} Absolute URL
+   * @return {string | Promise<string>} Absolute URL
    */
-  getFileLocation(config: Config, filename: string): string {}
+  getFileLocation(config: Config, filename: string): string | Promise<string> {}
 
   /** Validate a filename for this adapter type
    *

src/Controllers/FilesController.js

@@ -15,7 +15,7 @@ export class FilesController extends AdaptableController {
     return this.adapter.getFileData(filename);
   }
 
-  createFile(config, filename, data, contentType, options) {
+  async createFile(config, filename, data, contentType, options) {
     const extname = path.extname(filename);
 
     const hasExtension = extname.length > 0;
@@ -30,13 +30,12 @@ export class FilesController extends AdaptableController {
       filename = randomHexString(32) + '_' + filename;
     }
 
-    const location = this.adapter.getFileLocation(config, filename);
-    return this.adapter.createFile(filename, data, contentType, options).then(() => {
-      return Promise.resolve({
-        url: location,
-        name: filename,
-      });
-    });
+    const location = await this.adapter.getFileLocation(config, filename);
+    await this.adapter.createFile(filename, data, contentType, options);
+    return {
+      url: location,
+      name: filename,
+    }
   }
 
   deleteFile(config, filename) {
@@ -55,9 +54,10 @@ export class FilesController extends AdaptableController {
    * with the current mount point and app id.
    * Object may be a single object or list of REST-format objects.
    */
-  expandFilesInObject(config, object) {
+  async expandFilesInObject(config, object) {
     if (object instanceof Array) {
-      object.map(obj => this.expandFilesInObject(config, obj));
+      const promises = object.map(obj => this.expandFilesInObject(config, obj));
+      await Promise.all(promises);
       return;
     }
     if (typeof object !== 'object') {
@@ -74,7 +74,7 @@ export class FilesController extends AdaptableController {
         // all filenames starting with a "-" seperated UUID should be from files.parse.com
         // all other filenames have been migrated or created from Parse Server
         if (config.fileKey === undefined) {
-          fileObject['url'] = this.adapter.getFileLocation(config, filename);
+          fileObject['url'] = await this.adapter.getFileLocation(config, filename);
         } else {
           if (filename.indexOf('tfss-') === 0) {
             fileObject['url'] =
@@ -83,7 +83,7 @@ export class FilesController extends AdaptableController {
             fileObject['url'] =
               'http://files.parse.com/' + config.fileKey + '/' + encodeURIComponent(filename);
           } else {
-            fileObject['url'] = this.adapter.getFileLocation(config, filename);
+            fileObject['url'] = await this.adapter.getFileLocation(config, filename);
           }
         }
       }

src/RestQuery.js

@@ -735,7 +735,7 @@ _UnsafeRestQuery.prototype.replaceEquality = function () {
 
 // Returns a promise for whether it was successful.
 // Populates this.response with an object that only has 'results'.
-_UnsafeRestQuery.prototype.runFind = function (options = {}) {
+_UnsafeRestQuery.prototype.runFind = async function (options = {}) {
   if (this.findOptions.limit === 0) {
     this.response = { results: [] };
     return Promise.resolve();
@@ -749,24 +749,21 @@ _UnsafeRestQuery.prototype.runFind = function (options = {}) {
   if (options.op) {
     findOptions.op = options.op;
   }
-  return this.config.database
-    .find(this.className, this.restWhere, findOptions, this.auth)
-    .then(results => {
-      if (this.className === '_User' && !findOptions.explain) {
-        for (var result of results) {
-          this.cleanResultAuthData(result);
-        }
-      }
+  const results = await this.config.database.find(this.className, this.restWhere, findOptions, this.auth);
+  if (this.className === '_User' && !findOptions.explain) {
+    for (var result of results) {
+      this.cleanResultAuthData(result);
+    }
+  }
 
-      this.config.filesController.expandFilesInObject(this.config, results);
+  await this.config.filesController.expandFilesInObject(this.config, results);
 
-      if (this.redirectClassName) {
-        for (var r of results) {
-          r.className = this.redirectClassName;
-        }
-      }
-      this.response = { results: results };
-    });
+  if (this.redirectClassName) {
+    for (var r of results) {
+      r.className = this.redirectClassName;
+    }
+  }
+  this.response = { results: results };
 };
 
 // Returns a promise for whether it was successful.

src/RestWrite.js

@@ -322,7 +322,7 @@ RestWrite.prototype.runBeforeLoginTrigger = async function (userData) {
   const extraData = { className: this.className };
 
   // Expand file objects
-  this.config.filesController.expandFilesInObject(this.config, userData);
+  await this.config.filesController.expandFilesInObject(this.config, userData);
 
   const user = triggers.inflate(extraData, userData);
 
@@ -1308,7 +1308,7 @@ RestWrite.prototype.handleInstallation = function () {
           throw new Parse.Error(
             132,
             'Must specify installationId when deviceToken ' +
-              'matches multiple Installation objects'
+            'matches multiple Installation objects'
           );
         } else {
           // Multiple device token matches and we specified an installation ID,
@@ -1412,10 +1412,10 @@ RestWrite.prototype.handleInstallation = function () {
 // If we short-circuited the object response - then we need to make sure we expand all the files,
 // since this might not have a query, meaning it won't return the full result back.
 // TODO: (nlutsenko) This should die when we move to per-class based controllers on _Session/_User
-RestWrite.prototype.expandFilesForExistingObjects = function () {
+RestWrite.prototype.expandFilesForExistingObjects = async function () {
   // Check whether we have a short-circuited response - only then run expansion.
   if (this.response && this.response.response) {
-    this.config.filesController.expandFilesInObject(this.config, this.response.response);
+    await this.config.filesController.expandFilesInObject(this.config, this.response.response);
   }
 };
 

src/Routers/FilesRouter.js

@@ -263,7 +263,7 @@ export class FilesRouter {
       const { filename } = req.params;
       // run beforeDeleteFile trigger
       const file = new Parse.File(filename);
-      file._url = filesController.adapter.getFileLocation(req.config, filename);
+      file._url = await filesController.adapter.getFileLocation(req.config, filename);
       const fileObject = { file, fileSize: null };
       await triggers.maybeRunFileTrigger(
         triggers.Types.beforeDelete,

src/Routers/UsersRouter.js

@@ -264,7 +264,7 @@ export class UsersRouter extends ClassesRouter {
     // Remove hidden properties.
     UsersRouter.removeHiddenProperties(user);
 
-    req.config.filesController.expandFilesInObject(req.config, user);
+    await req.config.filesController.expandFilesInObject(req.config, user);
 
     // Before login trigger; throws if failure
     await maybeRunTrigger(
@@ -609,7 +609,7 @@ export class UsersRouter extends ClassesRouter {
         const userString = req.auth && req.auth.user ? req.auth.user.id : undefined;
         logger.error(
           `Failed running auth step challenge for ${provider} for user ${userString} with Error: ` +
-            JSON.stringify(e),
+          JSON.stringify(e),
           {
             authenticationStep: 'challenge',
             error: e,