expressjs/express

var express = require('express');
require('dotenv').config();
var cors = require('cors');
var mysql = require('mysql');
var bodyParser = require('body-parser');
var http = require('http');
var app = express();
var multer = require('multer');
const path = require('path');
const fs = require('fs')
//var upload = multer({ dest: 'uploads/', limits: { fieldSize: 10000000000 } }).any()

// building storage engine cb --> callback
app.use(bodyParser.urlencoded({ extended: false }));
app.use(bodyParser.json());
app.use(bodyParser.raw({ type: 'audio/wav', limit: '60mb' }))
app.use(cors());

app.use(express.static('./public'));

const storage = multer.diskStorage({
destination: './public/uploads/',
filename: function (req, file, cb) {
cb(null, file.fieldname + '-' + Date.now() + path.extname(file.originalname));
}
});

// Init upload
const upload = multer({
storage: storage,
limits: { fileSize: 100000000 },
fileFilter: function (req, file, cb) {
checkFileType(file, cb);
}
}).single('studentAudio');

// checking the extension and mimeType
function checkFileType(file, cb) {

const fileTypes = /wav/;
// checking extension
const extensionName = fileTypes.test(path.extname(file.originalname).toLowerCase());
// checking mimeType

console.log(file.mimetype === "audio/wav" && extensionName);

if (file.mimetype === "audio/wav" && extensionName) {
    return cb(null, true);
} else {
    cb('Just audio files allowed!!')
}

}

function parseMovementData(movStr) {
var result = movStr.split(" ");
var values = [];
var i;
for (i = 0; i < result.length; i++) {
var numStr = result[i].slice(result[i].lastIndexOf(':') + 1);
var numVal = parseFloat(numStr);
values.push(numVal);
}

return values;

}

// var jsonObj = convertToText(req.file.path, req.filename, req.body.date);
//"../data/test.csv"
//convertToText("public/uploads/test2.wav", "AudioText6test", "2020-05-11 16:04:22");
// function convertToText(audioPath, filename, date) {
// const spawn = require('child_process').spawn;
// const scriptExecution = spawn("python", ["audioTranscribe.py"])
// var info = [audioPath, date];
// var text;
// scriptExecution.stdout.on('data', function (data) {
// var text = data.toString()
// console.log("Here: " + data.toString());
// // saving transcribed files into transcriptions folder
// fs.writeFile('./transcriptions/' + filename + '.txt', text, function (err) {
// if (err) {
// return console.log(err)
// }
// console.log("File created!")
// })

// });
// scriptExecution.stdin.write(JSON.stringify(info));
// scriptExecution.stdin.end();
// }

// connection to interventions_db

var connection = mysql.createConnection({
host: process.env.DB_HOST,
user: process.env.DB_USER,
password: process.env.DB_PASS,
database: process.env.DB_DATABASE,
port: process.env.DB_PORT
})

var signalsConnection = mysql.createConnection({
host: process.env.DB_SIG_HOST,
user: process.env.DB_SIG_USER,
password: process.env.DB_SIG_PASS,
database: process.env.DB_SIG_DATABASE,
port: process.env.DB_SIG_PORT
})

var outputConnection = mysql.createConnection({
host: process.env.DB_OUT_HOST,
user: process.env.DB_OUT_USER,
password: process.env.DB_OUT_PASS,
database: process.env.DB_OUT_DATABASE,
port: process.env.DB_OUT_PORT
})

app.post('/interventions', function (req, res) {
const intervention = {
interventionType: req.body.interventionType,
place: req.body.place,
students: req.body.students,
date: req.body.date,
time: req.body.time,
severity: req.body.severity,
teachers: req.body.teachers
}

var q = "INSERT INTO interventions SET ?;";

connection.query(q, intervention, function (error, result) {
    if (error) throw error;
    console.log(result);
    res.send("Posted to DB");
})
console.log