diff options
Diffstat (limited to 'cleaner.go')
-rw-r--r-- | cleaner.go | 7 |
1 files changed, 7 insertions, 0 deletions
@@ -19,6 +19,7 @@ const ( ) func cleanData() (err error) { + db, err := sql.Open("mysql", DATABASE_USER+":"+DATABASE_PASS+"@/"+DATABASE_NAME) if err != nil { log.Println("Failed to connect to db") @@ -26,6 +27,12 @@ func cleanData() (err error) { } defer db.Close() + //Remove the processed mark on entries older than 1 day + err = reprocess(db, time.Now().Add(-24*1*time.Hour)) + if err != nil { + return + } + //Fetch data that should be cleaned rDat, err := fetchRawData(db, MAXIMUM_ENTRIES) if err != nil { |