diff --git a/src/server.js b/src/server.js index 0d3f133..1ec073b 100644 --- a/src/server.js +++ b/src/server.js @@ -58,11 +58,25 @@ app.post('/query', async (req, res) => { res.json({}); } } catch (err) { - console.error('Error...', err.message) - res.status(500).json({ error: err.message }); + // se err.messagge === 'socket hang up' allora attendi 2 secondi e richiama sql.query + if (err.message.trim() === 'socket hang up') { + await new Promise((resolve) => setTimeout(resolve, 2000)); + const result = await sql.query(req.body.query); + console.log(' ... tornato'); + if (result) { + console.log('Risultato:', result.recordset); + res.json(result.recordset); + } else { + res.json({}); + } + } else { + console.error('Error...', err.message) + res.status(500).json({ error: err.message }); + } } finally { sql.close(); } + }); const PORT = process.env.SERVER_PORT || 3000;