server.js

// require("dotenv").config();
const express = require("express");
const mysql = require("mysql2");
const bcrypt = require("bcrypt");
const cors = require("cors");
const bodyParser = require("body-parser");
const jwt = require("jsonwebtoken");
const path = require("path");

const app = express();
const PORT = 5000;

// ✅ Serve static files from the 'public' folder
app.use(express.static(path.join(__dirname, "public")));

// Middleware
app.use(cors());
app.use(bodyParser.json());
app.use(express.json());  // Parses JSON request bodies

const db = mysql.createConnection({
    host: "localhost",
    user: "root", 
    password: "pandeyakish2006", 
    database: "flight_db"
});

db.connect(err => {
    if (err) throw err;
    console.log("✅ MySQL Database Connected!");
});

// ----------------------------------------------------------------------------------------

// 🚀 REGISTER API
app.post("/register", async (req, res) => {
    const { name, address, email, password, contact, gender } = req.body;
    console.log("Received Registration Data:", req.body);

    // Check if email already exists
    db.query("SELECT * FROM users WHERE email = ?", [email], async (err, results) => {
        if (err) return res.status(500).json({ error: "Database Error" });

        if (results.length > 0) {
            return res.status(400).json({ error: "Email already registered!" });
        }

        // Hash Password
        const hashedPassword = await bcrypt.hash(password, 10);

        // Insert new user
        db.query(
            "INSERT INTO users (name, address, email, password, contact, gender) VALUES (?, ?, ?, ?, ?, ?)",
            [name, address, email, hashedPassword, contact, gender],
            (err, result) => {
                if (err) return res.status(500).json({ error: "Database Error" });
                res.json({ message: "User registered successfully!" });
            }
        );
    });
});

// ---------------------------------------------------------------------

app.post("/login", async (req, res) => {
    const { emailOrUsername, password } = req.body;

    console.log("📢 Received Login Request:", req.body);

    // ✅ Check if request body is missing or empty
    if (!emailOrUsername || !password) {
        console.error("❌ Missing emailOrUsername or password!");
        return res.status(400).json({ success: false, message: "Email/Username and password are required!" });
    }

    console.log("📢 Login credentials received:", emailOrUsername, password);

    let sql;
    let queryValue;

    // ✅ Check if input is email or username
    if (emailOrUsername.includes("@")) {
        sql = "SELECT * FROM users WHERE email = ?";
        queryValue = emailOrUsername;
    } else {
        sql = "SELECT * FROM users WHERE name = ?";
        queryValue = emailOrUsername;
    }

    db.query(sql, [queryValue], async (err, results) => {
        if (err) {
            console.error("❌ Database error:", err);
            return res.status(500).json({ success: false, message: "Server error!" });
        }

        if (results.length === 0) {
            console.log("❌ User not found:", emailOrUsername);
            return res.status(401).json({ success: false, message: "Invalid email/username or password!" });
        }

        const user = results[0];
        console.log("✅ User found in database:", user);

        // ✅ Compare entered password with stored hashed password
        const isMatch = await bcrypt.compare(password, user.password);
        console.log("🔑 Password match status:", isMatch);

        if (!isMatch) {
            
            console.log("❌ Password incorrect for:", emailOrUsername);
            return res.status(401).json({ success: false, message: "Invalid email/username or password!" });
        }

        // ✅ Generate JWT token
        const token = jwt.sign({ userId: user.id, email: user.email }, "secretkey", { expiresIn: "1h" });
        res.json({ success: true, message: "Login successful!", token });
    });
});

// ---------------------------------------------------------------------------------------------

// Flight Search Route
app.post("/search-flights", (req, res) => {
    const { from_location, to_location, departure_date } = req.body;

    // console.log("Received request:", origin, destination, departureDate); // Debugging log
    console.log("Received request:", req.body);  //Debugging Log

    const query = `SELECT * FROM flights WHERE from_location = ? AND to_location = ? AND departure_date = ?`;

    db.query(query, [from_location, to_location, departure_date], (err, results) => {
        if (err) {
            console.error("❌ Database query error:", err);
            return res.status(500).json({ success: false, message: "Database error." });
        }

        if (results.length > 0) {
            console.log("✅ Flight found:", results);
            return res.json({ success: true });
        } else {
            console.log("❌ No flight found.");
            return res.json({ success: false });
        }
    });
});

// ----------------------------------------------------------------------------------------------


app.post('/getFlights', async (req, res) => {
    try {
        const { from_location, to_location, departure_date } = req.body;

        if (!from_location || !to_location || !departure_date) {
            return res.status(400).json({ error: "Missing required fields" });
        }

        const query = `SELECT * FROM flights WHERE from_location = ? AND to_location = ? AND departure_date = ?`;
        const values = [from_location, to_location, departure_date];

        const [rows] = await db.promise().query(query, values);

        if (rows.length === 0) {
            return res.status(404).json({ message: "No flights found" });
        }

        res.json(rows);
    } catch (error) {
        console.error("Database error:", error);
        res.status(500).json({ error: "Internal Server Error" });
    }
});

// ✅ Route to serve login.html correctly
app.get("/login", (req, res) => {
    res.sendFile(path.join(__dirname, "public", "login.html"));
});

// Start Server
app.listen(PORT, () => {
    console.log(`🚀 Server running on http://localhost:${PORT}`);
});