budibase/packages/server/src/api/controllers/plugin.ts

import { ObjectStoreBuckets } from "../../constants"
import { extractPluginTarball } from "../../utilities/fileSystem"
import { getGlobalDB } from "@budibase/backend-core/tenancy"
import { generatePluginID } from "../../db/utils"
import { uploadDirectory } from "@budibase/backend-core/objectStore"

export async function upload(ctx: any) {
  const plugins =
    ctx.request.files.file.length > 1
      ? Array.from(ctx.request.files.file)
      : [ctx.request.files.file]
  const db = getGlobalDB()
  try {
    let docs = []
    // can do single or multiple plugins
    for (let plugin of plugins) {
      const { metadata, directory } = await extractPluginTarball(plugin)
      const version = metadata.package.version,
        name = metadata.package.name,
        description = metadata.package.description

      // first open the tarball into tmp directory
      const bucketPath = `${name}/${version}/`
      const files = await uploadDirectory(
        ObjectStoreBuckets.PLUGINS,
        directory,
        bucketPath
      )
      const jsFile = files.find((file: any) => file.name.endsWith(".js"))
      if (!jsFile) {
        throw new Error(`Plugin missing .js file.`)
      }
      const jsFileName = jsFile.name
      const pluginId = generatePluginID(name, version)
      let existing
      try {
        existing = await db.get(pluginId)
      } catch (err) {
        existing = null
      }
      if (existing) {
        throw new Error(
          `Plugin already exists: name: ${name}, version: ${version}`
        )
      }
      const doc = {
        _id: pluginId,
        name,
        version,
        description,
        ...metadata,
        jsUrl: `${bucketPath}${jsFileName}`,
      }
      const response = await db.put(doc)
      docs.push({
        ...doc,
        _rev: response.rev,
      })
    }
    ctx.body = {
      message: "Plugin(s) uploaded successfully",
      plugins: docs,
    }
  } catch (err: any) {
    const errMsg = err?.message ? err?.message : err
    ctx.throw(400, `Failed to import plugin: ${errMsg}`)
  }
}

export async function fetch(ctx: any) {}

export async function destroy(ctx: any) {}