app.js

require('dotenv').config({ path: 'variables.env' })
const express = require('express')
const path = require('path')
const cors = require('cors')
const moment = require('moment')
const fetch = require('node-fetch')
const schedule = require('node-schedule')
const cookieParser = require('cookie-parser')
const KosherZmanim = require('kosher-zmanim')
const NodeGeocoder = require('node-geocoder')
const geocoder = NodeGeocoder({ provider: 'openstreetmap' })
const webPush = require('web-push')
const MongoClient = require('mongodb').MongoClient
const { ObjectId } = require('mongodb')
const { resolveSoa } = require('dns')
const app = express()
const port = process.env.PORT || 5000

const dburl = process.env.DBURL
app.use(cookieParser())

app.set('view engine', 'ejs')
app.use(express.json())
app.use(cors())
app.options('*', cors())

const publicVapidKey = process.env.PUBLIC_VAPID_KEY
const privateVapidKey = process.env.PRIVATE_VAPID_KEY
webPush.setVapidDetails('mailto:tmeemoot@gmail.com', publicVapidKey, privateVapidKey)

const utcOffsetHours = '+03:00';

app.post("/subscribe", async function (req, res) {
  const subscription = req.body;
  if (!subscription.name || !subscription.city) {
    // בדיקה שהיוזר כתב שם ועיר
    res.status(401).json("name or city not declare");
  } else {
    const locates = await geocoder.geocode(subscription.city); // ארבע השורות הבאות - בדיקה שהיוזר לא חירטט עיר
    if (!Array.isArray(locates) || !locates.length) {
      console.log("not an city");
      return "nocity";
    } else {
      const latitude = locates[0].latitude;
      const longitude = locates[0].longitude;
      const cityname = locates[0].city;
      if (req.cookies.userid) {
        const userID = req.cookies.userid;
        console.log(`user change notify settings but we find userid in cookies.. ${userID}`);
        const client = await MongoClient.connect(dburl, { useUnifiedTopology: true });
        const record = await client.db("main").collection("users").findOneAndUpdate({ _id: ObjectId(userID) }, { $set: { name: subscription.name, city: subscription.city, lat: latitude, long: longitude } });
        if (record) {
          console.log(`user options updated: name - ${subscription.name}, city - ${cityname}`);
          res.status(201).json({ city: cityname });
          const payload = JSON.stringify({ title: "הגדרות ההתראה שלך השתנו בהצלחה", body: `נתריע לך רבע שעה לפני השקיעה ב${cityname}` });
          webPush.sendNotification(subscription.subscription, payload).catch((error) => console.error(error));
        }
      } else {
        const client = await MongoClient.connect(dburl, { useUnifiedTopology: true });
        const userkeys = { name: subscription.name, city: cityname, lat: latitude, long: longitude, endpoint: subscription.subscription.endpoint, expiriationTime: subscription.subscription.expiriationTime, keys: { p256dh: subscription.subscription.keys.p256dh, auth: subscription.subscription.keys.auth }, stop: false };
        const result = await client.db("main").collection("users").insertOne(userkeys); // רושמים את היוזר במסד נתונים
        const objid = result.insertedId; // מקבלים את המזהה של היוזר שנוצר במסד נתונים
        console.log(`userid is ${objid}, created succesfuly - name is ${subscription.name} and city is ${cityname}`);
        res.cookie("userid", objid, { expires: new Date("2022/01/20") }); // יוצרים עוגייה עם הערך של המזהה הנ"ל
        res.status(201).json({ city: cityname });
        console.log("userid cookie created successfully");
        const payload = JSON.stringify({
          title: "נרשמת בהצלחה, להתראות לפני שקיעה",
          body: `נתריע לך רבע שעה לפני השקיעה ב${cityname}`,
        });
        webPush.sendNotification(subscription.subscription, payload).catch((error) => console.error(error));
      }
    }
  }
});

app.use(express.static(path.join(__dirname, 'views')))

app.get('/', (req, res) => {
  res.render('index')
})

