Compare commits
3 Commits
| Author | SHA1 | Date | |
|---|---|---|---|
| 64190a500d | |||
| dcbf937d38 | |||
| 08c92ca74d |
3
.gitignore
vendored
3
.gitignore
vendored
@@ -1 +1,4 @@
|
|||||||
nlink.conf
|
nlink.conf
|
||||||
|
nlink.db
|
||||||
|
nlink
|
||||||
|
nlink.exe
|
||||||
|
|||||||
17
main.go
17
main.go
@@ -121,16 +121,18 @@ func main() {
|
|||||||
die.If(err)
|
die.If(err)
|
||||||
}
|
}
|
||||||
|
|
||||||
log.Debugln("config keys")
|
log.Infoln("nlink is starting")
|
||||||
for _, k := range config.ListKeys() {
|
|
||||||
log.Debugf("key: %s", k)
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Debugf("loading config file %s\n", configFile)
|
log.Debugf("loading config file %s\n", configFile)
|
||||||
if err := config.LoadFile(configFile); err != nil {
|
if err := config.LoadFile(configFile); err != nil {
|
||||||
log.Fatal(err)
|
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"))
|
log.Infof("minio_bucket: %s", config.Get("minio_bucket"))
|
||||||
if err := restoreDatabase(config.Get("local_database")); err != nil {
|
if err := restoreDatabase(config.Get("local_database")); err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
@@ -166,12 +168,15 @@ func main() {
|
|||||||
|
|
||||||
log.Debugf("will look for new items every %s\n", interval)
|
log.Debugf("will look for new items every %s\n", interval)
|
||||||
for {
|
for {
|
||||||
|
log.Infoln("running fetch loop")
|
||||||
for _, feed := range feeds {
|
for _, feed := range feeds {
|
||||||
log.Infoln("fetching items")
|
log.Infof("fetching items for feed %s", feed)
|
||||||
if err := fetchItems(db, feed, markOnly); err != nil {
|
if err := fetchItems(db, feed, markOnly); err != nil {
|
||||||
log.Info(err)
|
log.Errln(err)
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
time.Sleep(interval)
|
time.Sleep(interval)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
log.Infoln("exiting")
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -58,7 +58,12 @@ func restoreDatabase(path string) error {
|
|||||||
defer dbFile.Close()
|
defer dbFile.Close()
|
||||||
|
|
||||||
_, err = io.Copy(dbFile, obj)
|
_, err = io.Copy(dbFile, obj)
|
||||||
return err
|
if err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
log.Debugln("database restored from minio")
|
||||||
|
return nil
|
||||||
}
|
}
|
||||||
|
|
||||||
func saveDatabase(path string) error {
|
func saveDatabase(path string) error {
|
||||||
@@ -91,5 +96,7 @@ func saveDatabase(path string) error {
|
|||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
log.Debugln("database saved to minio")
|
||||||
return nil
|
return nil
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user