nodejs cronjob

1/**
2 @description CRONJOB RATE LIMIT REQUEST API MIDDLEWARE
3*/
4const cron = require('node-schedule')
5const axios = require('axios')
6
7/**
8 @description store ip address  user to array
9*/
10const IpAddress = []
11
12/**
13 @description fetch data from provider isp
14*/
15const IpGeolocation = async () => {
16  const ip = {}
17  const res = await axios.get('http://ipwhois.app/json/')
18  Object.defineProperty(ip, 'ipv4', { value: res.data.ip, enumerable: true })
19  return ip.ipv4
20}
21
22/**
23 @description reset  ip address after 1 minute
24*/
25const ResetRateLimit = () => {
26  const schedule = new cron.RecurrenceRule()
27  schedule.second = 59
28  schedule.tz = 'asia/jakarta'
29
30  cron.scheduleJob('ResetRateLimit', schedule, () => {
31    IpAddress.splice(0, IpAddress.length)
32  })
33}
34
35module.exports = async (req, res, next) => {
36  /**
37 @description result current IP Location from provider isp
38*/
39  const myIp = await IpGeolocation()
40
41  /**
42   @description get any request method  from user after sending data or request data
43  */
44  switch (req.method) {
45    case 'GET':
46      if (IpAddress.length < 7) {
47        IpAddress.push(myIp)
48      }
49      break
50    case 'POST':
51      if (IpAddress.length < 7) {
52        IpAddress.push(myIp)
53      }
54      break
55    default:
56      return next()
57  }
58
59  /**
60   @description get total requests from the same ip
61  */
62  const currentIp = IpAddress.filter((v, i) => v === myIp).length
63
64  /**
65   @description if the same ip requests more than 5 throw an error message
66  */
67  if (currentIp > 4) {
68    return res.status(401).json({
69      method: req.method,
70      status: res.statusCode,
71      error: 'Oopss..request method not allowed many to request'
72    })
73  }
74
75  /**
76   @description return to next function if  after reset ip address
77  */
78  ResetRateLimit()
79  return next()
80}