import { S3Client, PutObjectCommand, DeleteObjectCommand } from "@aws-sdk/client-s3"; import { getSignedUrl } from "@aws-sdk/s3-request-presigner"; const bucket = process.env["STORAGE_BUCKET"] || "epicure-uploads"; const endpoint = process.env["STORAGE_ENDPOINT"] || "http://localhost:9000"; const publicUrl = process.env["STORAGE_PUBLIC_URL"] || "http://localhost:9000"; // getPublicUrl() below runs in the browser too — non-NEXT_PUBLIC_ vars are never // inlined into the client bundle, so it needs its own NEXT_PUBLIC_ copy of the value. const clientPublicUrl = process.env.NEXT_PUBLIC_STORAGE_PUBLIC_URL || "http://localhost:9000"; const credentials = { accessKeyId: process.env["STORAGE_ACCESS_KEY"] ?? "minioadmin", secretAccessKey: process.env["STORAGE_SECRET_KEY"] ?? "minioadmin", }; const s3 = new S3Client({ region: process.env["STORAGE_REGION"] ?? "us-east-1", endpoint, forcePathStyle: true, credentials, }); // Presigned URLs are PUT/GET directly by the browser, so they must be signed // against an endpoint the browser can actually resolve — not the internal // docker hostname `s3` (and `endpoint`) use for server-to-server calls. Signing // is pure crypto (no network call), so a second client pointed at the public // URL is safe even though it's never used to make a real request itself. const presignS3 = new S3Client({ region: process.env["STORAGE_REGION"] ?? "us-east-1", endpoint: publicUrl, forcePathStyle: true, credentials, }); export async function createPresignedUploadUrl(key: string, contentType: string): Promise { const command = new PutObjectCommand({ Bucket: bucket, Key: key, ContentType: contentType }); return getSignedUrl(presignS3, command, { expiresIn: 300 }); } export async function deleteObject(key: string): Promise { await s3.send(new DeleteObjectCommand({ Bucket: bucket, Key: key })); } export function getPublicUrl(key: string): string { return `${clientPublicUrl}/${bucket}/${key}`; }