Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| dcbf937d38 | |||
| 08c92ca74d | |||
| d0929f5b01 |
3
.gitignore
vendored
3
.gitignore
vendored
@@ -1 +1,4 @@
|
||||
nlink.conf
|
||||
nlink.db
|
||||
nlink
|
||||
nlink.exe
|
||||
|
||||
19
main.go
19
main.go
@@ -2,7 +2,6 @@ package main
|
||||
|
||||
import (
|
||||
"flag"
|
||||
"os"
|
||||
"path/filepath"
|
||||
"strings"
|
||||
"time"
|
||||
@@ -122,16 +121,16 @@ func main() {
|
||||
die.If(err)
|
||||
}
|
||||
|
||||
log.Debugln("config keys")
|
||||
for _, k := range config.ListKeys() {
|
||||
log.Debugf("key: %s", k)
|
||||
}
|
||||
|
||||
log.Debugf("loading config file %s\n", configFile)
|
||||
if err := config.LoadFile(configFile); err != nil {
|
||||
log.Fatal(err)
|
||||
}
|
||||
|
||||
log.Debugln("config keys")
|
||||
for _, k := range config.ListKeys() {
|
||||
log.Debugf("key: %s", k)
|
||||
}
|
||||
|
||||
log.Infof("minio_bucket: %s", config.Get("minio_bucket"))
|
||||
if err := restoreDatabase(config.Get("local_database")); err != nil {
|
||||
log.Fatal(err)
|
||||
@@ -165,15 +164,17 @@ func main() {
|
||||
return
|
||||
}
|
||||
|
||||
os.Exit(1)
|
||||
log.Debugf("will look for new items every %s\n", interval)
|
||||
for {
|
||||
log.Infoln("running fetch loop")
|
||||
for _, feed := range feeds {
|
||||
log.Infoln("fetching items")
|
||||
log.Infof("fetching items for feed %s", feed)
|
||||
if err := fetchItems(db, feed, markOnly); err != nil {
|
||||
log.Info(err)
|
||||
log.Errln(err)
|
||||
}
|
||||
}
|
||||
time.Sleep(interval)
|
||||
}
|
||||
|
||||
log.Infoln("exiting")
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user