noe/bliss
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

feat: add file lib to routes, abstract out file upload functionality

Browse source
This commit is contained in:
Your Name 2025-01-31 10:38:28 -05:00
parent a680ff9120
commit 19a9d63d6c
2 changed files with 38 additions and 31 deletions
Download patch file Download diff file Expand all files Collapse all files

67
index.js
View file

@ -54,6 +54,31 @@ webPush.setVapidDetails(
vapidPrivateKey,
);
async function saveFile(structureId, req, uploadedFile, asset=false) {
const name = uploadedFile.name;
const [mime_type, mime_subtype] = uploadedFile.mimetype.split("/");
const uploadPath = path.join(__dirname, "public", structureId);
const storedPath = path.join(structureId, uploadedFile.name);
fs.mkdirSync(uploadPath, { recursive: true });
await uploadedFile.mv(path.join(uploadPath, name));
let id = model.createFile(
db,
structureId,
name,
storedPath,
mime_type,
mime_subtype,
asset,
);
let file = model.getFile(db, id);
file.url = prefixUrlWithHost(req, file.path);
return file
}
function bootstrapContext(db, structureId, routeId, initContext) {
const allDbInstances = {};
function getDb(alias) {
@ -64,7 +89,7 @@ function bootstrapContext(db, structureId, routeId, initContext) {
// for now just designing with component approach
const eta = model.getTemplater(structureId);
const libs = { eta, db: getDb, push: webPush };
const libs = { eta, db: getDb, push: webPush, files: { saveFile: (...args) => saveFile(structureId, ...args) } };
let dbs = model.getDbsForStructure(db, structureId);
let context = vm.createContext({
@ -693,44 +718,24 @@ app.get("/workshop/:structure_id/route/:route_id/logs", (req, res) => {
});
// POST route to handle file upload
app.post("/workshop/:structure_id/files", (req, res) => {
app.post("/workshop/:structure_id/files", async (req, res) => {
if (!req.files || Object.keys(req.files).length === 0) {
return res.status(400).send("failed to upload that file");
}
const { structure_id } = req.params;
const file = req.files.file;
const name = file.name;
const [mime_type, mime_subtype] = file.mimetype.split("/");
const uploadPath = path.join(__dirname, "public", structure_id);
const storedPath = path.join(structure_id, file.name);
const targetFile = req.files.file;
fs.mkdirSync(uploadPath, { recursive: true });
file.mv(path.join(uploadPath, name), (err) => {
try {
if (err) {
return res.status(500).send(err);
}
let id = model.createFile(
db,
structure_id,
name,
storedPath,
mime_type,
mime_subtype,
);
let file = model.getFile(db, id);
file.url = prefixUrlWithHost(req, file.path);
return res.send(eta.render("workshop/file_detail", { file: file }));
} catch (e) {
try {
const uploadedFile = await saveFile(structure_id, req, targetFile)
return res.send(eta.render("workshop/file_detail", { file: uploadedFile }));
}
catch (e) {
console.log(e)
res.status(500);
return res.send(e);
}
});
}
});
function prefixUrlWithHost(req, path) {