jws-backend/src/utils/minio.ts

import { buffer } from "node:stream/consumers";
import minio from "../services/minio";

if (!process.env.MINIO_BUCKET) {
  throw Error("Require MinIO bucket.");
}

const MINIO_BUCKET = process.env.MINIO_BUCKET;

export async function listFile(path: string) {
  return await new Promise<string[]>((resolve, reject) => {
    const item: string[] = [];

    const stream = minio.listObjectsV2(MINIO_BUCKET, path);

    stream.on("data", (v) => v && v.name && item.push(v.name.split("/").at(-1) || ""));
    stream.on("end", () => resolve(item));
    stream.on("error", () => reject(new Error("MinIO error.")));
  });
}

export async function getPresigned(method: string, path: string, exp = 60 * 60) {
  return await minio.presignedUrl(method, MINIO_BUCKET, path, exp);
}

export async function getFile(path: string, exp = 60 * 60) {
  return await minio.presignedGetObject(MINIO_BUCKET, path, exp);
}

export async function getFileBuffer(path: string) {
  return await minio.getObject(MINIO_BUCKET, path).then(buffer);
}

export async function setFile(path: string, exp = 6 * 60 * 60) {
  return await minio.presignedPutObject(MINIO_BUCKET, path, exp);
}

export async function deleteFile(path: string) {
  await minio.removeObject(MINIO_BUCKET, path, { forceDelete: true });
}

export async function deleteFolder(path: string) {
  new Promise<string[]>((resolve, reject) => {
    const item: string[] = [];

    const stream = minio.listObjectsV2(MINIO_BUCKET, path, true);

    stream.on("data", (v) => v && v.name && item.push(v.name));
    stream.on("end", () => resolve(item));
    stream.on("error", () => reject(new Error("MinIO error.")));
  }).then((list) => {
    list.map(async (v) => {
      await minio.removeObject(MINIO_BUCKET, v, { forceDelete: true });
    });
  });
}

const ROOT = ".system";

export const fileLocation = {
  branch: {
    line: (branchId: string) => `${ROOT}/branch/line-qr-${branchId}`,
    bank: (branchId: string, bankId: string) => `${ROOT}/branch/bank-qr-${branchId}-${bankId}`,
    img: (branchId: string, name?: string) => `${ROOT}/branch/img-${branchId}/${name || ""}`,
    attachment: (branchId: string, name?: string) =>
      `${ROOT}/branch/attachment-${branchId}/${name || ""}`,
  },
  user: {
    profile: (userId: string, name?: string) =>
      `${ROOT}/user/profile-image-${userId}/${name || ""}`,
    attachment: (userId: string, name?: string) =>
      `${ROOT}/user/attachment-${userId}/${name || ""}`,
  },
  customer: {
    img: (customerId: string, name?: string) => `${ROOT}/customer/img-${customerId}/${name || ""}`,
  },
  customerBranch: {
    attachment: (customerBranchId: string, name?: string) =>
      `${ROOT}/customer-branch/attachment-${customerBranchId}/${name || ""}`,
    citizen: (customerBranchId: string, citizenId?: string) =>
      `${ROOT}/customer-branch/citizen-${customerBranchId}/${citizenId || ""}`,
    houseRegistration: (customerBranchId: string, houseRegistrationId?: string) =>
      `${ROOT}/customer-branch/house-registration-${customerBranchId}/${houseRegistrationId || ""}`,
    commercialRegistration: (customerBranchId: string, commercialRegistrationId?: string) =>
      `${ROOT}/customer-branch/commercial-registration-${customerBranchId}/${commercialRegistrationId || ""}`,
    vatRegistration: (customerBranchId: string, vatRegistrationId?: string) =>
      `${ROOT}/customer-branch/vat-registration-${customerBranchId}/${vatRegistrationId || ""}`,
    powerOfAttorney: (customerBranchId: string, powerOfAttorneyId?: string) =>
      `${ROOT}/customer-branch/power-of-attorney-${customerBranchId}/${powerOfAttorneyId || ""}`,
  },
  employee: {
    img: (employeeId: string, name?: string) => `${ROOT}/employee/img-${employeeId}/${name || ""}`,
    attachment: (employeeId: string, name?: string) =>
      `${ROOT}/employee/attachment-${employeeId}/${name || ""}`,
    visa: (employeeId: string, visaId?: string) =>
      `${ROOT}/employee/visa-${employeeId}/${visaId || ""}`,
    passport: (employeeId: string, passportId?: string) =>
      `${ROOT}/employee/passport-${employeeId}/${passportId || ""}`,
    inCountryNotice: (employeeId: string, noticeId?: string) =>
      `${ROOT}/employee/in-country-notice-${employeeId}/${noticeId || ""}`,
  },
  product: {
    img: (productId: string, name?: string) => `${ROOT}/product/img-${productId}/${name || ""}`,
  },
  service: {
    img: (serviceId: string, name?: string) => `${ROOT}/service/img-${serviceId}/${name || ""}`,
  },
  quotation: {
    attachment: (quotationId: string, name?: string) =>
      `${ROOT}/quotation/attachment-${quotationId}/${name || ""}`,
    payment: (quotationId: string, paymentId: string, name?: string) =>
      `${ROOT}/quotation/payment-${quotationId}/${paymentId}/${name || ""}`,
  },
  request: {
    attachment: (requestId: string, step: number, name?: string) =>
      `${ROOT}/request/attachment-${requestId}-${step}/${name || ""}`,
  },
  institution: {
    attachment: (institutionId: string, name?: string) =>
      `${ROOT}/institution/attachment-${institutionId}/${name || ""}`,
    img: (institutionId: string, name?: string) =>
      `${ROOT}/institution/img-${institutionId}/${name || ""}`,
  },
  task: {
    attachment: (taskId: string, name?: string) =>
      `${ROOT}/task/attachment-${taskId}/${name || ""}`,
  },
  creditNote: {
    slip: (creditNoteId: string, name?: string) =>
      `${ROOT}/credit-note/slip-${creditNoteId}/${name || ""}`,
    attachment: (creditNoteId: string, name?: string) =>
      `${ROOT}/credit-note/attachment-${creditNoteId}/${name || ""}`,
  },
};