routes.js

var router = require('express').Router()
const Business = require('./models/business');
const googleBusiness = require('./models/googleBusiness');
const Message = require('./models/locations.js');
const User = require('./models/users');
const adminSetting = require('./models/AdminSetting');
const userEstablishmentRating = require('./models/userEstablishmentRating');

const axios = require('axios');
var mongoose = require('mongoose');
var cloudinary = require('cloudinary').v2;
const data = require('./jsonData/nightClubs');
const barData = require('./jsonData/bar');
const restaurantData = require('./jsonData/restaurant');
const mixedData = require('./jsonData/mixedThree');
var nodemailer = require("nodemailer");
var crypto = require('crypto');
var schedule = require('node-schedule');
var uniqid = require('uniqid');
const moment = require('moment');
const { findById } = require('./models/users');


cloudinary.config({ 
  cloud_name: 'developer-inn', 
  api_key: '141611599995991', 
  api_secret: '-FP9u7Z7cyB3TVM7x5dGpXcfDco' 
});

var smtpTransport = nodemailer.createTransport({
  service: "Gmail",
  auth: {
      user: "abubakarakram168@gmail.com",
      pass: "abubakar032449746"
  }
});
var rand,mailOptions,host,link;

router.get('/countAllBusinesses', async function(req, res){
  var totalCount = 0;
  var businesses = await googleBusiness.find({});
  for (let b of businesses){
    if( b.opening_hours.weekday_text.length ){
      totalCount = totalCount + 1;
    }
  }
  console.log("all businesses", totalCount);
})

router.post('/setDefaultSettings', async function(req, res){  
  let body = req.body;
  let { fun, crowd, ratioInput, difficultyGettingIn, difficultyGettingDrink } = body.rating;
  try{
    let {rating, ratingChangeTime} =  await adminSetting.findOne({ _id: mongoose.Types.ObjectId("600ad7fa8dc42b13b2c0e2da")})
    const filter = { _id: mongoose.Types.ObjectId("600ad7fa8dc42b13b2c0e2da") };
    
    if( parseInt(fun) === rating.fun && parseInt(crowd) === rating.crowd &&  parseInt(difficultyGettingIn) === rating.difficultyGettingIn
      && parseInt(ratioInput) === rating.ratioInput && parseInt(difficultyGettingDrink) === rating.difficultyGettingDrink
    ){
      body.rating = rating;
      body.ratingChangeTime = ratingChangeTime;
    }
      
    

    console.log("the body in getting backedn", body);
    let updatedDoc = await adminSetting.findOneAndUpdate(filter, body, {
      new: true
    });
    console.log("the updated doc", updatedDoc)
    res.send({ data: updatedDoc })
  }catch(error){
    res.status(400).json({ error: error.toString() });
  }
})

router.post('/setScheduleEvent', async function(req, res){  
  const body = req.body;
  body.startJobId = uniqid();
  body.endJobId = uniqid();
  body.isScheduleApply = true
  try{
    const filter = { _id: mongoose.Types.ObjectId("600ad7fa8dc42b13b2c0e2da") };
    let updatedDoc = await adminSetting.findOneAndUpdate(filter, body, {
      new: true
    });
    let [hours, minutes] = body.scheduleStartTime.split(':')
    console.log("the hours", hours)
    if(updatedDoc){
      let rule = new schedule.RecurrenceRule();
      rule.second = 0;
      rule.minute = parseInt(minutes);
      rule.hour = parseInt(hours);
      rule.dayOfWeek = body.noOfscheduleEventInAWeek;
      rule.month = [0,11]
      rule.tz = moment.tz.guess();
      console.log("the rule", rule)
      schedule.scheduleJob(body.startJobId, rule, async function () {
        console.log("in start")
        const filter = { _id: mongoose.Types.ObjectId("600ad7fa8dc42b13b2c0e2da") };
        await adminSetting.findOneAndUpdate(filter, { isRunning: true }, {
          new: true
        });
      })
      let endRule = new schedule.RecurrenceRule();
      hours = body.scheduleEndTime.split(':')[0]
      minutes = body.scheduleEndTime.split(':')[1]
      endRule.second = 0;
      endRule.minute = minutes;
      endRule.hour = hours;
      endRule.dayOfWeek = body.noOfscheduleEventInAWeek;
      endRule.month = [0,11]
      endRule.tz = moment.tz.guess();
      schedule.scheduleJob(body.endJobId, endRule, async function () {
        console.log("in close")
        const filter = { _id: mongoose.Types.ObjectId("600ad7fa8dc42b13b2c0e2da") };
        await adminSetting.findOneAndUpdate(filter, { isRunning: false }, {
          new: true
        });
      })

      res.send({ data: updatedDoc })
    }
  }catch(error){
    res.status(400).json({ error: error.toString() });
  }
})

