Base filesystem adapter

Author: flovilmart

index.js

@@ -0,0 +1,115 @@
+'use strict';
+// FileSystemAdapter
+//
+// Stores files in local file system
+// Requires write access to the server's file system.
+
+var fs = require('fs');
+var path = require('path');
+var pathSep = require('path').sep;
+
+function FileSystemAdapter(options) {
+  options = options || {};
+  let filesSubDirectory = options.filesSubDirectory || '';
+  this._filesDir = filesSubDirectory;
+  this._mkdir(this._getApplicationDir());
+  if (!this._applicationDirExist()) {
+    throw "Files directory doesn't exist.";
+  }
+}
+
+FileSystemAdapter.prototype.createFile = function(filename, data) {
+  return new Promise((resolve, reject) => {
+    let filepath = this._getLocalFilePath(filename);
+    fs.writeFile(filepath, data, (err) => {
+      if(err !== null) {
+        return reject(err);
+      }
+      resolve(data);
+    });
+  });
+}
+
+FileSystemAdapter.prototype.deleteFile = function(filename) {
+  return new Promise((resolve, reject) => {
+    let filepath = this._getLocalFilePath(filename);
+    fs.readFile( filepath , function (err, data) {
+      if(err !== null) {
+        return reject(err);
+      }
+      fs.unlink(filepath, (unlinkErr) => {
+      if(err !== null) {
+          return reject(unlinkErr);
+        }
+        resolve(data);
+      });
+    });
+
+  });
+}
+
+FileSystemAdapter.prototype.getFileData = function(filename) {
+  return new Promise((resolve, reject) => {
+    let filepath = this._getLocalFilePath(filename);
+    fs.readFile( filepath , function (err, data) {
+      if(err !== null) {
+        return reject(err);
+      }
+      resolve(data);
+    });
+  });
+}
+
+FileSystemAdapter.prototype.getFileLocation = function(config, filename) {
+  return (config.mount + '/' + this._getLocalFilePath(filename));
+}
+
+/*
+  Helpers
+ --------------- */
+ FileSystemAdapter.prototype._getApplicationDir = function() {
+  if (this._filesDir) {
+    return path.join('files', this._filesDir);
+  } else {
+    return 'files';
+  }
+ }
+
+FileSystemAdapter.prototype._applicationDirExist = function() {
+  return fs.existsSync(this._getApplicationDir());
+}
+
+FileSystemAdapter.prototype._getLocalFilePath = function(filename) {
+  let applicationDir = this._getApplicationDir();
+  if (!fs.existsSync(applicationDir)) {
+    this._mkdir(applicationDir);
+  }
+  return path.join(applicationDir, encodeURIComponent(filename));
+}
+
+FileSystemAdapter.prototype._mkdir = function(dirPath) {
+  // snippet found on -> https://gist.github.com/danherbert-epam/3960169
+  let dirs = dirPath.split(pathSep);
+  var root = "";
+
+  while (dirs.length > 0) {
+    var dir = dirs.shift();
+    if (dir === "") { // If directory starts with a /, the first path will be an empty string.
+      root = pathSep;
+    }
+    if (!fs.existsSync(path.join(root, dir))) {
+      try {
+        fs.mkdirSync(path.join(root, dir));
+      }
+      catch (e) {
+        if ( e.code == 'EACCES' ) {
+          throw new Error("PERMISSION ERROR: In order to use the FileSystemAdapter, write access to the server's file system is required.");
+        }
+      }
+    }
+    root = path.join(root, dir, pathSep);
+  }
+}
+
+module.exports = FileSystemAdapter;
+module.exports.default = FileSystemAdapter;

package.json

@@ -0,0 +1,21 @@
+{
+  "name": "parse-server-fs-adapter",
+  "version": "1.0.0",
+  "description": "File system adapter for parse-server",
+  "main": "index.js",
+  "scripts": {
+    "test": "jasmine"
+  },
+  "keywords": [
+    "parse-server",
+    "adapter",
+    "file",
+    "system"
+  ],
+  "author": "Parse",
+  "license": "MIT",
+  "dependencies": {
+    "jasmine": "^2.4.1",
+    "parse-server-conformance-tests": "^1.0.0"
+  }
+}

spec/support/jasmine.json

@@ -0,0 +1,6 @@
+{
+  "spec_dir": "spec",
+  "spec_files": [
+    "test.spec.js"
+  ]
+}

spec/test.spec.js

@@ -0,0 +1,12 @@
+'use strict';
+let filesAdapterTests = require('parse-server-conformance-tests').files;
+
+let FileSystemAdapter = require('../index.js');
+
+describe('FileSystemAdapter tests', () => {
+  var fsAdapter = new FileSystemAdapter({
+    filesSubDirectory: 'sub1/sub2'
+  });
+
+  filesAdapterTests.testAdapter("FileSystemAdapter", fsAdapter);  
+})