/**
 * Required External Modules and Interfaces
 */

import express, {Request, Response} from 'express';
import * as PriceAlarmsService from './pricealarms.service';
import {PriceAlarm} from './pricealarm.interface';
import {PriceAlarms} from './pricealarms.interface';
import * as UserService from '../users/users.service';


/**
 * Router Definition
 */
export const pricealarmsRouter = express.Router();


/**
 * Controller Definitions
 */

//GET pricealarms/
pricealarmsRouter.get('/', async (req: Request, res: Response) => {
    try {
        // Authenticate user
        const user_ip = req.connection.remoteAddress ?? '';
        const session_id = (req.query.session_id ?? '').toString();
        const session_key = (req.query.session_key ?? '').toString();
        const user = await UserService.checkSession(session_id, session_key, user_ip);

        const priceAlarms = await PriceAlarmsService.getPriceAlarms(user.user_id);

        res.status(200).send(priceAlarms);
    } catch (e) {
        console.log('Error handling a request: ' + e.message);
        res.status(500).send(JSON.stringify({'message': 'Internal Server Error. Try again later.'}));
    }
});

// POST pricealarms/
pricealarmsRouter.post('/', async (req: Request, res: Response) => {
    try {
        // Authenticate user
        const user_ip = req.connection.remoteAddress ?? '';
        const session_id = req.body.session_id;
        const session_key = req.body.session_key;
        const user = await UserService.checkSession(session_id, session_key, user_ip);

        // Get info for price alarm creation
        const product_id = req.body.product_id;
        const defined_price = req.body.defined_price;

        if (!product_id || !defined_price) {
            // Missing
            res.status(400).send(JSON.stringify({message: 'Missing parameters'}));
            return;
        }

        // Create price alarm
        const success = await PriceAlarmsService.createPriceAlarm(user.user_id, product_id, defined_price);

        if (success) {
            res.status(201).send(JSON.stringify({success: true}));
            return;
        } else {
            res.status(500).send(JSON.stringify({success: false}));
            return;
        }
    } catch (e) {
        console.log('Error handling a request: ' + e.message);
        res.status(500).send(JSON.stringify({'message': 'Internal Server Error. Try again later.'}));
    }
});

// PUT pricealarms/
pricealarmsRouter.put('/', async (req: Request, res: Response) => {
    try {
        // Authenticate user
        const user_ip = req.connection.remoteAddress ?? '';
        const session_id = req.body.session_id;
        const session_key = req.body.session_key;
        const user = await UserService.checkSession(session_id, session_key, user_ip);

        // Get info for price alarm creation
        const alarm_id = req.body.alarm_id;
        const defined_price = req.body.defined_price;

        if (!alarm_id || !defined_price) {
            // Missing
            res.status(400).send(JSON.stringify({message: 'Missing parameters'}));
            return;
        }

        // Update price alarm
        const success = await PriceAlarmsService.updatePriceAlarm(alarm_id, user.user_id, defined_price);

        if (success) {
            res.status(200).send(JSON.stringify({success: true}));
            return;
        } else {
            res.status(500).send(JSON.stringify({success: false}));
            return;
        }
    } catch (e) {
        console.log('Error handling a request: ' + e.message);
        res.status(500).send(JSON.stringify({'message': 'Internal Server Error. Try again later.'}));
    }
});