hedgedoc/lib/web/imageRouter/minio.ts

import path from 'path'
import fs from 'fs'
import Minio from 'minio'

import { config } from '../../config'
import { getImageMimeType } from '../../utils'
import { logger } from '../../logger'
import { UploadProvider } from './index'

const minioClient = new Minio.Client({
  endPoint: config.minio.endPoint,
  port: config.minio.port,
  useSSL: config.minio.secure,
  accessKey: config.minio.accessKey,
  secretKey: config.minio.secretKey
})

const MinioUploadProvider: UploadProvider = {
  uploadImage: (imagePath, callback) => {
    if (!imagePath) {
      callback(new Error('Image path is missing or wrong'), undefined)
      return
    }

    if (!callback || typeof callback !== 'function') {
      logger.error('Callback has to be a function')
      return
    }

    fs.readFile(imagePath, function (err, buffer) {
      if (err) {
        callback(new Error(err.message), undefined)
        return
      }

      const key = path.join('uploads', path.basename(imagePath))
      const protocol = config.minio.secure ? 'https' : 'http'

      minioClient.putObject(config.s3bucket, key, buffer, buffer.length, getImageMimeType(imagePath), function (err, _) {
        if (err) {
          callback(new Error(err.message), undefined)
          return
        }
        const hidePort = [80, 443].includes(config.minio.port)
        const urlPort = hidePort ? '' : `:${config.minio.port}`
        callback(undefined, `${protocol}://${config.minio.endPoint}${urlPort}/${config.s3bucket}/${key}`)
      })
    })
  }
}

export { MinioUploadProvider }