commit - 4b027dd5ebf86a899817b235cb999dc9cd37f2a8
commit + 54640ca00f76c1b4298c39a494603a3468c916b3
blob - e13d3e5bec8d3e544e132b865037605b3202a231
blob + d703d35406a6ac437561fcde96b4bc3023beb867
--- internal/db/channels.go
+++ internal/db/channels.go
import (
"encoding/json"
+ "errors"
"github.com/streatCodes/rss/rss"
bolt "go.etcd.io/bbolt"
return err
}
+var ErrNotExist = errors.New("channel does not exist")
+
func (db *DB) GetChannel(url string) (*rss.Channel, error) {
var channelBytes []byte
err := db.raw.View(func(tx *bolt.Tx) error {
if bucket := tx.Bucket(channelsBucket); bucket != nil {
channelBytes = bucket.Get([]byte(url))
}
+ if len(channelBytes) == 0 {
+ return ErrNotExist
+ }
return nil
})