const fastify = require('fastify')({ logger: true });
const schedule = require('node-schedule');
const pool = require("./postgresql.js");
const yaml = require("yaml")
const fs = require("fs");
const config = yaml.parse(fs.readFileSync("./config.yaml", "utf-8"));

const saveRate = require('./utils/saveRate.js');
const response = require('./utils/errorResponse');

schedule.scheduleJob('30 8 * * *', async function () {
    console.log('I save the currency data');
    await saveRate();
});

fastify.get('/api/getRate/', async function (req) {
    if (!req['query']?.['fromCurrency'] || !req['query']?.['convCurrency']) return response(
        'error',
        400,
        'fromCurrency and convCurrency parameter is required'
        );

    if (!req['query']?.['periodStart']) return response(
        'error',
        400,
        'periodStart parameter is required'
    );

    let data = await pool.query('SELECT * FROM currency WHERE from_currency = $1 AND conv_currency = $2 AND date = $3', [
        req['query']['fromCurrency'],
        req['query']['convCurrency'],
        req['query']['periodStart'],
    ]).then(response('error', 500, 'Internal Server Error'));

    if (!data['rows']?.[0]) return response(
        'error',
        204,
        'There is no data for this time'
    );

    if (req['query']?.['periodEnd']) {
        let data = await pool.query('SELECT * FROM currency WHERE (date BETWEEN $3 AND $4) AND from_currency = $1 AND conv_currency = $2', [
            req['query']['fromCurrency'],
            req['query']['convCurrency'],
            req['query']['periodStart'],
            req['query']['periodEnd'],
        ]);

        return data['rows'];
    }

    return data['rows'][0];
});

fastify.listen({
    host: config['server']['host'],
    port: config['server']['port'],
}, err => {
    if (err) throw err
    console.log(`server listening on ${fastify.server.address().port}`)
})