peter/ekster
1
0
Fork 0
Code Issues 3 Pull Requests Projects 3 Releases 1 Wiki Activity

Create more notifications for errors while processing feeds
All checks were successful
continuous-integration/drone/push Build is passing
Details

Browse Source
This commit is contained in:
Peter Stuifzand 2021-10-29 23:58:58 +02:00
parent 822ad38cfc
commit 3365b38e5a
Signed by: peter
GPG Key ID: 374322D56E5209E8
1 changed files with 21 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

32
cmd/eksterd/memory.go
View File

@ -343,22 +343,21 @@ func (b *memoryBackend) RefreshFeeds() {
for uid := range feeds { for uid := range feeds {
for _, feedURL := range feeds[uid] { for _, feedURL := range feeds[uid] {
log.Println(feedURL) log.Println("Processing", feedURL)
resp, err := b.Fetch3(uid, feedURL) resp, err := b.Fetch3(uid, feedURL)
if err != nil { if err != nil {
_ = b.channelAddItem("notifications", microsub.Item{
Type: "entry",
Name: "Error while fetching feed",
Content: &microsub.Content{
Text: fmt.Sprintf("Error while updating feed %s: %v", feedURL, err),
},
UID: time.Now().String(),
})
count++
log.Printf("Error while Fetch3 of %s: %v\n", feedURL, err) log.Printf("Error while Fetch3 of %s: %v\n", feedURL, err)
b.addNotification("Error while fetching feed", feedURL, err)
count++
continue
}
err = b.ProcessContent(uid, feedURL, resp.Header.Get("Content-Type"), resp.Body)
if err != nil {
log.Printf("Error while processing content for %s: %v\n", feedURL, err)
b.addNotification("Error while processing feed", feedURL, err)
count++
continue continue
} }
_ = b.ProcessContent(uid, feedURL, resp.Header.Get("Content-Type"), resp.Body)
_ = resp.Body.Close() _ = resp.Body.Close()
} }
} }
@ -368,6 +367,17 @@ func (b *memoryBackend) RefreshFeeds() {
} }
} }
func (b *memoryBackend) addNotification(name string, feedURL string, err error) {
_ = b.channelAddItem("notifications", microsub.Item{
Type: "entry",
Name: name,
Content: &microsub.Content{
Text: fmt.Sprintf("Error while updating feed %s: %v", feedURL, err),
},
UID: time.Now().String(),
})
}
func (b *memoryBackend) TimelineGet(before, after, channel string) (microsub.Timeline, error) { func (b *memoryBackend) TimelineGet(before, after, channel string) (microsub.Timeline, error) {
log.Printf("TimelineGet %s\n", channel) log.Printf("TimelineGet %s\n", channel)