import "dotenv/config";
import express from "express";
import http from "http";
import { Server } from "socket.io";
import axios from "axios";
import exceptionHandler from "./exceptionHandler";
import path from "path";
import initDB from "./database/initdb";
import sequelize from "./database/sequelize";
import { log, config, ZANO_ASSET_ID, parseComment, parseTrackingKey, decodeString } from "./utils/utils";
import { blockInfo, lastBlock, setLastBlock, state, setState, setBlockInfo } from "./utils/states";
import { emitSocketInfo, getBlocksDetails, getMainBlockDetails, getTxPoolDetails, getVisibilityInfo } from "./utils/methods";
import AltBlock from "./schemes/AltBlock";
import Transaction from "./schemes/Transaction";
import OutInfo, { IOutInfo } from "./schemes/OutInfo";
import Block, { IBlock } from "./schemes/Block";
import Alias from "./schemes/Alias";
import Chart, { IChart } from "./schemes/Chart";
import { get_all_pool_tx_list, get_alt_blocks_details, get_blocks_details, get_info, get_out_info, get_pool_txs_details, get_tx_details } from "./utils/zanod";
import { col, fn, literal, Op } from "sequelize";
import Pool from "./schemes/Pool";
import Asset, { IAsset } from "./schemes/Asset";
import { ITransaction } from "./schemes/Transaction";
import BigNumber from "bignumber.js";

// @ts-ignore
const __dirname = import.meta.dirname;


const app = express();
const server = http.createServer(app);
export const io = new Server(server, { transports: ['websocket', 'polling'] });

