Browse Source

update with signal message

fix-broken-scrape
Jørgen Sverre Lien Sellæg 4 years ago
parent
commit
301e31f291
  1. 32
      bin/adapter.mjs
  2. 8
      bin/run.sh

32
bin/adapter.mjs

@ -76,12 +76,8 @@ const get_place = (event) => {
} else { } else {
place = ''; place = '';
} }
if (place === '' || place == null) { if (place == null) {
console.log(event); place = '';
console.log(place);
if (place === undefined) {
process.exit(1);
}
} }
return place; return place;
}; };
@ -119,7 +115,6 @@ const sleep = (ms) => new Promise((res) => setTimeout(res, ms));
`${hostname}/search/events/?facebook_id=${event.facebook_id}&token=${token}` `${hostname}/search/events/?facebook_id=${event.facebook_id}&token=${token}`
); );
if (!search.ok) { if (!search.ok) {
console.error(117, search.status);
console.error(118, 'search not ok'); console.error(118, 'search not ok');
console.error(119, await search.text()); console.error(119, await search.text());
await sleep(1000); await sleep(1000);
@ -134,22 +129,35 @@ const sleep = (ms) => new Promise((res) => setTimeout(res, ms));
if (old_event.ticket_url.length > 0 && event.ticket_url.length == 0) { if (old_event.ticket_url.length > 0 && event.ticket_url.length == 0) {
delete event.ticket_url; delete event.ticket_url;
} }
console.error('132', event);
res = await fetch(`${hostname}/events/${event.id}/?token=${token}`, { res = await fetch(`${hostname}/events/${event.id}/?token=${token}`, {
method: 'PATCH', method: 'PATCH',
body: JSON.stringify(event), body: JSON.stringify(event),
headers: { 'Content-Type': 'application/json' } headers: { 'Content-Type': 'application/json' }
}); });
console.error(138, await res.text()); console.error(137, 'Updated');
console.error(139, 'update');
} else { } else {
res = await fetch(`${hostname}/events/?token=${token}`, { res = await fetch(`${hostname}/events/?token=${token}`, {
method: 'POST', method: 'POST',
body: JSON.stringify(event), body: JSON.stringify(event),
headers: { 'Content-Type': 'application/json' } headers: { 'Content-Type': 'application/json' }
}); });
console.error(146, 'new'); let newEvent = await res.text();
console.error(145, newEvent);
try {
newEvent = JSON.parse(newEvent);
await fetch(`http://localhost:8080/v2/send`, {
body: JSON.stringify({
message: `${new Date(newEvent.start * 1000)} ${newEvent.name}`,
number: '+4793478353',
recipients: ['dansbart.dev']
}),
method: 'POST',
headers: { 'Content-Type': 'application/json' }
});
} catch (e) {
console.error(e);
}
} }
console.error(148, res.status); console.error(161, res.status);
} }
})(); })();

8
bin/run.sh

@ -95,3 +95,11 @@ scrape_page 1858914204185866 events/trondheimstage-1858914204185866.json
scrape_page 237410323543222 events/tyventrondheim-237410323543222.json scrape_page 237410323543222 events/tyventrondheim-237410323543222.json
scrape_page 697776233588499 events/uffabookingcrew-697776233588499.json scrape_page 697776233588499 events/uffabookingcrew-697776233588499.json
scrape_page 965958530110723 events/vaarfruekirke-965958530110723.json scrape_page 965958530110723 events/vaarfruekirke-965958530110723.json
scrape_page 176869899002150 events/Nordenfjelske-176869899002150.json
scrape_page 1558392151139397 events/stammencafe-1558392151139397.json
scrape_page 309437036672672 events/sykkelgruppe-309437036672672.json
scrape_page 211200805559797 events/ringe-botaniske-211200805559797.json
scrape_page 236371750502642 events/galleri-hanne-236371750502642.json
scrape_page 127803117302354 events/modern-art-gallery-127803117302354.json
scrape_page 2056532634661437 events/kuk-2056532634661437.json
scrape_page 104735766271007 events/trondelag-teater-104735766271007.json

Loading…
Cancel
Save