devbeni/funcode2.0
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix: improve MySQL connection handling and cleanup on server start

Browse Source
This commit is contained in:
devbeni
2025-09-19 19:49:47 +02:00
parent cb2f5732eb
commit 730044f0b7
1 changed files with 30 additions and 10 deletions
Download Patch File Download Diff File Expand all files Collapse all files

40
app/api/socketio/route.js
View File

@@ -9,19 +9,21 @@ const QUEUE_THRESHOLD = parseInt(process.env.QUEUE_THRESHOLD || "100", 10)
const CONCURRENT_ACTIVE = parseInt(process.env.CONCURRENT_ACTIVE || "50", 10) const CONCURRENT_ACTIVE = parseInt(process.env.CONCURRENT_ACTIVE || "50", 10)
const TOKEN_TTL_SECONDS = parseInt(process.env.TOKEN_TTL_SECONDS || `${15 * 60}`, 10) const TOKEN_TTL_SECONDS = parseInt(process.env.TOKEN_TTL_SECONDS || `${15 * 60}`, 10)
// MySQL kapcsolat // MySQL kapcsolat - minden híváskor új connection
let db = null
async function getDbConnection() { async function getDbConnection() {
if (!db && process.env.MYSQL_HOST) { if (!process.env.MYSQL_HOST) return null
db = await mysql.createConnection({ try {
const connection = await mysql.createConnection({
host: process.env.MYSQL_HOST, host: process.env.MYSQL_HOST,
user: process.env.MYSQL_USER, user: process.env.MYSQL_USER,
password: process.env.MYSQL_PASSWORD, password: process.env.MYSQL_PASSWORD,
database: process.env.MYSQL_DATABASE, database: process.env.MYSQL_DATABASE,
}) })
return connection
} catch (error) {
console.error('MySQL connection error:', error)
return null
} }
return db
} }
function ensureEvent(eventId) { function ensureEvent(eventId) {
@@ -137,6 +139,15 @@ async function evaluateQueue(eventId, io) {
// If queue no longer needed, clear it // If queue no longer needed, clear it
if (ev.sockets.size < QUEUE_THRESHOLD) ev.queueOn = false if (ev.sockets.size < QUEUE_THRESHOLD) ev.queueOn = false
// Close database connection
if (connection) {
try {
await connection.end()
} catch (error) {
console.error('Error closing DB connection:', error)
}
}
// broadcast // broadcast
broadcastUpdate(eventId, io) broadcastUpdate(eventId, io)
} }
@@ -165,12 +176,12 @@ export async function GET(req) {
global.io = io global.io = io
// Clean up all expired sessions on server start // Clean up all expired sessions on server start
const connection = await getDbConnection() const startupConnection = await getDbConnection()
if (connection) { if (startupConnection) {
try { try {
const [result] = await connection.execute('DELETE FROM active_sessions WHERE expires_at < NOW()') const [result] = await startupConnection.execute('DELETE FROM active_sessions WHERE expires_at < NOW()')
console.log(`Server startup: Cleaned ${result.affectedRows} expired sessions`) console.log(`Server startup: Cleaned ${result.affectedRows} expired sessions`)
await connection.end() await startupConnection.end()
} catch (error) { } catch (error) {
console.error('Cleanup error on startup:', error) console.error('Cleanup error on startup:', error)
} }
@@ -276,6 +287,15 @@ export async function GET(req) {
position: pos === -1 ? null : pos + 1, position: pos === -1 ? null : pos + 1,
estimatedWait: pos === -1 ? null : (ev.active.size + pos) * TOKEN_TTL_SECONDS, estimatedWait: pos === -1 ? null : (ev.active.size + pos) * TOKEN_TTL_SECONDS,
}) })
// Close database connection
if (connection) {
try {
await connection.end()
} catch (error) {
console.error('Error closing DB connection:', error)
}
}
}) })
socket.on("disconnect", () => { socket.on("disconnect", () => {