feat: complete UI/UX improvements, vuesax icons, media server, and section management
This commit is contained in:
@@ -0,0 +1,119 @@
|
||||
import http from "node:http";
|
||||
import fs from "node:fs";
|
||||
import path from "node:path";
|
||||
import { fileURLToPath } from "node:url";
|
||||
|
||||
const __dirname = path.dirname(fileURLToPath(import.meta.url));
|
||||
const ROOT_DIR = path.resolve(__dirname, "../.s3data/imen-media");
|
||||
|
||||
if (!fs.existsSync(ROOT_DIR)) {
|
||||
fs.mkdirSync(ROOT_DIR, { recursive: true });
|
||||
}
|
||||
|
||||
const MIME_TYPES = {
|
||||
".webp": "image/webp",
|
||||
".jpg": "image/jpeg",
|
||||
".jpeg": "image/jpeg",
|
||||
".png": "image/png",
|
||||
".svg": "image/svg+xml",
|
||||
".json": "application/json",
|
||||
};
|
||||
|
||||
const server = http.createServer(async (req, res) => {
|
||||
res.setHeader("Access-Control-Allow-Origin", "*");
|
||||
res.setHeader("Access-Control-Allow-Methods", "GET, HEAD, PUT, DELETE, OPTIONS");
|
||||
res.setHeader("Access-Control-Allow-Headers", "*");
|
||||
|
||||
if (req.method === "OPTIONS") {
|
||||
res.writeHead(204);
|
||||
res.end();
|
||||
return;
|
||||
}
|
||||
|
||||
// Parse path and remove query string
|
||||
const urlObj = new URL(req.url, "http://localhost:9000");
|
||||
let pathname = decodeURIComponent(urlObj.pathname);
|
||||
|
||||
// Normalize path by stripping optional leading bucket name "/imen-media" or "/media"
|
||||
if (pathname.startsWith("/imen-media")) {
|
||||
pathname = pathname.slice("/imen-media".length);
|
||||
} else if (pathname.startsWith("/media")) {
|
||||
pathname = pathname.slice("/media".length);
|
||||
}
|
||||
|
||||
if (pathname === "" || pathname === "/") {
|
||||
res.writeHead(200, { "Content-Type": "application/xml" });
|
||||
res.end("<BucketResponse>OK</BucketResponse>");
|
||||
return;
|
||||
}
|
||||
|
||||
const safePath = path.normalize(pathname).replace(/^(\.\.[\/\\])+/, "");
|
||||
const filePath = path.join(ROOT_DIR, safePath);
|
||||
|
||||
if (req.method === "HEAD") {
|
||||
if (fs.existsSync(filePath)) {
|
||||
const stat = fs.statSync(filePath);
|
||||
const ext = path.extname(filePath).toLowerCase();
|
||||
res.writeHead(200, {
|
||||
"Content-Type": MIME_TYPES[ext] || "application/octet-stream",
|
||||
"Content-Length": stat.size,
|
||||
});
|
||||
res.end();
|
||||
} else {
|
||||
// Bucket check or file check
|
||||
res.writeHead(200);
|
||||
res.end();
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
if (req.method === "GET") {
|
||||
if (fs.existsSync(filePath) && fs.statSync(filePath).isFile()) {
|
||||
const ext = path.extname(filePath).toLowerCase();
|
||||
const contentType = MIME_TYPES[ext] || "application/octet-stream";
|
||||
res.writeHead(200, {
|
||||
"Content-Type": contentType,
|
||||
"Cache-Control": "public, max-age=31536000, immutable",
|
||||
});
|
||||
fs.createReadStream(filePath).pipe(res);
|
||||
} else {
|
||||
res.writeHead(404, { "Content-Type": "text/plain" });
|
||||
res.end(`File not found: ${pathname}`);
|
||||
}
|
||||
return;
|
||||
}
|
||||
|
||||
if (req.method === "PUT") {
|
||||
fs.mkdirSync(path.dirname(filePath), { recursive: true });
|
||||
const writeStream = fs.createWriteStream(filePath);
|
||||
req.pipe(writeStream);
|
||||
writeStream.on("finish", () => {
|
||||
res.writeHead(200, { ETag: '"local-etag"' });
|
||||
res.end();
|
||||
});
|
||||
writeStream.on("error", (err) => {
|
||||
res.writeHead(500, { "Content-Type": "text/plain" });
|
||||
res.end(err.message);
|
||||
});
|
||||
return;
|
||||
}
|
||||
|
||||
if (req.method === "DELETE") {
|
||||
if (fs.existsSync(filePath)) {
|
||||
try {
|
||||
fs.unlinkSync(filePath);
|
||||
} catch {}
|
||||
}
|
||||
res.writeHead(204);
|
||||
res.end();
|
||||
return;
|
||||
}
|
||||
|
||||
res.writeHead(405);
|
||||
res.end();
|
||||
});
|
||||
|
||||
const PORT = 9000;
|
||||
server.listen(PORT, "0.0.0.0", () => {
|
||||
console.log(`Media storage server listening on http://0.0.0.0:${PORT} (serving ${ROOT_DIR})`);
|
||||
});
|
||||
Reference in New Issue
Block a user