app.get("/api", async function (req, res) {
  console.log(`new api call..`);
  let city = req.query.city;
  if (!city) {
    console.log(`city not declared`);
    res.status(400).json(`you have to pass cityname to the request..`);
  } else {
    const zmanim = await gettimesforcity(city);
    if (zmanim == "nocity") {
      res.status(400).json("city not found... 😥😥");
    } else {
      res.status(200).json(zmanim);
    }
  }
});

// כשהאתר עולה, פונקציה בפרונטאנד מבקשת מהשרת נתונים על המשתמש, לשורה העליונה של האתר
app.post('/user', async function (req, res) {
  console.log('new visit, searching if theres a user cookie')
  if (req.cookies.userid) {
    const userID = req.cookies.userid // מזהים את היוזר לפי העוגייה שמכילה את המזהה שלו במסד נתונים
    console.log(`user cookie found with this id: ${userID}`)
    const client = await MongoClient.connect(dburl, { useUnifiedTopology: true })
    const doc = await client.db('main').collection('users').findOne({ _id: ObjectId(userID) })
    if (!doc) {
      console.log('id not found on DB')
      res.status(404).json('we cant find your userid in our DB... strange')
    } else {
      console.log('id match in DB. sending data to user')
      res.status(200).json({ name: doc.name, city: doc.city, stop: doc.stop })
    }
  } else {
    res.status(404).json('no user cookie found')
  }
})

// נותנים ליוזר לעשות פוס להתראות
app.post('/stop', async function (req, res) {
  console.log(`user request to stop push. user id is ${req.cookies.userid}`)
  if (req.cookies.userid) {
    const userID = req.cookies.userid
    const client = await MongoClient.connect(dburl, { useUnifiedTopology: true })
    const record = await client.db('main').collection('users').findOneAndUpdate({ _id: ObjectId(userID) }, { $set: { stop: true } })
    if (!record) {
      console.log('id not found on DB')
      res.status(404).json('we cant find your userid in our DB... strange')
    } else {
      console.log('id match in DB. sending data to user')
      res.status(202).json('ok, push stopped for you')
    }
  } else {
    res.status(404).json('no user cookie found')
  }
})

// ולבטל את הפוס
app.post('/start', async function (req, res) {
  console.log(`user request to stop push. user id is ${req.cookies.userid}`)
  if (req.cookies.userid) {
    const userID = req.cookies.userid
    const client = await MongoClient.connect(dburl, { useUnifiedTopology: true })
    const record = await client.db('main').collection('users').findOneAndUpdate({ _id: ObjectId(userID) }, { $set: { stop: false } })
    if (!record) {
      console.log('id not found on DB')
      res.status(404).json('we cant find your userid in our DB... strange')
    } else {
      console.log('id match in DB. sending data to user')
      res.status(202).json('ok, push started back for you')
    }
  } else {
    res.status(404).json('no user cookie found')
  }
})

app.post('/', async function (req, res) {
  console.log(`user check city manualy. his req is ${req.body.city}`)
  const zmanim = await gettimesforcity(req.body.city)
  if (zmanim == 'nocity') {
    res.status(404).json(`no city named ${req.body.city}`)
  } else {
    console.log(`got the answer... sending to user`)
    console.log(zmanim)
    res.status(200).json({ city: zmanim.cityname, zmanim: zmanim })
  }
})

app.listen(port, () => {
  console.log(`app started and listening at http://localhost:${port}`)
})

async function push (id) {
  const client = await MongoClient.connect(dburl, { useUnifiedTopology: true })
  const doc = await client.db('main').collection('users').findOne({ _id: ObjectId(id) })
  let sunset = await gettimesforcity(doc.city)
  sunset = sunset.shkia
  sunset = sunset.toString()
  sunset = sunset.slice(16, 21)
  const payload = JSON.stringify({
    title: 'תזכורת - שקיעת החמה',
    body: `שים לב! השקיעה ב${doc.city} עוד כרבע שעה\nבשעה ${sunset}\nהתפללת כבר מנחה? ותפילין 😉`
  })
  const pushkeys = { endpoint: doc.endpoint, keys: { p256dh: doc.keys.p256dh, auth: doc.keys.auth } }
  webPush.sendNotification(pushkeys, payload).catch((error) => console.error(error))
}

