initLocalStorageServer(options)

import express from 'express';
import { initLocalStorageServer } from '@blocklet/uploader-server';
import Upload from '../models/upload'; // データベースモデル

const router = express.Router();

// uploaderサーバーミドルウェアを初期化
const localStorageServer = initLocalStorageServer({
  // アップロードされたファイルが保存されるディレクトリ
  path: process.env.UPLOAD_DIR,
  express,

  // このコールバックはファイルが正常にアップロードされた後に実行されます
  onUploadFinish: async (req, res, uploadMetadata) => {
    const {
      id: filename, // ディスク上の一意でランダム化されたファイル名
      size,
      metadata: { filename: originalname, filetype: mimetype },
    } = uploadMetadata;

    // アップロードされたファイルの公開URLを構築
    const fileUrl = new URL(process.env.APP_URL);
    fileUrl.pathname = `/uploads/${filename}`;

    // ファイル情報をデータベースに保存
    const doc = await Upload.insert({
      mimetype,
      originalname,
      filename,
      size,
      url: fileUrl.href,
      createdAt: new Date().toISOString(),
      updatedAt: new Date().toISOString(),
      createdBy: req.user.did,
    });

    // データベースドキュメントをJSONレスポンスとして返す
    // このデータはフロントエンドのonUploadFinishコールバックに渡されます
    return doc;
  },
});

// '/uploads' ルートにミドルウェアをマウント
// 必要な認証/認可ミドルウェアがその前に実行されることを確認
router.use('/uploads', yourAuthMiddleware, localStorageServer.handle);

export default router;

import { localStorageServer } from './setup'; // インスタンスをエクスポートしたと仮定

async function deleteFile(filename) {
  try {
    await localStorageServer.delete(filename);
    console.log(`Successfully deleted ${filename}`);
  } catch (error) {
    console.error(`Failed to delete ${filename}:`, error);
  }
}