'use strict';
const httpStatus = require('http-status');
const Sequelize = require('sequelize');
const generateControllers = require('../../core/controllers');
const { buildContext } = require('../../core/controllers');
const pushService = require('./push.service');
const userService = require('../auth/auth.service');
const { extractParamsFromRequest, handleErrorResponse, handleResultResponse } = require('../../helpers/controller.helper');

// Module Name
const MODULE_NAME = '[push.controller]';
const controllerOptions = { MODULE_NAME };

const extraControllers = {
    sendNotification: (config) => {
        return async (req, res, next) => {
            let receipt = undefined;
            try {
                const context = buildContext(req, config);
                let params = extractParamsFromRequest(req, res);
                console.log(context, params);

                let token = undefined;
                if (params.userId) {
                    token = await pushService._getPushToken({
                        userId: params.userId}); 
                }

                const message = {
                    to: token,
                    sound: 'default',
                    title: req.body.title,
                    body: req.body.message,
                };

                receipt = await pushService.sendNotification(message);


            } catch (error) {
                console.error(error);
            } finally {
                // En todo caso devolver OK al cliente
                return handleResultResponse(receipt, null, null, res, httpStatus.OK);
            }
        }
    },

    registerUser: (config) => {
        return async (req, res, next) => {
            try {
                const context = buildContext(req, config);
                var data = {
                    token: req.body.token,
                    valid: 1,
                    userId: context.user.id
                };

                let params = extractParamsFromRequest(req, res, { 
                    includeAll: false, 
                    paginate: { limit: 1, page: 1 },
                    params: {
                        userId: context.user.id,
                        token: data.token,
                    }
                });

                // Buscamos el token y el usuario
                console.log('>> Busco el usuario y el token', params.params);
                let result = await pushService.fetchOne(params, context);
                if (!result) {
                    // Dar de alta el token
                    console.log('>> Dar de alta el token', data);
                    result = await pushService.create(data, context);
                } else {
                    // Actualizar el token
                    console.log('>> Actualizar el token', params.params, data, context);
                    result = await pushService.update(params, data, context);
                }
            } catch(error) {
                console.error(error);
            } finally {
                // En todo caso devolver OK al cliente
                return handleResultResponse('OK', null, null, res, httpStatus.OK);    
            }
        }
    },    
};

module.exports = generateControllers(pushService, extraControllers, controllerOptions);