router.post('/stopScheduleEvent', async function(req, res){  
  try{
    const filter = { _id: mongoose.Types.ObjectId("600ad7fa8dc42b13b2c0e2da") };
    const updatedSchedule = await adminSetting.findOneAndUpdate(filter, { isRunning:false, isScheduleApply : false }, {
      new: true
    });
    console.log("the updated schedule", updatedSchedule)
    let startingCurrentJob = schedule.scheduledJobs[updatedSchedule.startJobId]
    let endingCurrentJob = schedule.scheduledJobs[updatedSchedule.endJobId]
    startingCurrentJob.cancel();
    endingCurrentJob.cancel();
    res.send({ data: updatedSchedule })
  }catch(error){
    console.log("on stoping error", error)
    res.status(400).json({ error: error.toString() });
  }
})

router.post("/createSettings", async function(req, res){
  const userSetting = {
    scheduleStartTime: "13:10",
    scheduleEndTime: "16:00",
    startJobId: "231",
    endJobId: "4623",
    rating: {
      fun: 2,
      crowd: 2,
      ratioInput: 3,
      difficultyGettingIn: 2,
      difficultyGettingDrink : 2
    },
    noOfUsersUntilShowDefault: 3,
    noOfscheduleEventInAWeek: [1, 2]
  }
  const getSettings = new adminSetting(userSetting)
  const userCreated = await getSettings.save();
  res.send({ settings: userCreated })

})

router.get('/getdefaultSettings', async function(req, res){
  const getAdminSettings = await adminSetting.find();
  console.log("the get admin sett", getAdminSettings)
  res.send({ settings: getAdminSettings[0] })
})

router.post('/updateMapPinColor', async function(req, res){
  const filter = { _id: mongoose.Types.ObjectId("600ad7fa8dc42b13b2c0e2da") };
  
  console.log("here comess... the data", req.body.vibeCategories)

  const updatedMapPinsData = await adminSetting.findOneAndUpdate(filter, { isRunning:true, vibeCategoryPinsColor: req.body.vibeCategories}, {
    new: true
  });
  console.log("here the updateMap", updatedMapPinsData)
  res.send({ settings: updatedMapPinsData })
})

router.post('/sendEmailVerification',async function(req, res){
  var mykey = crypto.createCipher('aes-128-cbc', 'Halting');
  let randomString = Math.random().toString(36).substring(7);
  console.log("random", req.body);
  var mystr = mykey.update(randomString, 'utf8', 'hex')
  mystr += mykey.final('hex');
  const { userId } = req.body;
  console.log("the request body", userId)
  const user = await User.findById(mongoose.Types.ObjectId(userId))
  console.log("the user", user)
  if(!user)
    throw new Error("User Not Found")

  const update = {
    isVerified: {
      encodeData: randomString,
      verify: false
    }
  }
  const filter = { _id: mongoose.Types.ObjectId(user._id) };
  try{  
    let updatedDoc = await User.findOneAndUpdate( filter ,update, {
      new: true
    });
    
    if(updatedDoc){
      host=req.get('host');
      link="http://"+req.get('host')+"/verify?id="+mystr+`&email=${user.email}`;
      mailOptions={
        to : user.email,
        subject : "Please confirm your Email account",
        html : `Hello ${user.firstName},<br> Please Click on the link to verify your email.<br><a href="${link}">Click here to verify</a>`
      }
      smtpTransport.sendMail(mailOptions, function(error, response){
        console.log("the error", error)
      if(error)
        res.send({ message: "Email Could not send Successfully", status: 500 });
      else
        res.send({ message: "Email send Successfully", status: 200 });
      })
    }
    else
      res.send( { message: "Email Could not send Successfullyss", status: 500  })
  }catch(err){
    console.log("the error", err)
  }
});