(async () => {
    await initDB();
    await sequelize.authenticate();
    await sequelize.sync();

    io.engine.on('initial_headers', (headers, req) => {
        headers['Access-Control-Allow-Origin'] = config.frontend_api
    })

    io.engine.on('headers', (headers, req) => {
        headers['Access-Control-Allow-Origin'] = config.frontend_api
    })

    app.use(express.static('dist'));
    app.use(function (req, res, next) {
        res.header('Access-Control-Allow-Origin', '*')
        res.header(
            'Access-Control-Allow-Headers',
            'Origin, X-Requested-With, Content-Type, Accept'
        )
        next()
    })
    app.use(express.static(path.resolve(__dirname, "../build/")));

    app.get(
        '/api/get_info/:flags',
        exceptionHandler(async (req, res) => {
            let flags = req.params.flags
            const response = await axios({
                method: 'get',
                url: config.api,
                data: {
                    method: 'getinfo',
                    params: { flags: parseInt(flags) }
                }
            })
            res.json(response.data)
        })
    )

    app.get(
        '/api/get_total_coins',
        exceptionHandler(async (req, res) => {
            const response = await axios({
                method: 'get',
                url: config.api,
                data: {
                    method: 'getinfo',
                    params: { flags: parseInt("4294967295") }
                }
            })

            let str = response.data.result.total_coins
            let result: number | undefined;

            let totalCoins = Number(str)
            if (typeof totalCoins === 'number') {
                result = parseInt(totalCoins.toString()) / 1000000000000
            }
            let r2 = result?.toFixed(2)
            res.send(r2)
        })
    );

    // app.get(
    //     '/api/get_main_block_details/:id',
    //     exceptionHandler(async (req, res) => {
    //         let id = req.params.id
    //         const response = await axios({
    //             method: 'get',
    //             url: config.api,
    //             data: {
    //                 method: 'get_main_block_details',
    //                 params: {
    //                     id: id
    //                 }
    //             }
    //         })
    //         res.json(response.data)
    //     })
    // )

    app.get(
        '/api/get_main_block_details/:id',
        exceptionHandler(async (req, res) => {
            try {
                let id = req.params.id.toLowerCase()
                if (id) {
                    const result = await getMainBlockDetails(id);
                    return res.json(result || "Block not found");
                }

                res.status(400).json({ error: 'Invalid parameters' });
            } catch (error) {
                console.log(error);
                res.status(500).json({ error: error.message });

            }
        })
    );

    app.get('/api/ping', exceptionHandler(async (req, res) => {
        res.send('pong')
    }));

    app.get(
        '/api/get_assets/:offset/:count',
        exceptionHandler(async (req, res) => {
            const offset = parseInt(req.params.offset, 10);
            const count = parseInt(req.params.count, 10);
            const searchText = req.query.search || '';

            if (!searchText) {
                // No searchText, fetch all assets with pagination
                const assets = await Asset.findAll({
                    order: [['id', 'ASC']],
                    limit: count,
                    offset: offset
                });

                return res.send(assets);
            }

            // If there is searchText, count matching records
            const searchCondition = {
                [Op.or]: [
                    { ticker: { [Op.iLike]: `%${searchText}%` } },
                    { full_name: { [Op.iLike]: `%${searchText}%` } }
                ]
            };

            const firstSearchRowCount = await Asset.count({
                where: searchCondition
            });

            if (firstSearchRowCount > 0) {
                // Fetch records that match the searchText
                const assets = await Asset.findAll({
                    where: searchCondition,
                    order: [['id', 'ASC']],
                    limit: count,
                    offset: offset
                });

                return res.send(assets);
            } else {
                // If no matching records found, fetch by asset_id
                const assets = await Asset.findAll({
                    where: { asset_id: searchText },
                    limit: count,
                    offset: offset
                });

                return res.send(assets);
            }
        })
    );

    const getWhitelistedAssets = async (offset, count, searchText) => {
        // Step 1: Fetch assets from external API
        const response = await axios({
            method: 'get',
            url: config.assets_whitelist_url || 'https://api.zano.org/assets_whitelist_testnet.json'
        });

        if (!response.data.assets) {
            throw new Error('Assets whitelist response not correct');
        }

        // Step 2: Add the native Zano asset to the beginning of the array
        const allAssets = response.data.assets;
        allAssets.unshift({
            asset_id: ZANO_ASSET_ID,
            logo: "",
            price_url: "",
            ticker: "ZANO",
            full_name: "Zano (Native)",
            total_max_supply: "0",
            current_supply: "0",
            decimal_point: 0,
            meta_info: "",
            price: 0
        });

        // Step 3: Filter the assets based on searchText
        const searchTextLower = searchText?.toLowerCase();
        const filteredAssets = allAssets.filter(asset => {
            return searchText
                ? (
                    asset.ticker?.toLowerCase()?.includes(searchTextLower) ||
                    asset.full_name?.toLowerCase()?.includes(searchTextLower)
                )
                : true;
        });

        // Step 4: Handle no search result in filtered assets
        if (filteredAssets.length > 0) {
            return filteredAssets.slice(offset, offset + count);
        } else {
            // Step 5: If no match found, try to fetch assets from the local database (using Sequelize)
            const dbAssets = await Asset.findAll({
                where: {
                    asset_id: searchText
                },
                limit: count,
                offset: offset
            });

            return dbAssets.map(asset => asset.toJSON());
        }
    };

    app.get(
        '/api/get_whitelisted_assets/:offset/:count',
        exceptionHandler(async (req, res) => {
            const offset = parseInt(req.params.offset, 10);
            const count = parseInt(req.params.count, 10);
            const searchText = req.query.search || '';

            const assets = await getWhitelistedAssets(offset, count, searchText);
            res.send(assets);
        })
    );

    app.get(
        '/api/get_aliases/:offset/:count/:search',
        exceptionHandler(async (req, res, next) => {
            const { offset, count, search } = req.params;
            const limit = Math.min(parseInt(count), config.maxDaemonRequestCount);
            const parsedOffset = parseInt(offset);
            const searchTerm = search.toLowerCase();

            const whereClause = {
                enabled: true,
            };

            if (searchTerm !== 'all') {
                whereClause[Op.or] = [
                    { alias: { [Op.like]: `%${searchTerm}%` } },
                    { address: { [Op.like]: `%${searchTerm}%` } },
                    { comment: { [Op.like]: `%${searchTerm}%` } },
                ];
            }

            try {
                const aliases = await Alias.findAll({
                    where: whereClause,
                    order: [['block', 'DESC']],
                    limit,
                    offset: parsedOffset,
                });

                res.json(aliases.length > 0 ? aliases : []);
            } catch (error) {
                next(error);
            }
        })
    );

    interface AggregatedData {
        at: number;
        sum_trc?: number;
        bcs?: number;
        trc?: number;
        totalSize?: number;
        totalTrans?: number;
        totalD120?: number;
        totalH100?: number;
        totalH400?: number;
        maxDiff?: number;
        minDiff?: number;
        sumDiff?: number;
        count?: number;
        d?: number;
    }
    


    app.get(
        '/api/get_chart/:chart/:period',
        exceptionHandler(async (req, res) => {
            const { chart } = req.params;
            const now = Math.round(new Date().getTime() / 1000);
            const period24HoursAgo = now - 24 * 3600;
            const period48HoursAgo = now - 48 * 3600;

            try {
                if (chart === 'all') {
                    // Fetch all raw chart data for the 'all' case
                    const arrayAll = await Chart.findAll({
                        attributes: ['actual_timestamp', 'block_cumulative_size', 'tr_count', 'difficulty', 'type'],
                        where: {
                            actual_timestamp: {
                                [Op.gt]: period24HoursAgo,
                            },
                        },
                        order: [['actual_timestamp', 'DESC']],
                    });

                    // Fetch raw data to calculate dailySum
                    const dailyData = await Chart.findAll({
                        attributes: ['actual_timestamp', 'tr_count'],
                        order: [['actual_timestamp', 'ASC']],
                    });

                    // Manually calculate the sum of transactions per day
                    const dailySum: Record<number, AggregatedData> = dailyData.reduce((acc, row) => {
                        const day = new Date(row.actual_timestamp).setHours(0, 0, 0, 0);
                        if (!acc[day]) {
                            acc[day] = { at: day, sum_trc: 0 };
                        }
                        acc[day].sum_trc += parseFloat(row.tr_count.toString());
                        return acc;
                    }, {});

                    // Fetch raw data for hash rate calculations
                    const hashRateData = await Chart.findAll({
                        attributes: ['actual_timestamp', 'difficulty120', 'hashrate100', 'hashrate400'],
                        where: {
                            type: "1",
                            actual_timestamp: {
                                [Op.gt]: period48HoursAgo,
                            },
                        },
                        order: [['actual_timestamp', 'DESC']],
                    });

                    res.json({
                        data: arrayAll,
                        dailySum: Object.values(dailySum) as AggregatedData[],
                        hashRateData,
                    });
                } else if (chart === 'AvgBlockSize') {
                    const blockSizeData = await Chart.findAll({
                        attributes: ['actual_timestamp', 'block_cumulative_size'],
                        order: [['actual_timestamp', 'ASC']],
                    });

                    // Manually calculate average block size per hour
                    const blockSizePerHour = blockSizeData.reduce((acc, row) => {
                        const hour = new Date(row.actual_timestamp).setMinutes(0, 0, 0);
                        if (!acc[hour]) {
                            acc[hour] = { at: hour, totalSize: 0, count: 0 };
                        }
                        acc[hour].totalSize += parseFloat(row.block_cumulative_size);
                        acc[hour].count++;
                        return acc;
                    }, {}) as Record<number, AggregatedData>;

                    const result = Object.values(blockSizePerHour).map(hourData => ({
                        at: hourData.at,
                        bcs: (hourData?.totalSize || 0) / (hourData.count || 1),
                    })) as AggregatedData[];

                    res.json(result);
                } else if (chart === 'AvgTransPerBlock') {
                    const transData = await Chart.findAll({
                        attributes: ['actual_timestamp', 'tr_count'],
                        order: [['actual_timestamp', 'ASC']],
                    });

                    // Manually calculate average transactions per block per hour
                    const transPerHour = transData.reduce((acc, row) => {
                        const hour = new Date(row.actual_timestamp).setMinutes(0, 0, 0);
                        if (!acc[hour]) {
                            acc[hour] = { at: hour, totalTrans: 0, count: 0 };
                        }
                        acc[hour].totalTrans += parseFloat(row.tr_count.toString());
                        acc[hour].count++;
                        return acc;
                    }, {}) as Record<number, AggregatedData>;

                    const result = Object.values(transPerHour).map(hourData => ({
                        at: hourData.at,
                        trc: (hourData.totalTrans || 0) / (hourData.count || 1),
                    }));

                    res.json(result);
                } else if (chart === 'hashRate') {
                    const hashRateData = await Chart.findAll({
                        attributes: ['actual_timestamp', 'difficulty120', 'hashrate100', 'hashrate400'],
                        where: { type: "1" },
                        order: [['actual_timestamp', 'ASC']],
                    });

                    // Manually calculate average hash rates per hour
                    const hashRatePerHour = hashRateData.reduce((acc, row) => {
                        const hour = new Date(row.actual_timestamp).setMinutes(0, 0, 0);
                        if (!acc[hour]) {
                            acc[hour] = { at: hour, totalD120: 0, totalH100: 0, totalH400: 0, count: 0 };
                        }
                        acc[hour].totalD120 += parseFloat(row.difficulty120 || "");
                        acc[hour].totalH100 += parseFloat(row.hashrate100 || "");
                        acc[hour].totalH400 += parseFloat(row.hashrate400 || "");
                        acc[hour].count++;
                        return acc;
                    }, {}) as Record<number, AggregatedData>;

                    const result = Object.values(hashRatePerHour).map(hourData => ({
                        at: hourData.at,
                        d120: (hourData.totalD120 || 0) / (hourData.count || 1),
                        h100: (hourData.totalH100 || 0) / (hourData.count || 1),
                        h400: (hourData.totalH400 || 0) / (hourData.count || 1),
                    })) as AggregatedData[];

                    res.json(result);
                } else if (chart === 'pos-difficulty' || chart === 'pow-difficulty') {
                    const type = (chart === 'pos-difficulty' ? 0 : 1).toString();
                    const difficultyData = await Chart.findAll({
                        attributes: ['actual_timestamp', 'difficulty'],
                        where: { type },
                        order: [['actual_timestamp', 'ASC']],
                    });

                    // Manually calculate the max/min/avg difficulty logic per hour
                    const difficultyPerHour = difficultyData.reduce((acc, row) => {
                        const hour = new Date(row.actual_timestamp).setMinutes(0, 0, 0);
                        if (!acc[hour]) {
                            acc[hour] = { at: hour, maxDiff: parseFloat(row.difficulty), minDiff: parseFloat(row.difficulty), sumDiff: 0, count: 0 };
                        }
                        const diff = parseFloat(row.difficulty);
                        acc[hour].maxDiff = Math.max(acc[hour].maxDiff, diff);
                        acc[hour].minDiff = Math.min(acc[hour].minDiff, diff);
                        acc[hour].sumDiff += diff;
                        acc[hour].count++;
                        return acc;
                    }, {}) as Record<number, AggregatedData>;

                    const aggregatedResult = Object.values(difficultyPerHour).map(hourData => ({
                        at: hourData.at,
                        d:  (hourData.maxDiff || 0 - (hourData.sumDiff || 0 / (hourData.count || 1))) 
                            > 
                            ((hourData.sumDiff || 0 / (hourData.count || 1)) - (hourData.minDiff || 0)) ? hourData.maxDiff : hourData.minDiff,
                    }));

                    const detailedResult = difficultyData;

                    res.json({
                        aggregated: aggregatedResult,
                        detailed: detailedResult,
                    });
                } else if (chart === 'ConfirmTransactPerDay') {
                    const transData = await Chart.findAll({
                        attributes: ['actual_timestamp', 'tr_count'],
                        order: [['actual_timestamp', 'ASC']],
                    });

                    // Manually calculate the sum of confirmed transactions per day
                    const transPerDay = transData.reduce((acc, row) => {
                        const day = new Date(row.actual_timestamp).setHours(0, 0, 0, 0);
                        if (!acc[day]) {
                            acc[day] = { at: day, sum_trc: 0 };
                        }
                        acc[day].sum_trc += parseFloat(row.tr_count.toString());
                        return acc;
                    }, {});

                    res.json(Object.values(transPerDay));
                }
            } catch (error) {
                console.log(error);
                
                res.status(500).json({ error: error.message });
            }
        })
    );

    app.get(
        '/api/get_tx_details/:tx_hash',
        exceptionHandler(async (req, res) => {
            try {
                const tx_hash = req.params.tx_hash.toLowerCase();

                if (tx_hash) {
                    // Fetching transaction details with associated block information using Sequelize
                    const transaction = await Transaction.findOne({
                        where: { tx_id: tx_hash },
                    });


                    const transactionBlock = await Block.findOne({
                        where: { height: transaction?.keeper_block },
                    }).catch(() => null);

                    if (transaction && transactionBlock) {
                        const response = {
                            ...transaction.toJSON(),
                            block_hash: transactionBlock?.tx_id,
                            block_timestamp: transactionBlock?.timestamp,
                            last_block: lastBlock.height,
                        };

                        res.json(response);
                    } else {
                        const response = await get_tx_details(tx_hash);
                        const data = response.data;

                        if (data?.result?.tx_info) {
                            if (data.result.tx_info.ins && typeof data.result.tx_info.ins === 'object') {
                                data.result.tx_info.ins = JSON.stringify(data.result.tx_info.ins);
                            }

                            if (data.result.tx_info.outs && typeof data.result.tx_info.outs === 'object') {
                                data.result.tx_info.outs = JSON.stringify(data.result.tx_info.outs);
                            }

                            res.json(data.result.tx_info);
                        } else {
                            res.status(500).json({
                                message: `/get_tx_details/:tx_hash ${JSON.stringify(req.params)}`,
                            });
                        }
                    }
                } else {
                    res.status(500).json({
                        message: `/get_tx_details/:tx_hash ${JSON.stringify(req.params)}`,
                    });
                }
            } catch (error) {
                console.log(error);

                res.status(500).json({ error: error.message });
            }
        })
    );

    app.get(
        "/api/get_tx_by_keyimage/:id",
        exceptionHandler(async (req, res, next) => {
            const id = req.params.id.toLowerCase();

            try {
                // Find transactions where 'ins' column contains the keyimage
                const transactions = await Transaction.findAll({
                    where: {
                        ins: {
                            [Op.like]: `%${id}%`
                        }
                    }
                });

                // Iterate through each transaction to find the exact match within the 'ins' field
                for (const tx of transactions) {
                    try {
                        const ins = JSON.parse(tx.ins);
                        if (Array.isArray(ins) && ins.find(e => e.kimage_or_ms_id === id)) {
                            return res.json({ result: "FOUND", data: tx.id });
                        }
                    } catch (error) {
                        // Skip the transaction if there's an error parsing the 'ins' field
                    }
                }

                return res.json({ result: "NOT FOUND" });
            } catch (error) {
                next(error);
            }
        })
    );


    app.get(
        '/api/search_by_id/:id',
        exceptionHandler(async (req, res, next) => {
            const id = req.params.id.toLowerCase();

            if (!id) {
                return res.json({ result: 'NOT FOUND' });
            }

            try {
                // Search in the 'blocks' table
                let blockResult = await Block.findOne({ where: { tx_id: id } });
                if (blockResult) {
                    return res.json({ result: 'block' });
                }

                // Search in the 'alt_blocks' table
                let altBlockResult = await AltBlock.findOne({ where: { hash: id } });
                if (altBlockResult) {
                    return res.json({ result: 'alt_block' });
                }

                // Search in the 'transactions' table
                let transactionResult = await Transaction.findOne({ where: { tx_id: id } });
                if (transactionResult) {
                    return res.json({ result: 'tx' });
                }

                // Attempt to get transaction details from an external service
                try {
                    let response = await get_tx_details(id);
                    if (response.data.result) {
                        return res.json({ result: 'tx' });
                    }
                } catch (error) {
                    // Ignore the error and continue searching in the database
                }

                // Search in the 'aliases' table
                let aliasResult = await Alias.findOne({
                    where: {
                        enabled: true,
                        [Op.or]: [
                            { alias: { [Op.like]: `%${id}%` } },
                            { address: { [Op.like]: `%${id}%` } },
                            { comment: { [Op.like]: `%${id}%` } }
                        ]
                    },
                    order: [['block', 'DESC']],
                });

                if (aliasResult) {
                    return res.json({ result: 'alias' });
                }

                // If nothing is found
                return res.json({ result: 'NOT FOUND' });
            } catch (error) {
                console.log(error);

                next(error);
            }
        })
    );

    app.get(
        '/api/get_out_info/:amount/:i',
        exceptionHandler(async (req, res) => {
            const { amount, i } = req.params;
            const index = parseInt(i, 10);

            if (amount && !isNaN(index)) {
                const outInfo = await OutInfo.findOne({
                    where: {
                        amount: amount,
                        i: index,
                    },
                });

                if (!outInfo) {
                    const response = await get_out_info(amount, index);
                    res.json({ tx_id: response.data.result.tx_id });
                } else {
                    res.json(outInfo.toJSON());
                }
            } else {
                res.status(500).json({
                    message: `/get_out_info/:amount/:i ${req.params}`,
                });
            }
        })
    );

    app.get(
        '/api/get_info',
        exceptionHandler((_, res) => {
            blockInfo.lastBlock = lastBlock.height
            res.json(blockInfo);
        })
    );

    app.get(
        '/api/get_blocks_details/:start/:count',
        exceptionHandler(async (req, res) => {
            try {
                const start = parseInt(req.params.start, 10);
                const count = parseInt(req.params.count, 10);

                if (start && count) {
                    const result = await getBlocksDetails({ start, count });
                    res.json(result);
                } else {
                    res.status(400).json({ error: 'Invalid parameters' });
                }
            } catch (error) {
                console.log(error);

                res.status(500).json({ error: error.message });
            }
        })
    );


    app.get('/api/get_asset_details/:asset_id', exceptionHandler(async (req, res) => {
        const { asset_id } = req.params;

        // Check if the asset exists in the database using Sequelize
        const dbAsset = await Asset.findOne({ where: { asset_id } });

        if (!dbAsset) {
            try {
                // Fetch the assets whitelist from the external API
                const response = await axios.get(config.assets_whitelist_url || 'https://api.zano.org/assets_whitelist_testnet.json');

                if (!response.data.assets) {
                    throw new Error('Assets whitelist response not correct');
                }

                const allAssets = response.data.assets;

                // Add Zano (Native) asset as the first item in the list
                allAssets.unshift({
                    asset_id: ZANO_ASSET_ID,
                    logo: "",
                    price_url: "",
                    ticker: "ZANO",
                    full_name: "Zano (Native)",
                    total_max_supply: "0",
                    current_supply: "0",
                    decimal_point: 0,
                    meta_info: "",
                    price: 0
                });

                // Find the asset in the whitelist
                const whitelistedAsset = allAssets.find(e => e.asset_id === asset_id);

                if (whitelistedAsset) {
                    return res.json({ success: true, asset: whitelistedAsset });
                } else {
                    return res.json({ success: false, data: "Asset not found" });
                }
            } catch (error) {
                return res.status(500).json({ success: false, error: error.message });
            }
        } else {
            // If asset is found in the database, return it
            return res.json({ success: true, asset: dbAsset });
        }
    }));


    app.get(
        '/api/get_visibility_info',
        exceptionHandler(async (_, res) => {
            const result = await getVisibilityInfo();
            res.send(result)
        })
    );

    app.get(
        '/api/get_tx_pool_details/:count',
        exceptionHandler(async (req, res, next) => {
            let count = parseInt(req.params.count, 10);

            if (count !== undefined) {
                res.json(await getTxPoolDetails(count))
            } else {
                res.status(400).json({ error: 'Invalid parameters' });
            }
        })
    );

    app.get(
        '/api/get_alt_blocks_details/:offset/:count',
        exceptionHandler(async (req, res, next) => {
            let offset = parseInt(req.params.offset)
            let count = parseInt(req.params.count)

            if (count > config.maxDaemonRequestCount) {
                count = config.maxDaemonRequestCount
            }
            const result = await AltBlock.findAll({
                order: [['height', 'DESC']],
                limit: count,
                offset: offset
            });

            return result.length > 0 ? result.map(e => e.toJSON()) : [];
        })
    );

    app.get(
        '/api/get_alt_block_details/:id',
        exceptionHandler(async (req, res, next) => {
            const id = req.params.id.toLowerCase();

            if (id) {
                const altBlock = await AltBlock.findOne({
                    where: {
                        hash: id
                    }
                });

                if (altBlock) {
                    res.json(altBlock.toJSON());
                } else {
                    res.json([]);
                }
            } else {
                res.status(500).json({
                    message: `/get_out_info/:amount/:i ${req.params}`
                });
            }
        })
    );

    app.get(
        '/api/get_alt_blocks_details/:offset/:count',
        exceptionHandler(async (req, res) => {
            let offset = req.params.offset
            let count = req.params.count
            const response = await axios({
                method: 'get',
                url: config.api,
                data: {
                    method: 'get_alt_blocks_details',
                    params: {
                        offset: parseInt(offset),
                        count: parseInt(count)
                    }
                }
            })
            res.json(response.data)
        })
    )

    app.get(
        '/api/get_alt_block_details/:id',
        exceptionHandler(async (req, res) => {
            let id = req.params.id
            const response = await axios({
                method: 'get',
                url: config.api,
                data: {
                    method: 'get_alt_block_details',
                    params: {
                        id: id
                    }
                }
            })
            res.json(response.data)
        })
    )

    app.get(
        '/api/get_all_pool_tx_list',
        exceptionHandler(async (req, res) => {
            const response = await axios({
                method: 'get',
                url: config.api,
                data: {
                    method: 'get_all_pool_tx_list'
                }
            })
            res.json(response.data)
        })
    )

    app.get(
        '/api/get_pool_txs_details',
        exceptionHandler(async (req, res) => {
            const response = await axios({
                method: 'get',
                url: config.api,
                data: {
                    method: 'get_pool_txs_details'
                }
            })
            res.json(response.data)
        })
    )

    app.get(
        '/api/get_pool_txs_brief_details',
        exceptionHandler(async (req, res) => {
            const response = await axios({
                method: 'get',
                url: config.api,
                data: {
                    method: 'get_pool_txs_brief_details'
                }
            })
            res.json(response.data)
        })
    )

    app.get('/api/price', exceptionHandler(async (req, res) => {
        if (req.query.asset_id) {
            if (req.query.asset_id === ZANO_ASSET_ID) {
                if (!state.priceData?.zano?.zano?.usd) {
                    return res.send({ success: false, data: "Price not found" });
                }

                return res.send({
                    success: true,
                    data: {
                        name: "Zano",
                        usd: state.priceData?.zano?.zano?.usd,
                        usd_24h_change: state.priceData?.zano?.zano?.usd_24h_change
                    }
                });
            }

            const assetData = await Asset.findOne({
                where: { asset_id: req.query.asset_id }
            });

            if (!assetData) {
                return res.json({ success: false, data: "Asset not found" });
            }

            // Assuming that you handle further processing of the `assetData` here...
        }

        const responseData = {
            success: true,
            data: state.priceData.zano
        };

        switch (req.query.asset) {
            case "ethereum":
                if (state.priceData?.ethereum?.ethereum?.usd === undefined) {
                    responseData.data = {};
                    responseData.success = false;
                } else {
                    responseData.data = state.priceData.ethereum;
                }
                break;
            default:
                if (state.priceData?.zano?.zano?.usd === undefined) {
                    responseData.data = {};
                    responseData.success = false;
                }
                break;
        }

        return res.json(responseData);
    }));


    app.get('/api/get_asset_details/:asset_id', exceptionHandler(async (req, res) => {
        const { asset_id } = req.params;

        const dbAsset = await Asset.findOne({
            where: { asset_id }
        });

        if (!dbAsset) {
            // Fetch the external asset list
            const response = await axios({
                method: 'get',
                url: config.assets_whitelist_url || 'https://api.zano.org/assets_whitelist_testnet.json'
            });

            if (!response.data.assets) {
                throw new Error('Assets whitelist response not correct');
            }

            // Add Zano to the beginning of the list
            const allAssets = response.data.assets;
            allAssets.unshift({
                asset_id: ZANO_ASSET_ID,
                logo: "",
                price_url: "",
                ticker: "ZANO",
                full_name: "Zano (Native)",
                total_max_supply: "0",
                current_supply: "0",
                decimal_point: 0,
                meta_info: "",
                price: 0
            });

            const whitelistedAsset = allAssets.find(e => e.asset_id === asset_id);

            if (whitelistedAsset) {
                return res.json({ success: true, asset: whitelistedAsset });
            } else {
                return res.json({ success: false, data: "Asset not found" });
            }
        } else {
            return res.json({ success: true, asset: dbAsset });
        }
    }));



    app.get("/*", function (req, res) {
        const buildPath = path.resolve(__dirname, "../build/index.html");
        res.sendFile(buildPath);
    });

    io.on('connection', async (socket) => {
        socket.on('get-socket-info', () => {
            emitSocketInfo(socket);
        })
        socket.on('get-socket-pool', async () => {
            io.emit('get_transaction_pool_info', JSON.stringify(await getTxPoolDetails(0)))
        });
    })

    server.listen(config.server_port, () => {
        // @ts-ignore
        log(`Server listening on port ${server?.address()?.port}`)
    })




    // App logic




    const syncTransactions = async () => {
        if (state.block_array.length > 0) {
            let blockInserts: IBlock[] = [];
            let transactionInserts: ITransaction[] = [];
            let chartInserts: IChart[] = [];
            let outInfoInserts: IOutInfo[] = [];

            for (const bl of state.block_array) {
                try {
                    if (bl.tr_count === undefined) bl.tr_count = bl.transactions_details.length;
                    if (bl.tr_out === undefined) bl.tr_out = [];

                    let localTr: any;

                    while (!!(localTr = bl.transactions_details.splice(0, 1)[0])) {
                        let response = await get_tx_details(localTr.id);
                        let tx_info = response.data.result.tx_info;

                        for (let item of tx_info.extra) {
                            if (item.type === 'alias_info') {
                                let arr = item.short_view.split('-->');
                                let aliasName = arr[0];
                                let aliasAddress = arr[1];
                                let aliasComment = parseComment(item.datails_view || item.details_view);
                                let aliasTrackingKey = parseTrackingKey(item.datails_view || item.details_view);
                                let aliasBlock = bl.height;
                                let aliasTransaction = localTr.id;

                                await Alias.update(
                                    { enabled: 0 },
                                    { where: { alias: aliasName } }
                                );

                                try {
                                    await Alias.upsert({
                                        alias: decodeString(aliasName),
                                        address: aliasAddress,
                                        comment: decodeString(aliasComment),
                                        tracking_key: decodeString(aliasTrackingKey),
                                        block: aliasBlock,
                                        transact: aliasTransaction,
                                        enabled: 1,
                                    });
                                } catch (error) {
                                    log(`SyncTransactions() Insert into aliases ERROR: ${error}`);
                                }
                            }
                        }

                        for (let item of tx_info.ins) {
                            if (item.global_indexes) {
                                bl.tr_out.push({
                                    amount: item.amount,
                                    i: item.global_indexes[0],
                                });
                            }
                        }

                        transactionInserts.push({
                            keeper_block: tx_info.keeper_block,
                            tx_id: tx_info.id,
                            amount: tx_info.amount.toString(),
                            blob_size: tx_info.blob_size,
                            extra: decodeString(JSON.stringify(tx_info.extra)),
                            fee: tx_info.fee,
                            ins: decodeString(JSON.stringify(tx_info.ins)),
                            outs: decodeString(JSON.stringify(tx_info.outs)),
                            pub_key: tx_info.pub_key,
                            timestamp: tx_info.timestamp,
                            attachments: decodeString(
                                JSON.stringify(!!tx_info.attachments ? tx_info.attachments : {})
                            ),
                        });
                    }
                } catch (error) {
                    log(`SyncTransactions() Inserting aliases ERROR: ${error}`);
                }

                chartInserts.push({
                    height: bl.height,
                    actual_timestamp: bl.actual_timestamp,
                    block_cumulative_size: bl.block_cumulative_size,
                    cumulative_diff_precise: bl.cumulative_diff_precise,
                    difficulty: bl.difficulty,
                    tr_count: bl.tr_count ? bl.tr_count : 0,
                    type: bl.type,
                });

                if (bl.tr_out && bl.tr_out.length > 0) {
                    for (let localOut of bl.tr_out) {
                        let localOutAmount = new BigNumber(localOut.amount).toNumber();
                        let response = await get_out_info(localOutAmount, localOut.i);

                        outInfoInserts.push({
                            amount: localOut.amount?.toString(),
                            i: localOut.i,
                            tx_id: response.data.result.tx_id,
                            block: bl.height,
                        });
                    }

                    await sequelize.transaction(async (transaction) => {
                        try {
                            if (outInfoInserts.length > 0) {
                                await OutInfo.bulkCreate(outInfoInserts, {
                                    ignoreDuplicates: true,
                                    transaction,
                                });
                            }
                        } catch (error) {
                            log(`SyncTransactions() Insert Into out_info ERROR: ${error}`);
                        }
                    });
                }

                blockInserts.push({
                    height: bl.height,
                    actual_timestamp: bl.actual_timestamp,
                    base_reward: bl.base_reward,
                    blob: bl.blob,
                    block_cumulative_size: bl.block_cumulative_size,
                    block_tself_size: bl.block_tself_size,
                    cumulative_diff_adjusted: bl.cumulative_diff_adjusted,
                    cumulative_diff_precise: bl.cumulative_diff_precise,
                    difficulty: bl.difficulty,
                    effective_fee_median: bl.effective_fee_median,
                    tx_id: bl.id,
                    is_orphan: bl.is_orphan,
                    penalty: bl.penalty,
                    prev_id: bl.prev_id,
                    summary_reward: bl.summary_reward,
                    this_block_fee_median: bl.this_block_fee_median,
                    timestamp: bl.timestamp,
                    total_fee: bl.total_fee,
                    total_txs_size: bl.total_txs_size,
                    tr_count: bl.tr_count ? bl.tr_count : 0,
                    type: bl.type,
                    miner_text_info: decodeString(bl.miner_text_info),
                    already_generated_coins: bl.already_generated_coins,
                    object_in_json: decodeString(bl.object_in_json),
                    pow_seed: bl.pow_seed,
                });
            }

            await sequelize.transaction(async (transaction) => {
                try {

                    if (blockInserts.length > 0) {
                        await Block.bulkCreate(blockInserts, {
                            transaction,
                        });
                    }

                    if (transactionInserts.length > 0) {
                        await Transaction.bulkCreate(transactionInserts, {
                            ignoreDuplicates: true,
                            transaction,
                        });
                    }

                    if (chartInserts.length > 0) {
                        await Chart.bulkCreate(chartInserts, {
                            transaction,
                        });
                    }

                    // const elementOne = state.block_array[0];
                    const newLastBlock = state.block_array.pop();
                    setLastBlock({
                        height: newLastBlock.height,
                        tx_id: newLastBlock.id,
                    });
                    log(`BLOCKS: db = ${lastBlock.height}/ server = ${blockInfo.height}`);

                    // await sequelize.query(
                    //     `CALL update_statistics(${Math.min(elementOne.height, lastBlock.height)})`,
                    //     { transaction }
                    // );

                    setState({
                        ...state,
                        block_array: [],
                    })
                } catch (error) {
                    console.log(error);

                    log(`SyncTransactions() Transaction Commit ERROR: ${error}`);
                    throw error;
                }
            });
        }
    };


    const syncBlocks = async () => {
        try {
            let count = (blockInfo?.height || 0) - lastBlock.height + 1;
            if (count > 100) {
                count = 100;
            }
            if (count < 0) {
                count = 1;
            }

            // Get block details from the external service
            let response = await get_blocks_details(lastBlock.height + 1, count);
            let localBlocks = response.data.result && response.data.result.blocks ? response.data.result.blocks : [];

            if (localBlocks.length && lastBlock.tx_id === localBlocks[0].prev_id) {
                state.block_array = localBlocks;
                await syncTransactions();

                if (lastBlock.height >= (blockInfo?.height || 0) - 1) {
                    state.now_blocks_sync = false;
                    // config.websocket.enabled_during_sync = true;
                    await emitSocketInfo();
                } else {
                    await pause(state.serverTimeout);
                    await syncBlocks();
                }
            } else {
                const deleteHeightThreshold = lastBlock.height - 100;

                // Delete blocks with height greater than the threshold
                await Block.destroy({
                    where: {
                        height: {
                            [Op.gt]: deleteHeightThreshold,
                        },
                    },
                });

                // Find the block with the maximum height after deletion
                const result = await Block.findOne({
                    order: [['height', 'DESC']],
                });

                if (result) {
                    setLastBlock(result.dataValues);
                } else {
                    setLastBlock({
                        height: -1,
                        tx_id: '0000000000000000000000000000000000000000000000000000000000000000'
                    });
                }

                await pause(state.serverTimeout);
                await syncBlocks();
            }
        } catch (error) {
            log(`SyncBlocks() get_blocks_details ERROR: ${error.message}`);
            state.now_blocks_sync = false;
        }
    };



    const syncAltBlocks = async () => {
        try {
            setState({
                ...state,
                statusSyncAltBlocks: true
            })

            // Start a transaction
            const transaction = await sequelize.transaction();

            try {
                // Delete all records from the alt_blocks table within the transaction
                await AltBlock.destroy({ where: {}, transaction });

                // Fetch the alt block details from the external service
                let response = await get_alt_blocks_details(0, state.countAltBlocksServer);

                // Iterate through the blocks and insert them into the alt_blocks table
                for (let block of response.data.result.blocks) {
                    await AltBlock.create({
                        height: block.height,
                        timestamp: block.timestamp,
                        actual_timestamp: block.actual_timestamp,
                        size: block.block_cumulative_size,
                        hash: block.id,
                        type: block.type,
                        difficulty: block.difficulty,
                        cumulative_diff_adjusted: block.cumulative_diff_adjusted,
                        cumulative_diff_precise: block.cumulative_diff_precise,
                        is_orphan: block.is_orphan,
                        base_reward: block.base_reward,
                        total_fee: block.total_fee,
                        penalty: block.penalty,
                        summary_reward: block.summary_reward,
                        block_cumulative_size: block.block_cumulative_size,
                        this_block_fee_median: block.this_block_fee_median,
                        effective_fee_median: block.effective_fee_median,
                        total_txs_size: block.total_txs_size,
                        transactions_details: JSON.stringify(block.transactions_details),
                        miner_txt_info: block.miner_text_info
                            .replace('\u0000', '')
                            .replace("'", "''"),
                        pow_seed: '', // Adjust as needed
                    }, { transaction });
                }

                // Commit the transaction
                await transaction.commit();

                // Get the updated count of alt blocks in the database
                setState({
                    ...state,
                    countAltBlocksDB: await AltBlock.count()
                })
            } catch (error) {
                // Rollback the transaction in case of an error
                await transaction.rollback();
                throw error;
            }
        } catch (error) {
            log(`SyncAltBlocks() ERROR: ${error.message}`);
        } finally {
            setState({
                ...state,
                statusSyncAltBlocks: false
            })
        }
    };

    const syncPool = async () => {
        try {
            // statusSyncPool = true;
            // countTrPoolServer = blockInfo.tx_pool_size;

            setState({
                ...state,
                statusSyncPool: true,
                countTrPoolServer: blockInfo.tx_pool_size
            });

            if (state.countTrPoolServer === 0) {
                // Clear the pool if there are no transactions on the server
                await Pool.destroy({ where: {} });
                setState({
                    ...state,
                    statusSyncPool: false
                })
                io.emit('get_transaction_pool_info', JSON.stringify([]));
            } else {
                let response = await get_all_pool_tx_list();

                if (response.data.result.ids) {
                    setState({
                        ...state,
                        pools_array: response?.data?.result?.ids || []
                    })

                    try {
                        // Delete pool entries not in the current pool list from the server
                        await Pool.destroy({
                            where: {
                                id: {
                                    [Op.notIn]: state.pools_array
                                }
                            }
                        });
                    } catch (error) {
                        log(`Delete From Pool ERROR: ${error.message}`);
                    }

                    try {
                        // Fetch all transaction ids currently in the pool
                        const existingTransactions = await Pool.findAll({
                            attributes: ['id']
                        });

                        // Find new transactions that are not already in the pool
                        const existingIds = existingTransactions.map(tx => tx.id);
                        const new_ids = state.pools_array.filter(id => !existingIds.includes(id));

                        if (new_ids.length) {
                            try {
                                // Fetch details of the new transactions
                                let response = await get_pool_txs_details(new_ids);
                                if (response.data.result && response.data.result.txs) {
                                    const txInserts = response.data.result.txs.map(tx => ({
                                        blob_size: tx.blob_size,
                                        fee: tx.fee,
                                        id: tx.id,
                                        timestamp: tx.timestamp
                                    }));

                                    // Insert the new transactions into the pool
                                    if (txInserts.length > 0) {
                                        await sequelize.transaction(async (transaction) => {
                                            await Pool.bulkCreate(txInserts, { transaction });
                                        });
                                    }
                                }
                                io.emit('get_transaction_pool_info', JSON.stringify(await getTxPoolDetails(0)));
                            } catch (error) {
                                log(`Error fetching new pool transactions: ${error.message}`);
                            }
                        }

                        setState({
                            ...state,
                            statusSyncPool: false
                        });
                    } catch (error) {
                        log(`Select id from pool ERROR: ${error.message}`);
                    }
                } else {
                    setState({
                        ...state,
                        statusSyncPool: false
                    });
                }
            }
        } catch (error) {
            log(`SyncPool() ERROR: ${error.message}`);
            await Pool.destroy({ where: {} });

            setState({
                ...state,
                statusSyncPool: false
            });
        }
    };


    const getInfoTimer = async () => {
        if (!state.now_delete_offers) {
            try {
                const response = await get_info();
                setBlockInfo(response.data.result);
                setState({
                    ...state,
                    countAliasesServer: response.data.result.alias_count,
                    countAltBlocksServer: response.data.result.alt_blocks_count,
                    countTrPoolServer: response.data.result.tx_pool_size,
                })

                if (!state.statusSyncPool) {
                    // Fetch the count of transactions in the pool using Sequelize
                    const poolTransactionCount = await Pool.count();

                    if (poolTransactionCount !== state.countTrPoolServer) {
                        log(
                            `need to update pool transactions, db=${poolTransactionCount} server=${state.countTrPoolServer}`
                        );
                        await syncPool();
                    }
                }

                if (!state.statusSyncAltBlocks) {
                    if (state.countAltBlocksServer !== state.countAltBlocksDB) {
                        log(
                            `need to update alt-blocks, db=${state.countAltBlocksDB} server=${state.countAltBlocksServer}`
                        );
                        await syncAltBlocks();
                    }
                }

                if (lastBlock.height !== (blockInfo.height || 0) - 1 && !state.now_blocks_sync) {
                    log(
                        `need to update blocks, db=${lastBlock.height} server=${blockInfo.height}`
                    );

                    // Fetch the count of aliases using Sequelize
                    const aliasCountDB = await Alias.count();

                    if (aliasCountDB !== state.countAliasesServer) {
                        log(
                            `need to update aliases, db=${aliasCountDB} server=${state.countAliasesServer}`
                        );
                    }

                    setState({
                        ...state,
                        now_blocks_sync: true
                    })
                    await syncBlocks();
                    await emitSocketInfo();
                }

                // Pause for 10 seconds
                await pause(10000);
                await getInfoTimer();

            } catch (error) {
                log(`getInfoTimer() ERROR: ${error.message}`);
                blockInfo.daemon_network_state = 0;
                // Pause for 5 minutes on error
                await pause(300000);
                await getInfoTimer();
            }
        } else {
            // If now_delete_offers is true, pause for 10 seconds before retrying
            await pause(10000);
            await getInfoTimer();
        }
    };

    const pause = (ms: number) => {
        return new Promise((resolve) => setTimeout(resolve, ms));
    };


    const start = async () => {
        try {
            // Delete all records from the alt_blocks table
            await AltBlock.destroy({
                where: {},
                truncate: true
            });

            // Get the block with the maximum height
            const lastBlockResult = await Block.findOne({
                order: [['height', 'DESC']],
            });

            if (lastBlockResult) {
                setLastBlock({
                    height: lastBlockResult.height,
                    tx_id: lastBlockResult.tx_id
                });
            }

            // Get the count of aliases
            const aliasCountResult = await Alias.count();
            setState({
                ...state,
                countAliasesDB: aliasCountResult
            });

            // Get the count of alt_blocks
            const altBlockCountResult = await AltBlock.count();
            setState({
                ...state,
                countAltBlocksDB: altBlockCountResult
            })

            // Call the getInfoTimer function
            getInfoTimer();
        } catch (error) {
            log(`Start ERROR: ${error.message}`);
        }
    };

    start();
})();


