const envFile = process.env.NODE_ENV === 'production' ? '.env.production' : '.env';
require('dotenv').config({ path: envFile });

console.log('Directory corrente:', process.cwd());
const express = require('express');
const sql = require('mssql');
const cors = require('cors');

const app = express();
app.use(express.json());
app.use(cors());

const API_KEY = process.env.API_KEY;

const config = {
    user: process.env.DB_USERNAME_SQLSRVTEST,
    password: process.env.DB_PASSWORD_SQLSRVTEST,
    server: process.env.DB_HOST_SQLSRVTEST,
    port: parseInt(process.env.DB_PORT_SQLSRVTEST, 10),
    database: process.env.DB_DATABASE_SQLSRVTEST,
    options: {
        encrypt: false,
        trustServerCertificate: true,
        requestTimeout: 40000 // timeout in ms (30 secondi)
    }
};

// Middleware per verificare l'API Key
app.use((req, res, next) => {
    const apiKey = req.headers['x-api-key'];
    if (apiKey !== API_KEY) {
        console.error('APIKEY NON CORRETTA !');
        return res.status(403).json({ error: 'Accesso negato' });
    }
    next();
});

app.get('/test', (req, res) => {
    console.log('Il server risponde correttamente')
    res.status(200).json({
        success: true,
        message: "Il server risponde correttamente"
    });
});

app.post('/query', async (req, res) => {
    let retry = false;
    try {

        if (!req.body.query || typeof req.body.query !== 'string') {
            return res.status(400).json({ error: 'Query non valida' });
        }

        console.log('Connect con config...');
        await sql.connect(config);

        const doQuery = async () => {
            console.log('Eseguo query:', req.body.query);
            const result = await sql.query(req.body.query);
            console.log('Query completata');
            return result;
        };

        let result;

        try {
            result = await doQuery();
        } catch (err) {
            if (err.message.trim() === 'socket hang up' && !retry) {
                console.warn('⚠️ socket hang up — attendo 5 secondi e riprovo...');
                retry = true;
                await new Promise(resolve => setTimeout(resolve, 5000));
                result = await doQuery();
            } else {
                throw err;
            }
        }

        res.json(result?.recordset || {});
    } catch (err) {
        console.error('❌ Errore nella query:', err.message);
        res.status(500).json({ error: err.message });
    } finally {
        sql.close(); // chiude anche se fallisce
    }
});

const PORT = process.env.SERVER_PORT || 3000;
// Log iniziali di avvio
console.log('Avvio del server...');
console.log(`Configurazione: utilizzo della porta ${PORT}`);

// console.log(process.env);

app.listen(PORT, () => {
    console.log(`Server in ascolto sulla porta ${PORT}`);
});