From f6414f9858285db241f91322e95983947d206b93 Mon Sep 17 00:00:00 2001 From: ChrisChrome Date: Sun, 22 Dec 2024 17:49:10 -0700 Subject: [PATCH] Unlimited db connections --- routes/admin.js | 10 ++++++++-- routes/api.js | 2 +- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/routes/admin.js b/routes/admin.js index f19a35f..4728353 100644 --- a/routes/admin.js +++ b/routes/admin.js @@ -21,8 +21,8 @@ const pool = mariadb.createPool({ port: process.env.DB_PORT || 3306, user: process.env.DB_USER, // Replace with your database username password: process.env.DB_PASS, // Replace with your database password - database: process.env.DB_DATABASE, // Replace with your database name - connectionLimit: 5 // Adjust connection limit as needed + // Replace with your database name + connectionLimit: 0 // 0 means no limit }); router.use(express.json()); @@ -164,6 +164,9 @@ router.post('/import', authenticate, upload.single('fileInput'), async (req, res conn.end(); fs.unlinkSync(filePath); // Remove the file after processing uploads[uploadId].completed = true; + setTimeout(() => { + delete uploads[uploadId]; + }, 60000); // Remove the upload after 1 minute }); } else if (fileType === 'mfd') { 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 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) => { diff --git a/routes/api.js b/routes/api.js index 4506302..7b2bc31 100644 --- a/routes/api.js +++ b/routes/api.js @@ -12,7 +12,7 @@ const pool = mariadb.createPool({ user: process.env.DB_USER, // Replace with your database username password: process.env.DB_PASS, // Replace with your database password 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) => {