local-provider.ts

import { UploadedFile } from 'adminjs'
import fs, { existsSync } from 'fs'
import path from 'path'
import { ERROR_MESSAGES } from '../constants.js'
import { BaseProvider, ProviderOpts } from './base-provider.js'

/**
 * Options required by the LocalAdapter
 *
 * @memberof module:@adminjs/upload
 */
export type LocalUploadOptions = {
  /**
   * Path where files will be stored. For example: `path.join(__dirname, '../public')`
   */
  bucket: string;

  /**
   * options for local provider
   */
  opts?: ProviderOpts;
};

export class LocalProvider extends BaseProvider {
  constructor(options: LocalUploadOptions) {
    super(options.bucket, options?.opts)
    if (!existsSync(options.bucket)) {
      throw new Error(ERROR_MESSAGES.NO_DIRECTORY(options.bucket))
    }
  }

  public async upload(file: UploadedFile, key: string): Promise<any> {
    const filePath = process.platform === 'win32' ? this.path(key) : this.path(key).slice(1) // adjusting file path according to OS

    await fs.promises.mkdir(path.dirname(filePath), { recursive: true })
    await fs.promises.rename(file.path, filePath)
  }

  public async delete(key: string, bucket: string): Promise<any> {
    const fileLink = process.platform === 'win32'
      ? this.path(key, bucket)
      : this.path(key, bucket).slice(1)
    if (fs.existsSync(fileLink)) {
      await fs.promises.unlink(fileLink)
    }
  }

  // eslint-disable-next-line class-methods-use-this
  public path(key: string, bucket?: string): string {
    // Windows doesn't requires the '/' in path, while UNIX system does
    return process.platform === 'win32'
      ? `${path.join(bucket || this.bucket, key)}`
      : `/${path.join(bucket || this.bucket, key)}`
  }
}