delete old items

server/server.go

@@ -38,7 +38,7 @@ func (h *Handler) startJobs() {
 		}			
 	}()
 	go h.db.SyncSearch()
-	//h.fetchAllFeeds()
+	h.fetchAllFeeds()
 }
 
 func (h *Handler) fetchFeed(feed storage.Feed) {
@@ -141,6 +141,7 @@ func writeJSON(rw http.ResponseWriter, data interface{}) {
 
 func New() *http.Server {
 	db, _ := storage.New()
+	db.DeleteOldItems()
 	h := Handler{
 		db: db,
 		feedQueue: make(chan storage.Feed),

storage/item.go

@@ -310,3 +310,19 @@ func (s *Storage) SyncSearch() {
 		}
 	}
 }
+
+func (s *Storage) DeleteOldItems() {
+	result, err := s.db.Exec(
+		`delete from items where status = ? and date < ?`,
+		READ, time.Now().Add(-time.Hour * 24 * 90) /* 90 days */)
+	if err != nil {
+		s.log.Print(err)
+		return
+	}
+	num, err := result.RowsAffected()
+	if err != nil {
+		s.log.Print(err)
+		return
+	}
+	s.log.Printf("Deleted %d items\n", num)
+}