local
/
rssmon3
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix leveldb problems 

Former-commit-id: f17fe73babf8910a2031323ffb2a28979082a4dd
master v0.2
bel 2019-06-22 17:06:50 -06:00
parent 9faa727261
commit 21d5bad2a5
3 changed files with 8 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
.gitignore vendored
View File

@ -1,3 +1,4 @@
rssmon3 rssmon3
exec-rssmon3 exec-rssmon3
**.sw* **.sw*
**testdata

8
monitor/queue.go
View File

@ -1,7 +1,9 @@
package monitor package monitor
import ( import (
"fmt"
"local/rssmon3/config" "local/rssmon3/config"
"local/storage"
"log" "log"
"github.com/golang-collections/go-datastructures/queue" "github.com/golang-collections/go-datastructures/queue"
@ -17,13 +19,15 @@ func newQueue() (*Queue, error) {
q := queue.NewPriorityQueue(1) q := queue.NewPriorityQueue(1)
db := config.Values().DB db := config.Values().DB
keys, err := db.List([]string{nsQueued}) keys, err := db.List([]string{nsQueued})
if err != nil { if err == storage.ErrNotFound {
keys = []string{}
} else if err != nil {
return nil, err return nil, err
} }
for _, key := range keys { for _, key := range keys {
b, err := db.Get(key, nsQueued) b, err := db.Get(key, nsQueued)
if err != nil { if err != nil {
return nil, err return nil, fmt.Errorf("failed to get %s:%s: %v", nsQueued, key, err)
} }
i := &Item{} i := &Item{}
if err := i.Decode(b); err != nil { if err := i.Decode(b); err != nil {

2
testdata/2add vendored
View File

@ -38,7 +38,7 @@ https://www.youtube.com/feeds/videos.xml?channel_id=UCs-w7E2HZWwXmjt9RTvBB_A
https://roosterteeth.com/show/rt-podcast/feed/mp3 podcast ".*" ".*" "6h" https://roosterteeth.com/show/rt-podcast/feed/mp3 podcast ".*" ".*" "6h"
' '
feedsB="$(printf "%s\n" "$feeds" | grep -v '^$' | tail -n 1)" feedsB="$(printf "%s\n" "$feeds" | grep -v '^$' | tail -n 1)"
#feeds="$feedsB" feeds="$feedsB"
defaultIF='""' defaultIF='""'
defaultCF='"<img.*?/(img)?>"' defaultCF='"<img.*?/(img)?>"'