router.get('/verify', async function(req,res){
  console.log(req.protocol+":/"+req.get('host'));
  var mykey = crypto.createDecipher('aes-128-cbc', 'Halting');
  const { id: hashedId, email } = req.query;
  var mystr = mykey.update(hashedId, 'hex', 'utf8')
  mystr += mykey.final('utf8');
  const user = await User.findOne({ email })
  if(!user)
    res.end("Unauthorized User")
  console.log("the user", user)
  const { isVerified } = user;
  if((req.protocol+"://"+req.get('host'))==("http://"+host)){
    console.log("Domain is matched. Information is from Authentic email");
    console.log(`the random var ${mystr} and query value id is ${email} `)
    if( isVerified.encodeData === mystr){
      const update = {
        isVerified: {
          encodeData: null,
          verify: true
        }
      }
      const filter = { _id: mongoose.Types.ObjectId(user._id) };
      try{  
        let updatedDoc = await User.findOneAndUpdate( filter ,update, {
          new: true
        });
        if(updatedDoc){
          console.log("email is verified");
          res.end(`Your ${updatedDoc.email} is verified`)
        }
      }catch(err){
        res.end("Email Not verified")
      }     
    }
    else
      res.end("<h1>Bad Request</h1>");   
  }
  else
    res.end("<h1>Request is from unknown source");

});


router.post('/uploadAllBusinessPhotos', async function(req, res) {
  const getAllBusinesses = await Business.find({}).populate('googleBusiness').skip(2000).limit(479)
  const totalNames = []
  getAllBusinesses.map(async(business)=>{
    if(business.googleBusiness.photos && business.googleBusiness.photos.length > 1){
      const allPhotos = business.googleBusiness.photos;
      totalNames.push(business.placeId)
      const uploadAll = await uploadAllPhotos(allPhotos);
      console.log("the upload all", uploadAll)
      const filter = { placeId: business.placeId };
      const update = {
        uploadedPhotos: uploadAll  
      }
      let updatedDoc = await Business.findOneAndUpdate(filter, update, {
        new: true
      });
      console.log("the updated doc", updatedDoc);
    }
  })
  res.send({
    totalNames: totalNames
  })
})

router.get('/updateBusiness',  async function(req, res){
 
  let businessSelectedCategories = [];
  const { place_id } = req.query
  const { category_id } = req.query
 
  businessSelectedCategories.push(mongoose.Types.ObjectId(category_id));
  
  const filter = { placeId : place_id};
  const update = {
    category: businessSelectedCategories, 
  }


  let updatedDoc = await Business.findOneAndUpdate(filter, update, {
    new: true
  });
  console.log("the updated doc", updatedDoc);
  res.send(updatedDoc)
})

router.post('/storeData', function(req, res) {
  let totalNames = [];
  let totalResults = [];
  let totalCountResults = 0;

  mixedData.data.map(async(business) => {
    
    let businessData =  await googleBusiness.findOne({ place_id: business.placeId })
    if(!businessData){
      const businessDetails = await getDetailsOfBusiness(business.placeId);
      console.log("the business detais", businessDetails)
      if(businessDetails){
        console.log("the business Detaials", businessDetails)
        totalNames.push(businessDetails.name)
        // console.log("the total Name", totalNames)
        totalResults.push(businessDetails)
        totalCountResults = totalCountResults + 1;
        const { location } = businessDetails.geometry; 
        let googleData = new googleBusiness(businessDetails)
        const getGoogleData = await googleData.save();

        let uploadPhotoResult = {}; 
        if(getGoogleData.photos && getGoogleData.photos.length > 0 )
          uploadPhotoResult = await uploadAllPhotos(getGoogleData.photos)
          console.log("the upload photoresult", uploadPhotoResult)
        let businessLocal = new Business( {
          placeId: getGoogleData.place_id,
          category: [],
          name: googleData.name,
          googleBusiness : mongoose.Types.ObjectId(googleData._id),
          location: {
            type: "Point",
            coordinates: [location.lng, location.lat ]  //[longitude, latitude]
          },
          uploadedPhotos : uploadPhotoResult
        });
        await businessLocal.save();
      }
    }
    console.log("the totoal names", totalNames)
  })

  res.send({ 
    totalNames,
    totalResults,
    totalCountResults
  });

});

router.get('/getBusiness', async (req, res)=>{
  const getBusiness =  await Business.findById(mongoose.Types.ObjectId('5fd83e7674710e0b68528ae4')).populate('googleBusiness')
  console.log("get business", getBusiness)
  res.send(getBusiness);
})

