Cloud file storage #256

packages/azure_file_storage/bootstrap.js

@@ -0,0 +1,43 @@
+const { addProcessor } = require('@evershop/evershop/src/lib/util/registry');
+const { azureFileUploader } = require('./services/azureFileUploader');
+const { azureFileDeleter } = require('./services/azureFileDeleter');
+const { azureFolderCreator } = require('./services/azureFolderCreator');
+const { azureFileBrowser } = require('./services/azureFileBrowser');
+
+module.exports = () => {
+  addProcessor('fileUploader', function (value) {
+    const {config} = this;
+    if (config === 'azure') {
+      return azureFileUploader;
+    } else {
+      return value;
+    }
+  });
+
+  addProcessor('fileDeleter', function (value) {
+    const {config} = this;
+    if (config === 'azure') {
+      return azureFileDeleter;
+    } else {
+      return value;
+    }
+  });
+
+  addProcessor('folderCreator', function (value) {
+    const {config} = this;
+    if (config === 'azure') {
+      return azureFolderCreator;
+    } else {
+      return value;
+    }
+  });
+
+  addProcessor('fileBrowser', function (value) {
+    const {config} = this;
+    if (config === 'azure') {
+      return azureFileBrowser;
+    } else {
+      return value;
+    }
+  });
+};

packages/azure_file_storage/services/azureFileBrowser.js

@@ -0,0 +1,50 @@
+const { BlobServiceClient } = require('@azure/storage-blob');
+const { getEnv } = require('@evershop/evershop/src/lib/util/getEnv');
+
+module.exports.azureFileBrowser = {
+  list: async (path) => {
+    const blobServiceClient = BlobServiceClient.fromConnectionString(
+      getEnv('AZURE_STORAGE_CONNECTION_STRING')
+    );
+    const containerName = getEnv('AZURE_STORAGE_CONTAINER_NAME', 'images');
+    const containerClient = blobServiceClient.getContainerClient(containerName);
+    // Create a container if it does not exist with access level set to public
+    await containerClient.createIfNotExists({
+      access: 'blob'
+    });
+
+    if (path !== '') {
+      // eslint-disable-next-line no-param-reassign
+      path = `${path}/`;
+    }
+    const blobs = containerClient.listBlobsFlat({ prefix: path });
+    const subfolders = new Set();
+    const files = [];
+    // eslint-disable-next-line no-restricted-syntax
+    for await (const blob of blobs) {
+      const blobName = blob.name;
+      const blobUrl = `${containerClient.url}/${blobName}`;
+      const relativePath = blobName.substring(path.length);
+      const slashIndex = relativePath.indexOf('/');
+      if (slashIndex === -1) {
+        // It's a file
+        if (blob.properties.contentLength) {
+          files.push({
+            name: relativePath,
+            url: blobUrl
+          });
+        }
+      } else {
+        // It's a subfolder
+        const subfolder = relativePath.substring(0, slashIndex);
+        if (subfolder !== '') {
+          subfolders.add(subfolder);
+        }
+      }
+    }
+    return {
+      folders: Array.from(subfolders),
+      files
+    };
+  }
+};

packages/azure_file_storage/services/azureFileDeleter.js

@@ -0,0 +1,20 @@
+const { BlobServiceClient } = require('@azure/storage-blob');
+const { getEnv } = require('@evershop/evershop/src/lib/util/getEnv');
+
+module.exports.azureFileDeleter = {
+  delete: async (path) => {
+    const blobServiceClient = BlobServiceClient.fromConnectionString(
+      getEnv('AZURE_STORAGE_CONNECTION_STRING')
+    );
+    const containerName = getEnv('AZURE_STORAGE_CONTAINER_NAME', 'images');
+    const containerClient = blobServiceClient.getContainerClient(containerName);
+    const blobClient = containerClient.getBlobClient(path);
+    const blobProperties = await blobClient.getProperties();
+
+    if (blobProperties.contentType) {
+      await blobClient.delete();
+    } else {
+      throw new Error(`Path "${path}" does not exist.`);
+    }
+  }
+};