-
Notifications
You must be signed in to change notification settings - Fork 3
/
index.js
54 lines (47 loc) · 2.27 KB
/
index.js
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
// si estamos en desarrollo, requerimos el archivo '.env'
// en producción, esa configuración se recibe directamente como variables de entorno
if (process.env.NODE_ENV === 'development') {
require('dotenv').config()
}
const cache = require('memory-cache')
const microCors = require('micro-cors')
const { send } = require('micro')
const getEvents = require('./lib/get-events')
const getMeetups = require('./lib/get-meetups')
const blackList = process.env.BLACK_LIST ? process.env.BLACK_LIST.split(',') : []
const cacheExpiration = parseInt(process.env.CACHE_EXPIRATION)
const cors = microCors({
allowMethods: ['GET']
})
const whiteList = process.env.WHITE_LIST ? process.env.WHITE_LIST.split(',') : []
async function handler(req, res) {
try {
// si el resultado del API no fue previamente cacheado
if (!cache.get('data')) {
// obtenemos un array de meetups que corresponden al rango es búsqueda
const data = await getMeetups()
// filtramos los eventos que no queremos que aparezcan
.then(eventsList =>
eventsList.filter(event => !blackList.includes(event.id.toString()))
)
// agregamos los meetups que queremos que aparezcan que no entran en el rango de búsqueda
.then(meetups => meetups.concat(whiteList.map(m => ({ urlname: m }))))
// buscamos los eventos de esos meetups
.then(meetups => meetups.map(m => getEvents(m.urlname)))
// cuando obtengamos toda la información, vamos a tener un array de arrays,
// donde cada uno es una lista de eventos
.then(eventsProms => Promise.all(eventsProms))
// generamos un array de 1 solo nivel por medio de un reduce
// que solo concatena todos los eventos de los diferentes meetups
.then(eventsLists =>
eventsLists.reduce((output, events) => output.concat(events), [])
)
// guardamos los datos en cache por el tiempo indicado por configuración
cache.put('data', data, cacheExpiration)
}
send(res, 200, cache.get('data'))
} catch (error) {
send(res, 500, error.message)
}
}
module.exports = cors(handler)