router.get('/uploadPhoto', async(req, res) => {
  // const photoReference = 'ATtYBwK6BOJcWTN_bZVK7xryLg1caQHSb5dkU8059rWW6c4HNBg7Daq-3KizjLJTSloAtjejn3aAXn_eMh_EuUZtzM8ZUtXx0u3i0gqGxgvs8yyuMOzVuAFYgMdb1ZycwZi7kS3mGzMyUdAPaktiyB8GlzoRm-sI3Fog7-KZ8fhtl4g8Xpia'
  const finalString = `https://maps.googleapis.com/maps/api/place/photo?maxwidth=400&photoreference=${photoReference}&key=AIzaSyAx3VG1J8LBgf02sGaIQOoEVgf71m4XP2w`;
  console.log(`the final string:: ${finalString}`)
  try{
    const getUrl = await cloudinary.uploader.upload(finalString);
    console.log("the get url::", getUrl);
  }
  catch(err){
    console.log("the err", err)
  }
})

router.get('/getGoogleMapsResults', async function (req, res, next) {
  
  const latitude = req.query.lat;
  const longitude = req.query.lon;
  const radius = req.query.radius;
  const {business_type} = req.query;
  const { search_text } = req.query;
    
  let detailCall = 1;
  let totalNames = [];
  let totalResults = [];
  let totalCountResults = 0 
  let noOfCalls = 50000;
  let pageToken = true;
  let first = true;
  while(first || (pageToken && noOfCalls !== 0)  ){
    // console.log("the page token", pageToken)
     let { data, nextPageToken } = await getAnother(latitude, longitude, radius, business_type, pageToken, first)
    //  let { data, nextPageToken } = await getBySearchText( search_text, pageToken, first, business_type)
    if (first)
      first = false;
    data.map(async(business) => {
      let businessData =  await googleBusiness.findOne({ place_id: business.place_id })
      if(!businessData){
        const businessDetails = await getDetailsOfBusiness(business.place_id);
        totalNames.push(businessDetails.name)
        console.log("the total Name", totalNames)
        totalResults.push(businessDetails)
        totalCountResults = totalCountResults + 1;
        const { location } = businessDetails.geometry; 
        let googleData = new googleBusiness(businessDetails)
        const getGoogleData = await googleData.save();

        let uploadPhotoResult = {}; 
        if(getGoogleData.photos && getGoogleData.photos.length > 0 )
          uploadPhotoResult = await uploadPhoto(getGoogleData.photos[0].photo_reference)
        
        let businessLocal = new Business( {
          placeId: getGoogleData.place_id,
          category: [],
          name: googleData.name,
          googleBusiness : mongoose.Types.ObjectId(googleData._id),
          location: {
            type: "Point",
            coordinates: [location.lng, location.lat ]  //[longitude, latitude]
          },
          uploadedPhotos : [uploadPhotoResult]
        });
        await businessLocal.save();
      }
    })
    await delay();
    if(!nextPageToken)
      pageToken = null
    else
      pageToken = nextPageToken;  
    if(noOfCalls === 0)
      pageToken = false;  
    noOfCalls = noOfCalls - 1; 
  }
  res.send({ 
    totalNames,
    totalResults,
    totalCountResults
  });
})

const uploadPhoto = async(photoReference) => {
  
  const finalString = `https://maps.googleapis.com/maps/api/place/photo?maxwidth=400&photoreference=${photoReference}&key=AIzaSyAx3VG1J8LBgf02sGaIQOoEVgf71m4XP2w`;
  try{
    const result = await cloudinary.uploader.upload(finalString);
    return result;
  }
  catch(err){
    console.log("the err", err)
  }
}

const uploadAllPhotos = async(photos) => {
  const totalphotosUrl = [];
  let i = 1
  for(let photo of photos){
    const finalString = `https://maps.googleapis.com/maps/api/place/photo?maxwidth=400&photoreference=${photo.photo_reference}&key=AIzaSyAx3VG1J8LBgf02sGaIQOoEVgf71m4XP2w`;
    try{
      if(i !== 0){
        const result = await cloudinary.uploader.upload(finalString);
        totalphotosUrl.push(result)
      }
      i = i-1;
    }
    catch(err){
      console.log("the err", err)
    }
  }
  return totalphotosUrl;
}



