retrotoon-studio/server/_core/storageProxy.ts

import type { Express } from "express";

export function registerStorageProxy(app: Express) {
  const minioEndpoint = process.env.MINIO_ENDPOINT || "minio";
  const minioPort = process.env.MINIO_PORT || "9000";
  const bucket = process.env.MINIO_BUCKET || "retrotoon";
  const minioBase = `http://${minioEndpoint}:${minioPort}/${bucket}`;

  app.get("/storage/*", async (req, res) => {
    const key = (req.params as Record<string, string>)[0];
    if (!key) { res.status(400).send("Missing key"); return; }

    try {
      const upstream = await fetch(`${minioBase}/${key}`);
      if (!upstream.ok) { res.status(upstream.status).send("Not found"); return; }

      const contentType = upstream.headers.get("content-type") || "application/octet-stream";
      const contentLength = upstream.headers.get("content-length");

      res.set("Content-Type", contentType);
      res.set("Cache-Control", "public, max-age=86400, immutable");
      if (contentLength) res.set("Content-Length", contentLength);

      const buffer = Buffer.from(await upstream.arrayBuffer());
      res.send(buffer);
    } catch (err) {
      console.error("[StorageProxy] failed:", err);
      res.status(502).send("Storage error");
    }
  });

  // Legacy path
  app.get("/manus-storage/*", (req, res) => {
    const key = (req.params as Record<string, string>)[0];
    if (!key) { res.status(400).send("Missing key"); return; }
    res.redirect(301, `/storage/${key}`);
  });
}