vodorod/parcer
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

refactor: remove all code related to fs

Browse Source
This commit is contained in:
karishmas6
2024-10-10 04:34:04 +05:30
parent eb7e2459ee
commit 3c226d0791
1 changed files with 1 additions and 22 deletions
Download Patch File Download Diff File Expand all files Collapse all files

21
server/src/routes/storage.ts
View File

@@ -143,15 +143,6 @@ router.put('/runs/:id', requireSignIn, async (req, res) => {
console.log(`Created run (plain object):`, plainRun); console.log(`Created run (plain object):`, plainRun);
// // we need to handle this via DB
// fs.mkdirSync('../storage/runs', { recursive: true })
// await saveFile(
// `../storage/runs/${req.params.fileName}_${runId}.json`,
// JSON.stringify({ ...run_meta }, null, 2)
// );
// logger.log('debug', `Created run with name: ${req.params.fileName}.json`);
// console.log('Run meta:', run_meta);
return res.send({ return res.send({
browserId: id, browserId: id,
runId: plainRun.runId, runId: plainRun.runId,
@@ -171,7 +162,6 @@ router.get('/runs/run/:id', requireSignIn, async (req, res) => {
console.log(`Params for GET /runs/run/:id`, req.params.id) console.log(`Params for GET /runs/run/:id`, req.params.id)
// read the run from storage // read the run from storage
const run = await Run.findOne({ where: { runId: req.params.runId }, raw: true }); const run = await Run.findOne({ where: { runId: req.params.runId }, raw: true });
//const parsedRun = JSON.parse(run);
if (!run) { if (!run) {
return res.status(404).send(null); return res.status(404).send(null);
} }
@@ -188,11 +178,6 @@ router.get('/runs/run/:id', requireSignIn, async (req, res) => {
*/ */
router.post('/runs/run/:id', requireSignIn, async (req, res) => { router.post('/runs/run/:id', requireSignIn, async (req, res) => {
try { try {
// const recording = await readFile(`./../storage/recordings/${req.params.fileName}.json`)
// const parsedRecording = JSON.parse(recording);
// const run = await readFile(`./../storage/runs/${req.params.fileName}_${req.params.runId}.json`)
// const parsedRun = JSON.parse(run);
console.log(`Params for POST /runs/run/:id`, req.params.id) console.log(`Params for POST /runs/run/:id`, req.params.id)
const run = await Run.findOne({ where: { runId: req.params.id } }); const run = await Run.findOne({ where: { runId: req.params.id } });
@@ -371,12 +356,6 @@ router.post('/runs/abort/:id', requireSignIn, async (req, res) => {
serializableOutput, serializableOutput,
binaryOutput, binaryOutput,
}); });
// fs.mkdirSync('../storage/runs', { recursive: true })
// await saveFile(
// `../storage/runs/${run.name}_${req.params.runId}.json`,
// JSON.stringify({ ...run_meta, serializableOutput, binaryOutput }, null, 2)
// );
return res.send(true); return res.send(true);
} catch (e) { } catch (e) {
const { message } = e as Error; const { message } = e as Error;