import mdb from "mariadb"

export default class DBAdapter {
    #dbhost = 'localhost';
    #dbPort = 3306;
    #dbName = 'N';
    #dbUserLogin = 'u';
    #dbUserPassword = 'p';
    #dbClient = null;

    constructor({
        dbHost,
        dbPort,
        dbName,
        dbUserLogin,
        dbUserPassword
    }) {
        this.#dbhost = dbHost;
        this.#dbPort = dbPort;
        this.#dbName = dbName;
        this.#dbUserLogin = dbUserLogin;
        this.#dbUserPassword = dbUserPassword;
        this.#dbClient = new mdb.createPool({
            host: this.#dbhost,
            port: this.#dbPort,
            database: this.#dbName,
            user: this.#dbUserLogin,
            password: this.#dbUserPassword
        });
    }

    async connect() {
        try {
            // Проверяем подключение, выполняя простой запрос
            const conn = await this.#dbClient.getConnection();
            console.log("✅ Database connection test successful");
            conn.release();
        } catch (err) {
            console.error("❌ Database connection failed:", err.message);
            // Пробрасываем ошибку дальше
            return Promise.reject();
        }
    }

    async disconnect() {
        await this.#dbClient.end();
        console.log("DISCONNECT");
    }

    async getProducts() {
        try {
            const products = await this.#dbClient.query('SELECT * FROM products ORDER BY name');
            console.log("All products:", products);
            return products;
        } catch(err){
            console.log(`WHOOPS`);
            return Promise.reject();
        }
    }

    async getOrders() {
        try {
            const raw_orders = await this.#dbClient.query('SELECT * FROM orders ORDER BY order_date ASC');
            console.log("All orders:", raw_orders);
            
            const items = await this.#dbClient.query(
                `SELECT order_items.*, products.name AS product_name FROM order_items
                JOIN products ON order_items.product_id = products.id`
            );
            console.log("All order items:", items);
            
            const groupedItems = {};
            if (items && items.length > 0) {
                items.forEach(item => {
                    const orderId = item.order_id;
                    if (!groupedItems[orderId]) {
                        groupedItems[orderId] = [];
                    }
                    groupedItems[orderId].push(item);
                });
            }
            
            const ordersWithItems = raw_orders.map(order => {
                return {
                    ...order,
                    items: groupedItems[order.id] || []
                };
            });
            
            console.log("Orders with items:", ordersWithItems);
            return ordersWithItems;
        } catch(err) {
            console.log(`WHOOPS: ${err.message}`);
            return Promise.reject(err);
        }
    }
}