add integration tests

Author: vahidalizad

spec/integration.spec.js

@@ -0,0 +1,72 @@
+const Parse = require('parse/node');
+const { TestUtils } = require('parse-server');
+const { PARSE_APP_ID, PARSE_MASTER_KEY, reconfigureServer, serverURL } = require('./mocks/server');
+const { httpRequest } = require('./support/request');
+
+const fileData = 'hello world';
+
+describe('S3Adapter integration tests', () => {
+  beforeEach(async () => {
+    process.env.TESTING = true;
+
+    await reconfigureServer();
+
+    Parse.initialize(PARSE_APP_ID);
+    Parse.serverURL = serverURL;
+    Parse.CoreManager.set('SERVER_URL', serverURL);
+    Parse.CoreManager.set('MASTER_KEY', PARSE_MASTER_KEY);
+  }, 60 * 1000);
+
+  afterAll(async () => {
+    Parse.Storage._clear();
+    await TestUtils.destroyAllDataPermanently(true);
+  });
+
+  it('should create a file in Parse Server', async () => {
+    const fileName = 'test-1.txt';
+
+    const base64 = Buffer.from(fileData).toString('base64');
+    const file = new Parse.File(fileName, { base64 });
+
+    await file.save();
+
+    expect(file).toBeDefined();
+    expect(file.url()).toContain(fileName);
+  });
+
+  it(
+    'should read the contents of the file',
+    async () => {
+      const fileName = 'test-2.txt';
+      const base64 = Buffer.from(fileData).toString('base64');
+      const file = new Parse.File(fileName, { base64 });
+      await file.save();
+      const fileLink = file.url();
+
+      const response = await httpRequest(fileLink);
+      const text = response.toString();
+
+      expect(text).toBe(fileData); // Check if the contents match the original data
+    },
+    60 * 1000
+  );
+
+  it(
+    'should delete the file',
+    async () => {
+      const fileName = 'test-3.txt';
+
+      const base64 = Buffer.from(fileData).toString('base64');
+      const file = new Parse.File(fileName, { base64 });
+      await file.save();
+
+      const fileLink = file.url();
+      await file.destroy();
+
+      return expectAsync(httpRequest(fileLink)).toBeRejectedWithError(
+        'Request failed with status code 404'
+      );
+    },
+    60 * 1000
+  );
+});

spec/mocks/MockEmailAdapterWithOptions.js

@@ -0,0 +1,18 @@
+module.exports = (options = {}) => {
+  const adapter = {
+    sendVerificationEmail: () => Promise.resolve(),
+    sendPasswordResetEmail: () => Promise.resolve(),
+    sendMail: () => Promise.resolve(),
+  };
+  if (options.sendMail) {
+    adapter.sendMail = options.sendMail;
+  }
+  if (options.sendPasswordResetEmail) {
+    adapter.sendPasswordResetEmail = options.sendPasswordResetEmail;
+  }
+  if (options.sendVerificationEmail) {
+    adapter.sendVerificationEmail = options.sendVerificationEmail;
+  }
+
+  return adapter;
+};

spec/mocks/s3adapter.js

@@ -74,4 +74,4 @@ function makeS3Adapter(options) {
   return s3;
 }
 
-module.exports = {makeS3Adapter}
+module.exports = { makeS3Adapter };

spec/mocks/server.js

@@ -0,0 +1,68 @@
+const { ParseServer } = require('parse-server');
+const MockEmailAdapterWithOptions = require('./MockEmailAdapterWithOptions');
+const { makeS3Adapter } = require('./s3adapter');
+
+const port = 1327;
+const mountPath = '/api/parse';
+const serverURL = 'http://127.0.0.1:1327/api/parse';
+
+const PARSE_APP_ID = 'app-id';
+const PARSE_MASTER_KEY = 'master-key';
+
+const S3Adapter = makeS3Adapter();
+
+const defaultConfiguration = {
+  databaseURI: 'mongodb://127.0.0.1:27017/s3-adapter',
+  appId: PARSE_APP_ID,
+  masterKey: PARSE_MASTER_KEY,
+  serverURL,
+  liveQuery: {
+    classNames: [],
+  },
+  startLiveQueryServer: true,
+  verbose: false,
+  silent: true,
+  fileUpload: {
+    enableForPublic: true,
+    enableForAnonymousUser: true,
+    enableForAuthenticatedUser: true,
+  },
+  revokeSessionOnPasswordReset: false,
+  allowCustomObjectId: false,
+  allowClientClassCreation: true,
+  encodeParseObjectInCloudFunction: true,
+  masterKeyIps: ['0.0.0.0/0', '0.0.0.0', '::/0', '::'],
+  emailAdapter: MockEmailAdapterWithOptions(),
+  port,
+  mountPath,
+  filesAdapter: S3Adapter,
+};
+
+let parseServer;
+
+const reconfigureServer = async () => {
+  if (parseServer) {
+    await parseServer.handleShutdown();
+    await new Promise(resolve => parseServer.server.close(resolve));
+    parseServer = undefined;
+    return reconfigureServer();
+  }
+
+  parseServer = await ParseServer.startApp(defaultConfiguration);
+  if (parseServer.config.state === 'initialized') {
+    console.error('Failed to initialize Parse Server');
+    return reconfigureServer();
+  }
+
+  return parseServer;
+};
+
+module.exports = {
+  reconfigureServer,
+  S3Adapter,
+  port,
+  mountPath,
+  serverURL,
+  PARSE_APP_ID,
+  PARSE_MASTER_KEY,
+};

spec/support/request.js

@@ -0,0 +1,39 @@
+const http = require('http');
+const https = require('https');
+
+/**
+ * Makes an HTTP or HTTPS request.
+ * @param {string} url - The URL to request.
+ * @returns {Promise<string>} - A promise that resolves with the response data or rejects with an error.
+ */
+function httpRequest(url) {
+  return new Promise((resolve, reject) => {
+    // Determine the appropriate module to use based on the URL protocol
+    const client = url.startsWith('https') ? https : http;
+
+    // Make the request
+    client
+      .get(url, response => {
+        let data = '';
+
+        // Collect the data chunks
+        response.on('data', chunk => {
+          data += chunk;
+        });
+
+        // When the response ends, resolve or reject the promise
+        response.on('end', () => {
+          if (response.statusCode >= 200 && response.statusCode < 300) {
+            resolve(data); // Resolve with the collected data
+          } else {
+            reject(new Error(`Request failed with status code ${response.statusCode}`));
+          }
+        });
+      })
+      .on('error', error => {
+        reject(new Error(`Error making request: ${error.message}`)); // Reject on error
+      });
+  });
+}
+
+module.exports = { httpRequest };