var admin = require("firebase-admin");
var serviceAccount = require(process.env.FB_CRED);
var dbModels = require("../../db/db").Models;
var dbFunctions = require("../../db/db").Functions;
const { randomUUID } = require('crypto');

const app = admin.initializeApp({
  credential: admin.credential.cert(serviceAccount)
});

var express = require('express');
var router = express.Router();

// Initialize Firebase Cloud Messaging and get a reference to the service
const messaging = admin.messaging(app);

router.post('/new', async function(req, res, next) {
    // Get info of ingredient request and create new document in collection
    let userId = req.body.email;
    let ingredientName = req.body.requestItem;
    let fcmToken = req.body.fcmtok;
    let phoneNo = req.body.phoneNo;
    if (userId && ingredientName && fcmToken) {
        let requestId = randomUUID();
        let newIngredientRequest = new dbModels.IngredientRequest({
            requestId, 
            userId,
            phoneNo,
            ingredientName,
            fcmToken
        });
        await dbFunctions.dbSaveRecord(newIngredientRequest);
        res.status(200);
        res.send(newIngredientRequest);
    } else {
        res.status(400);
        res.send("Body parameters must not be empty");
    }
});

router.get('/self', async function(req, res, next) {
    let userId = req.headers.email;
    if (userId) {
        let allSelfRequests = await dbFunctions.dbFindAllRecords(dbModels.IngredientRequest, {userId: `${userId}`});
        res.status(200);
        res.send(allSelfRequests);
    } else {
        res.status(400);
        res.send("User email must not be empty");
    }
});

router.post('/self/delete', async function(req, res, next) {
    let requestId = req.body.requestId;
    if (requestId) {
        let ingredientRequest = await dbFunctions.dbFindRecord(
                dbModels.IngredientRequest, 
                {requestId}
            );
        if (ingredientRequest) {
            await dbFunctions.dbDeleteRecord(ingredientRequest);
            res.status(200);
            res.send(`Request ID ${requestId} successfully deleted`);
        } else {
            res.status(400);
            res.send(`Request ID ${requestId} does not exist`); 
        }
    } else {
        res.status(400);
        res.send("Missing Ingredient Request ID");
    }
});

router.get('/', async function(req, res, next) {
    let allRequests = await dbFunctions.dbFindAllRecords(dbModels.IngredientRequest, {});
    res.status(200);
    res.send(allRequests);
});

router.post('/', async function(req, res, next) {
    // This registration token comes from the client FCM SDKs.
    let requestId = req.body.requestId;
    let donatorId = req.body.email;
    if (!donatorId) {
        res.status(400);
        res.send("Missing donator ID");
        return;
    }
    if (!requestId) {
        res.status(400);
        res.send("Missing Ingredient Request ID");
        return;
    }
    let ingredientRequest = await dbFunctions.dbFindRecord(
        dbModels.IngredientRequest, 
        {requestId}
    );

    if (!ingredientRequest) {
        res.status(400);
        res.send(`Request ID ${requestId} does not exist`);
        return;
    }
    let fcmToken = ingredientRequest.fcmToken;
    const message = {
        data: {
            text: `${donatorId} has fulfilled your request for ${ingredientRequest.ingredientName}. 
                Please call ${ingredientRequest.phoneNo} to pick up your ingredients!`
        },
        token: fcmToken   
    };

    messaging.send(message);
    // .then((response) => {
    //     // Response is a message ID string.
    //     console.log('Successfully sent message:', response);
    // })
    // .catch((error) => {
    //     console.log('Error sending message:', error);
    // });
    await dbFunctions.dbDeleteRecord(ingredientRequest);
    res.status(200);
    res.send(`Donated to request ID ${requestId}`);
});
  
module.exports = router;