feat: azure blob storage provider + s3 rename fix

package.json

@@ -36,6 +36,7 @@
   },
   "dependencies": {
     "@aoberoi/passport-slack": "1.0.5",
+    "@azure/storage-blob": "12.0.1",
     "@bugsnag/js": "6.4.3",
     "@exlinc/keycloak-passport": "1.0.2",
     "algoliasearch": "3.35.1",

server/modules/storage/azure/definition.yml

@@ -4,7 +4,43 @@ description: Azure Blob Storage by Microsoft provides massively scalable object
 author: requarks.io
 logo: https://static.requarks.io/logo/azure.svg
 website: https://azure.microsoft.com/services/storage/blobs/
+isAvailable: true
+supportedModes:
+  - push
+defaultMode: push
+schedule: false
 props:
-  accountName: String
-  accountKey: String
-  container: String
+  accountName:
+    type: String
+    title: Account Name
+    default: ''
+    hint: Your unique account name.
+    order: 1
+  accountKey:
+    type: String
+    title: Account Access Key
+    default: ''
+    hint: Either key 1 or key 2.
+    order: 2
+  containerName:
+    type: String
+    title: Container Name
+    default: 'wiki'
+    hint: Will automatically be created if it doesn't exist yet.
+    order: 3
+  storageTier:
+    type: String
+    title: Storage Tier
+    hint: Represents the access tier on a blob. Use Cool for lower storage costs but at higher retrieval costs.
+    order: 4
+    default: 'Cool'
+    enum:
+        - 'Hot'
+        - 'Cool'
+actions:
+  - handler: exportAll
+    label: Export All
+    hint: Output all content from the DB to Azure Blog Storage, overwriting any existing data. If you enabled Azure Blog Storage after content was created or you temporarily disabled Git, you'll want to execute this action to add the missing content.
+  - handler: importAll
+    label: Import Everything
+    hint: Will import all content currently in Azure Blog Storage. Useful for importing or restoring content from a previously backed up state.

server/modules/storage/azure/storage.js

+const { BlobServiceClient, StorageSharedKeyCredential } = require('@azure/storage-blob')
+const pageHelper = require('../../../helpers/page.js')
+
+/* global WIKI */
+
+const getFilePath = (page, pathKey) => {
+  const fileName = `${page[pathKey]}.${pageHelper.getFileExtension(page.contentType)}`
+  const withLocaleCode = WIKI.config.lang.namespacing && WIKI.config.lang.code !== page.localeCode
+  return withLocaleCode ? `${page.localeCode}/${fileName}` : fileName
+}
+
 module.exports = {
   async activated() {
 
@@ -6,18 +17,98 @@ module.exports = {
 
   },
   async init() {
-
+    WIKI.logger.info(`(STORAGE/AZURE) Initializing...`)
+    const { accountName, accountKey, containerName } = this.config
+    this.client = new BlobServiceClient(
+      `https://${accountName}.blob.core.windows.net`,
+      new StorageSharedKeyCredential(accountName, accountKey)
+    )
+    this.container = this.client.getContainerClient(containerName)
+    try {
+      await this.container.create()
+    } catch (err) {
+      if (err.statusCode !== 409) {
+        WIKI.logger.warn(err)
+        throw err
+      }
+    }
+    WIKI.logger.info(`(STORAGE/AZURE) Initialization completed.`)
   },
-  async created() {
-
+  async created (page) {
+    WIKI.logger.info(`(STORAGE/AZURE) Creating file ${page.path}...`)
+    const filePath = getFilePath(page, 'path')
+    const pageContent = page.injectMetadata()
+    const blockBlobClient = this.container.getBlockBlobClient(filePath)
+    await blockBlobClient.upload(pageContent, pageContent.length, { tier: this.config.storageTier })
   },
-  async updated() {
-
+  async updated (page) {
+    WIKI.logger.info(`(STORAGE/AZURE) Updating file ${page.path}...`)
+    const filePath = getFilePath(page, 'path')
+    const pageContent = page.injectMetadata()
+    const blockBlobClient = this.container.getBlockBlobClient(filePath)
+    await blockBlobClient.upload(pageContent, pageContent.length, { tier: this.config.storageTier })
   },
-  async deleted() {
-
+  async deleted (page) {
+    WIKI.logger.info(`(STORAGE/AZURE) Deleting file ${page.path}...`)
+    const filePath = getFilePath(page, 'path')
+    const blockBlobClient = this.container.getBlockBlobClient(filePath)
+    await blockBlobClient.delete({
+      deleteSnapshots: 'include'
+    })
   },
-  async renamed() {
-
+  async renamed(page) {
+    WIKI.logger.info(`(STORAGE/${this.storageName}) Renaming file ${page.path} to ${page.destinationPath}...`)
+    let sourceFilePath = getFilePath(page, 'path')
+    let destinationFilePath = getFilePath(page, 'destinationPath')
+    if (WIKI.config.lang.namespacing) {
+      if (WIKI.config.lang.code !== page.localeCode) {
+        sourceFilePath = `${page.localeCode}/${sourceFilePath}`
+      }
+      if (WIKI.config.lang.code !== page.destinationLocaleCode) {
+        destinationFilePath = `${page.destinationLocaleCode}/${destinationFilePath}`
+      }
+    }
+    const sourceBlockBlobClient = this.container.getBlockBlobClient(sourceFilePath)
+    const destBlockBlobClient = this.container.getBlockBlobClient(destinationFilePath)
+    await destBlockBlobClient.syncCopyFromURL(sourceBlockBlobClient.url)
+    await sourceBlockBlobClient.delete({
+      deleteSnapshots: 'include'
+    })
+  },
+  /**
+   * ASSET UPLOAD
+   *
+   * @param {Object} asset Asset to upload
+   */
+  async assetUploaded (asset) {
+    WIKI.logger.info(`(STORAGE/AZURE) Creating new file ${asset.path}...`)
+    const blockBlobClient = this.container.getBlockBlobClient(asset.path)
+    await blockBlobClient.upload(asset.data, asset.data.length, { tier: this.config.storageTier })
+  },
+  /**
+   * ASSET DELETE
+   *
+   * @param {Object} asset Asset to delete
+   */
+  async assetDeleted (asset) {
+    WIKI.logger.info(`(STORAGE/AZURE) Deleting file ${asset.path}...`)
+    const blockBlobClient = this.container.getBlockBlobClient(asset.path)
+    await blockBlobClient.delete({
+      deleteSnapshots: 'include'
+    })
+  },
+  /**
+   * ASSET RENAME
+   *
+   * @param {Object} asset Asset to rename
+   */
+  async assetRenamed (asset) {
+    WIKI.logger.info(`(STORAGE/AZURE) Renaming file from ${asset.path} to ${asset.destinationPath}...`)
+    const sourceBlockBlobClient = this.container.getBlockBlobClient(asset.path)
+    const destBlockBlobClient = this.container.getBlockBlobClient(asset.destinationPath)
+    await destBlockBlobClient.syncCopyFromURL(sourceBlockBlobClient.url)
+    await sourceBlockBlobClient.delete({
+      deleteSnapshots: 'include'
+    })
   }
 }

server/modules/storage/s3/common.js

@@ -57,8 +57,8 @@ module.exports = class S3CompatibleStorage {
   }
   async renamed(page) {
     WIKI.logger.info(`(STORAGE/${this.storageName}) Renaming file ${page.path} to ${page.destinationPath}...`)
-    let sourceFilePath = `${page.path}.${page.getFileExtension()}`
-    let destinationFilePath = `${page.destinationPath}.${page.getFileExtension()}`
+    let sourceFilePath = getFilePath(page, 'path')
+    let destinationFilePath = getFilePath(page, 'destinationPath')
     if (WIKI.config.lang.namespacing) {
       if (WIKI.config.lang.code !== page.localeCode) {
         sourceFilePath = `${page.localeCode}/${sourceFilePath}`