const getDetailsOfBusiness = async (placeId)=>{
  console.log("the place id", placeId)
  const details = await axios.get(`https://maps.googleapis.com/maps/api/place/details/json?place_id=${placeId}&key=AIzaSyAx3VG1J8LBgf02sGaIQOoEVgf71m4XP2w`);
  return details.data.result
}

const delay = (args) => new Promise((resolve) => {
  setTimeout(()=>{ resolve('ok') }, 1500);
});

const getAnother = async(latitude, longitude, radius, business_type, pageToken, first) => {
  console.log(`the latitude ${latitude} the longitude: ${longitude} the radius: ${radius} and businesType: ${business_type} `)
  let getBusiness  = '';
  if(!pageToken || first )
    getBusiness = await axios.get(`https://maps.googleapis.com/maps/api/place/nearbysearch/json?location=${latitude},${longitude}&radius=${radius}&type=${business_type}&key=AIzaSyAx3VG1J8LBgf02sGaIQOoEVgf71m4XP2w`);
  else{
    // console.log("in comingg")
    getBusiness = await axios.get(`https://maps.googleapis.com/maps/api/place/nearbysearch/json?location=${latitude},${longitude}&radius=${radius}&type=${business_type}&key=AIzaSyAx3VG1J8LBgf02sGaIQOoEVgf71m4XP2w&pagetoken=${pageToken}`);
  }
  console.log("the page token fetched", getBusiness.data.next_page_token);    
  return {  data: getBusiness.data.results,
            nextPageToken: getBusiness.data.next_page_token 
        }
}

const getBySearchText = async(searchText, pageToken, first, type) => {
  console.log(`the type ${type} and search text ${searchText} `)
  let getBusiness  = '';
  if(!pageToken || first )
    getBusiness = await axios.get(`https://maps.googleapis.com/maps/api/place/textsearch/json?query=${searchText}&key=AIzaSyAx3VG1J8LBgf02sGaIQOoEVgf71m4XP2w`);
  else{
    console.log("in comingg")
    getBusiness = await axios.get(`https://maps.googleapis.com/maps/api/place/textsearch/json?query=${searchText}&key=AIzaSyAx3VG1J8LBgf02sGaIQOoEVgf71m4XP2w&pagetoken=${pageToken}`);
  }
  console.log("the page toke token next", getBusiness.data.next_page_token);  
  return {  data: getBusiness.data.results,
            nextPageToken: getBusiness.data.next_page_token 
        }
}

router.get('/getSinglePlaceResult', async function (req, res, next) {
  const { place_id } = req.query
  console.log("the params in backend", req.query.place_id);
  const getData = await axios.get(`https://maps.googleapis.com/maps/api/place/details/json?place_id=${req.query.place_id}&key=AIzaSyAx3VG1J8LBgf02sGaIQOoEVgf71m4XP2w`);
  console.log("the resultss", getData.data.result)
  res.send(getData.data.result);

})

router.post('/createMessage', async function(req, res, next){
  var message = new Message({
    username: "nayyar",
    text: "mcdonalds",
    location: {
     type: "Point",
     coordinates: [-109.110492, 35.021112 ]  //[longitude, latitude]
    },
   });
  message.save((err, message) => {
    if (err) console.log(err);
    console.log(message);
    res.send(message)
   });
})

router.get('/getNearLocations', async function(req, res, next){
  
  const latitude = req.query.lat;
  const longitude = req.query.lon;
  const radius = req.query.radius;

  const getData = await Business.find({
    location: {
     $near: {
      $maxDistance: radius,
      $geometry: {
       type: "Point",
       coordinates: [longitude, latitude ]
      }
     }
    }
   }).find().populate('googleBusiness').limit(60)
     console.log("the getdata", getData);
   
   res.send( { totalCount: getData});
})

router.get('/getSearchTextResult', async function (req, res, next) {
  const { search_text } = req.query
  console.log("the params in backend", search_text);
  try{
    const getData = await axios.get(`https://maps.googleapis.com/maps/api/place/textsearch/json?query=${search_text}&key=AIzaSyD9CLs9poEBtI_4CHd5Y8cSHklQPoCi6NM`);
    console.log("the resultss", getData)
    res.send(getData.data.results);
  }catch(err){
    console.log("the error", err.response);
  }
})

module.exports = router