Salastil/streamwall
1
0
Fork 0
mirror of https://github.com/streamwall/streamwall.git synced 2026-04-03 20:32:08 -04:00
Code Issues Packages Projects Releases Wiki Activity

Add error handling to public data fetching

Browse Source
This commit is contained in:
Max Goodhart
2020-06-21 21:13:09 -07:00
parent c25e5d5f59
commit ebcc0c8b2a
1 changed files with 8 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/node/data.js
View File

@@ -14,9 +14,14 @@ export async function* pollPublicData() {
const publicDataURL = 'https://woke.net/csv' const publicDataURL = 'https://woke.net/csv'
const refreshInterval = 5 * 60 * 1000 const refreshInterval = 5 * 60 * 1000
while (true) { while (true) {
let data
try {
const resp = await fetch(publicDataURL) const resp = await fetch(publicDataURL)
const text = await resp.text() const text = await resp.text()
const data = await csv().fromString(text) data = await csv().fromString(text)
} catch (err) {
console.warn('error loading stream data', err)
}
yield filterLive(data) yield filterLive(data)
await sleep(refreshInterval) await sleep(refreshInterval)
} }