Unlimited db connections

This commit is contained in:
Christopher Cookman 2024-12-22 17:49:10 -07:00
parent 38f2c632bb
commit f6414f9858
2 changed files with 9 additions and 3 deletions

View file

@ -21,8 +21,8 @@ const pool = mariadb.createPool({
port: process.env.DB_PORT || 3306, port: process.env.DB_PORT || 3306,
user: process.env.DB_USER, // Replace with your database username user: process.env.DB_USER, // Replace with your database username
password: process.env.DB_PASS, // Replace with your database password password: process.env.DB_PASS, // Replace with your database password
database: process.env.DB_DATABASE, // Replace with your database name // Replace with your database name
connectionLimit: 5 // Adjust connection limit as needed connectionLimit: 0 // 0 means no limit
}); });
router.use(express.json()); router.use(express.json());
@ -164,6 +164,9 @@ router.post('/import', authenticate, upload.single('fileInput'), async (req, res
conn.end(); conn.end();
fs.unlinkSync(filePath); // Remove the file after processing fs.unlinkSync(filePath); // Remove the file after processing
uploads[uploadId].completed = true; uploads[uploadId].completed = true;
setTimeout(() => {
delete uploads[uploadId];
}, 60000); // Remove the upload after 1 minute
}); });
} else if (fileType === 'mfd') { } else if (fileType === 'mfd') {
const data = fs.readFileSync(filePath, 'utf-8'); const data = fs.readFileSync(filePath, 'utf-8');
@ -198,6 +201,9 @@ router.post('/import', authenticate, upload.single('fileInput'), async (req, res
fs.unlinkSync(filePath); // Remove the file if the type is not supported fs.unlinkSync(filePath); // Remove the file if the type is not supported
res.json({ success: false, message: 'Unsupported file type.' }); res.json({ success: false, message: 'Unsupported file type.' });
} }
setTimeout(() => {
delete uploads[uploadId];
}, 60000); // Remove the upload after 1 minute
}); });
router.get('/uploadStatus', authenticate, (req, res) => { router.get('/uploadStatus', authenticate, (req, res) => {

View file

@ -12,7 +12,7 @@ const pool = mariadb.createPool({
user: process.env.DB_USER, // Replace with your database username user: process.env.DB_USER, // Replace with your database username
password: process.env.DB_PASS, // Replace with your database password password: process.env.DB_PASS, // Replace with your database password
database: process.env.DB_DATABASE, // Replace with your database name database: process.env.DB_DATABASE, // Replace with your database name
connectionLimit: 5 // Adjust connection limit as needed connectionLimit: 0 // Adjust connection limit as needed
}); });
router.get("/v1/myIP", (req,res) => { router.get("/v1/myIP", (req,res) => {