(async () => {
    while (true) {
        try {
            // Fetch assets from external API
            async function fetchAssets(offset, count) {
                try {
                    const response = await axios({
                        method: 'get',
                        url: config.api,
                        data: {
                            method: 'get_assets_list',
                            params: {
                                count: count,
                                offset: offset,
                            }
                        }
                    });

                    return response?.data?.result?.assets || [];
                } catch {
                    return [];
                }
            }

            // Fetch Zano price info
            const zanoInfo = await fetch("https://api.coingecko.com/api/v3/simple/price?ids=zano&vs_currencies=usd&include_24hr_change=true").then(res => res.json());

            await new Promise(res => setTimeout(res, 5 * 1e3));

            // Fetch Ethereum price info
            try {
                const ethInfo = await fetch("https://api.coingecko.com/api/v3/simple/price?ids=ethereum&vs_currencies=usd&include_24hr_change=true").then(res => res.json());
                console.log('ETH INFO: ', ethInfo);
                if (ethInfo?.ethereum?.usd !== undefined) {
                    setState({
                        ...state,
                        priceData: {
                            ...state.priceData,
                            ethereum: ethInfo
                        }
                    });
                }
            } catch (error) {
                console.log('ETH PARSING ERROR');
                console.log('Error: ', error);
            }

            console.log('ZANO INFO: ', zanoInfo);

            if (zanoInfo?.zano?.usd !== undefined) {
                setState({
                    ...state,
                    priceData: {
                        ...state.priceData,
                        zano: zanoInfo
                    }
                });
            }

            // Fetch all assets
            const assets: IAsset[] = [];
            let iterator = 0;
            const amountPerIteration = 100;

            while (true) {
                const newAssets = await fetchAssets(iterator + 1, iterator + amountPerIteration);
                if (!newAssets.length) break;
                assets.push(...newAssets);
                iterator += amountPerIteration;
            }

            console.log('Got assets list');

            // Fetch existing assets from the database
            const assetsRows = await Asset.findAll();

            // Update or delete existing assets
            for (const assetRow of assetsRows) {
                const foundAsset = assets.find(e => e.asset_id === assetRow.asset_id);
                if (!foundAsset) {
                    // Delete asset if not found in the external data
                    await Asset.destroy({
                        where: { asset_id: assetRow.asset_id }
                    });
                } else {
                    // Update existing asset
                    const {
                        asset_id,
                        logo,
                        price_url,
                        ticker,
                        full_name,
                        total_max_supply,
                        current_supply,
                        decimal_point,
                        meta_info,
                        price
                    } = foundAsset;

                    await Asset.update({
                        logo: logo || "",
                        price_url: price_url || "",
                        ticker: ticker || "",
                        full_name: full_name || "",
                        total_max_supply: total_max_supply?.toString() || "0",
                        current_supply: current_supply?.toString() || "0",
                        decimal_point: decimal_point || 0,
                        meta_info: meta_info || "",
                        price: price
                    }, {
                        where: { asset_id }
                    });
                }
            }

            // Insert new assets
            for (const asset of assets) {
                const foundAsset = assetsRows.find(e => e.asset_id === asset.asset_id);
                if (!foundAsset && asset.asset_id) {
                    const {
                        asset_id,
                        logo,
                        price_url,
                        ticker,
                        full_name,
                        total_max_supply,
                        current_supply,
                        decimal_point,
                        meta_info,
                        price = 0
                    } = asset;

                    await Asset.create({
                        asset_id,
                        logo: logo || "",
                        price_url: price_url || "",
                        ticker,
                        full_name,
                        total_max_supply: total_max_supply?.toString(),
                        current_supply: current_supply?.toString(),
                        decimal_point,
                        meta_info: meta_info || "",
                        price
                    });
                }
            }
        } catch (error) {
            console.log('ASSETS PARSING ERROR');
            console.log('Error: ', error);
        }

        // Wait for 60 seconds before the next iteration
        await new Promise(res => setTimeout(res, 60 * 1e3));
    }
})();