async function getsunforcity (citly) {
  const geolocation = await geocoder.geocode(citly)
  if (!Array.isArray(geolocation) || !geolocation.length) {
    console.log('not an city')
    return 'nocity'
  } else {
    const options = {
      date: Date.now(),
      timeZoneId: 'Asia/Jerusalem',
      locationName: geolocation[0].city,
      latitude: geolocation[0].latitude,
      longitude: geolocation[0].longitude,
      elevation: 0,
      complexZmanim: (boolean = false)
    }
    let sunset = KosherZmanim.getZmanimJson(options).BasicZmanim.Sunset
    sunset = new Date(sunset)
    sunset = moment(sunset).utcOffset(utcOffsetHours)
    return sunset
  }
}

async function gettimesforcity (citly) {
  const geolocation = await geocoder.geocode(citly)
  if (!Array.isArray(geolocation) || !geolocation.length) {
    console.log('not an city')
    return 'nocity'
  } else {
    const options = {
      date: Date.now(),
      timeZoneId: 'Asia/Jerusalem',
      locationName: geolocation[0].city,
      latitude: geolocation[0].latitude,
      longitude: geolocation[0].longitude,
      elevation: 0,
      complexZmanim: (boolean = false)
    }
    let netz = KosherZmanim.getZmanimJson(options).BasicZmanim.Sunrise
    let gra = KosherZmanim.getZmanimJson(options).BasicZmanim.SofZmanShmaGRA
    let chatzos = KosherZmanim.getZmanimJson(options).BasicZmanim.Chatzos
    let shkia = KosherZmanim.getZmanimJson(options).BasicZmanim.Sunset
    netz = new Date(netz)
    gra = new Date(gra)
    chatzos = new Date(chatzos)
    shkia = new Date(shkia)
    netz = moment(netz).utcOffset(utcOffsetHours)
    gra = moment(gra).utcOffset(utcOffsetHours)
    chatzos = moment(chatzos).utcOffset(utcOffsetHours)
    shkia = moment(shkia).utcOffset(utcOffsetHours)
    netz = moment(netz).format('kk:mm:ss')
    gra = moment(gra).format('kk:mm:ss')
    chatzos = moment(chatzos).format('kk:mm:ss')
    shkia = moment(shkia).format('kk:mm:ss')
    const zmanim = { cityname: geolocation[0].city, netz: netz, gra: gra, chatzos: chatzos, shkia: shkia }
    return zmanim
    }
}

async function checksun () { // חישוב הפושים לכל אחד מהיוזרים במסד נתונים, ויצירת טיימאאוטים לכל אחד
  console.log('started scheduled job - calculating pushes for everyone')
  const client = await MongoClient.connect(dburl, { useUnifiedTopology: true })
  const result = await client.db('main').collection('users').find({}).toArray()
  console.log(`there is ${result.length} users in push DB:`)
  for (const user of result) {
    if (user.stop !== true) {
      const city = user.city
      const id = user._id
      const timeforcity = await getsunforcity(city)
      let thistime = new Date(Date.now())
      thistime = moment(thistime).utcOffset(utcOffsetHours)
      let destime = moment.duration(timeforcity - thistime).asMilliseconds()
      destime = destime - 900000 // הורדה של רבע שעה
      if (destime < 0) {
        destime = destime + 86400000
      }
      console.log(`shkia for ${user.name} is in ${moment(timeforcity).format('kk:mm:ss')}, and now is ${moment(thistime).format('kk:mm:ss')}. remaining time in ms - ${destime}`)
      setTimeout(push, destime, id)
    } else {
      console.log(`userid ${user._id} requested to stop push...`)
    }
  }
}

schedule.scheduleJob('0 14 * * *', function () { checksun() }) // הרצה של חישוב הפושים לכולם, בשעה ארבע בצהריים של השרת