Cyber Panel
5c11a289df
- Created a new Python script `uziom.py` for generating DXF drawings of grounding systems based on user input parameters. - Added detailed documentation in `wet_input_15.docx` and `wet_input_3.docx` for the design of grounding systems, including calculations for resistance and resistivity measurements. - Included placeholders for dynamic data insertion in the documents to facilitate project-specific customization.
106 lines
3.2 KiB
JavaScript
106 lines
3.2 KiB
JavaScript
import fs from "fs";
|
|
import path from "path";
|
|
// import nextConnect from 'next-connect';
|
|
// import { sendFile } from 'next/dist/server/send-file';
|
|
|
|
import formidable from "formidable";
|
|
import { spawn } from "child_process";
|
|
|
|
export const config = {
|
|
api: {
|
|
bodyParser: false,
|
|
},
|
|
};
|
|
|
|
export default async function (req, res) {
|
|
const form = new formidable.IncomingForm();
|
|
try {
|
|
form.parse(req, async (err, fields, files) => {
|
|
if (err) {
|
|
return res.status(400).json({ message: err.message });
|
|
}
|
|
|
|
console.log('doing the saving')
|
|
|
|
|
|
const { filepath, originalFilename } = files.file;
|
|
const dateNow = Date.now()
|
|
const newFilename = `${Date.now()}-${originalFilename}`;
|
|
const newPath = path.join(
|
|
process.cwd(),
|
|
"public",
|
|
"uploads",
|
|
newFilename
|
|
);
|
|
|
|
console.log('i tried so hart')
|
|
|
|
const readStream = fs.createReadStream(filepath);
|
|
const writeStream = fs.createWriteStream(newPath);
|
|
|
|
readStream.on('error', function(err) {
|
|
console.error('Error while reading file.', err);
|
|
res.status(500).send('Error while uploading file.');
|
|
});
|
|
|
|
writeStream.on('error', function(err) {
|
|
console.error('Error while writing file.', err);
|
|
res.status(500).send('Error while uploading file.');
|
|
});
|
|
|
|
writeStream.on('finish', function() {
|
|
console.log('File copied successfully');
|
|
let dataToSend;
|
|
python.stdout.on("data", function (data) {
|
|
console.log("Pipe data from python script ...");
|
|
dataToSend = data.toString();
|
|
console.log(dataToSend);
|
|
});
|
|
python.stderr.on("data", (data) => {
|
|
console.error(`stderr: ${data}`);
|
|
res.send("Py Error: " + data);
|
|
});
|
|
// in close event we are sure that stream from child process is closed
|
|
python.on("close", (code) => {
|
|
console.log(`child process close all stdio with code ${code}`);
|
|
// send data to browser
|
|
console.log(dataToSend);
|
|
console.log("done");
|
|
try {
|
|
// const handler = nextConnect();
|
|
|
|
// handler.get(async (req, res) => {
|
|
const filename = newFilename; // get the filename from the query string
|
|
const filePath = path.join(process.cwd(), 'public', 'uploads', filename);
|
|
|
|
console.log(newFilename, filename, filePath, dataToSend)
|
|
|
|
res.status(200).send({ filename: newFilename, filepath:filePath, data: dataToSend });
|
|
// sendFile(req, filePath); // send the file as a response
|
|
// });
|
|
} catch (e) {
|
|
console.log("child process end");
|
|
}
|
|
});
|
|
});
|
|
|
|
readStream.pipe(writeStream);
|
|
console.log('and got so far')
|
|
|
|
let fileName = Math.floor(Math.random() * 9999) + 1000;
|
|
|
|
console.log('starting the engines', newPath)
|
|
|
|
const python = spawn("python3", ["cross.py", 50, newPath]);
|
|
console.log('oui')
|
|
|
|
|
|
|
|
// return res.status(200).json({ message: "File uploaded successfully" });
|
|
});
|
|
} catch (err) {
|
|
console.log("err: ", err)
|
|
return res.status(500).json({ message: err.message });
|
|
}
|
|
}
|