|
|
|
@ -221,7 +221,7 @@ const open_browser = async () => { |
|
|
|
return browser; |
|
|
|
return browser; |
|
|
|
}; |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
const register_upcoming_events_listener = (endpoint, page) => { |
|
|
|
const register_page_scraper = (endpoint, page) => { |
|
|
|
let responses = []; |
|
|
|
let responses = []; |
|
|
|
return new Promise((resolve, reject) => { |
|
|
|
return new Promise((resolve, reject) => { |
|
|
|
page.on('response', async (response) => { |
|
|
|
page.on('response', async (response) => { |
|
|
|
@ -249,13 +249,10 @@ const register_upcoming_events_listener = (endpoint, page) => { |
|
|
|
}); |
|
|
|
}); |
|
|
|
}; |
|
|
|
}; |
|
|
|
|
|
|
|
|
|
|
|
const get_upcoming_events = async (browser, page_id) => { |
|
|
|
const get_page_events = async (browser, page_id) => { |
|
|
|
let scraping = true; |
|
|
|
let scraping = true; |
|
|
|
const facebook_page = await browser.newPage(); |
|
|
|
const facebook_page = await browser.newPage(); |
|
|
|
const upcoming_events = register_upcoming_events_listener( |
|
|
|
const upcoming_events = register_page_scraper(graphql_endpoint, facebook_page) |
|
|
|
graphql_endpoint, |
|
|
|
|
|
|
|
facebook_page, |
|
|
|
|
|
|
|
) |
|
|
|
|
|
|
|
.then((upcoming_events) => { |
|
|
|
.then((upcoming_events) => { |
|
|
|
scraping = false; |
|
|
|
scraping = false; |
|
|
|
return upcoming_events; |
|
|
|
return upcoming_events; |
|
|
|
@ -285,5 +282,5 @@ module.exports = { |
|
|
|
open_browser, |
|
|
|
open_browser, |
|
|
|
parse_args, |
|
|
|
parse_args, |
|
|
|
read_previous_events, |
|
|
|
read_previous_events, |
|
|
|
get_upcoming_events, |
|
|
|
get_page_events, |
|
|
|
}; |
|
|
|
}; |
|
|
|
|