-
Notifications
You must be signed in to change notification settings - Fork 0
/
Copy pathindex.js
119 lines (93 loc) · 3.16 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
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
const puppeteer = require('puppeteer');
const { Telegraf } = require('telegraf');
require('dotenv').config();
const fs = require('fs');
const refreshTimeInSeconds = 2 * 60;
const numberOfMonthToCheck = 3;
const saveChats = (chats) => {
fs.writeFile('chats.json', JSON.stringify(chats), function (err) {
if (err) throw err;
console.log('Chats have been saved succesfully.');
});
}
(async () => {
const browser = await puppeteer.launch({args: ['--no-sandbox']});//{headless: false});
let chats = []
// load chats from chats.json file
try {
chats = JSON.parse(fs.readFileSync('chats.json'));
console.log(chats);
} catch {
console.log("No saved chats.");
}
const bot = new Telegraf(process.env.BOT_TOKEN)
bot.start(async (ctx) => {
ctx.reply("Willkommen beim Barberini Ticket Warnservice. Ich sende dir eine Nachricht sobald neue Tickets verfügbar sind!");
let chat = await ctx.getChat();
chat.lastMessage = "",
chats.push(chat);
console.log('added chat: ', chat);
saveChats(chats);
})
bot.hears('hi', (ctx) => ctx.reply('Hey there'))
bot.launch()
checkForTickets = async ()=> {
console.log("Checking for Tickets...")
const page = await browser.newPage();
await page.goto('https://shop.museum-barberini.com/#/tickets');
await page.setDefaultNavigationTimeout(0);
const availableDates = [];
const clickNextMonth = async () => {
await page.click('.barberini-tickets .day-selection .uib-right');
};
let monthIndex = 0;
page.on('response', async response => {
if (response.url().includes("/tickets/calendar")) {
response.text().then(async (text) => {
const responseObj = JSON.parse(text).data;
Object.keys(responseObj).forEach(function(date) {
var ticketsAvailable = responseObj[date];
if(!!ticketsAvailable){
availableDates.push(date);
}
});
if(monthIndex < numberOfMonthToCheck){
monthIndex++;
await clickNextMonth();
}
if (monthIndex === numberOfMonthToCheck){
let newMessage = `
Es gibt jetzt wieder Tickets für folgende Tage: ${availableDates}.
Klicke hier um Tickets zu buchen: https://shop.museum-barberini.com/#/tickets`;
if(availableDates.length > 0){
const idsSent = [];
chats.forEach(({lastMessage, id}, chatIndex) => {
if(newMessage !== lastMessage){
idsSent.push(id);
bot.telegram.sendMessage(id, newMessage);
chats[chatIndex].lastMessage = newMessage;
}
})
if (idsSent.length > 0){
saveChats(chats);
console.log(`
Sending Message:
'${newMessage}'
To chat ids: ${idsSent}
`);
}
}
page.close();
}
}).catch((e)=>{
// silently fail
});
}
});
}
const refreshData = async() => {
await checkForTickets();
setTimeout(refreshData, refreshTimeInSeconds*1000);
}
refreshData()
})();