43 lines
614 B
Go
43 lines
614 B
Go
package rss
|
|
|
|
import (
|
|
"local/rssmon3/config"
|
|
"local/rssmon3/monitor"
|
|
"log"
|
|
)
|
|
|
|
type RSS struct {
|
|
items chan *monitor.Item
|
|
config.Stoppable
|
|
}
|
|
|
|
func New(items chan *monitor.Item) *RSS {
|
|
return &RSS{
|
|
items: items,
|
|
}
|
|
}
|
|
|
|
func (rss *RSS) Run() error {
|
|
for {
|
|
select {
|
|
case <-rss.Stopped():
|
|
return nil
|
|
case i := <-rss.items:
|
|
if err := rss.update(i); err != nil {
|
|
log.Println("[rss.Run]", err)
|
|
}
|
|
}
|
|
}
|
|
}
|
|
|
|
func (rss *RSS) update(item *monitor.Item) error {
|
|
f := newFeed(item.Key)
|
|
if err := f.Pull(); err != nil {
|
|
return err
|
|
}
|
|
if err := f.save(); err != nil {
|
|
return err
|
|
}
|
|
return nil
|
|
}
|