remove feed_sizes

src/server/routes.go

@@ -252,7 +252,6 @@ func (s *Server) handleFeedList(c *router.Context) {
 			items := worker.ConvertItems(result.Feed.Items, *feed)
 			if len(items) > 0 {
 				s.db.CreateItems(items)
-				s.db.SetFeedSize(feed.Id, len(items))
 				s.db.SyncSearch()
 			}
 			s.worker.FindFeedFavicon(*feed)

src/storage/feed.go

@@ -216,16 +216,3 @@ func (s *Storage) GetFeedErrors() map[int64]string {
 	}
 	return errors
 }
-
-func (s *Storage) SetFeedSize(feedId int64, size int) {
-	_, err := s.db.Exec(`
-		insert into feed_sizes (feed_id, size)
-		values (:feed_id, :size)
-		on conflict (feed_id) do update set size = excluded.size`,
-		sql.Named("feed_id", feedId),
-		sql.Named("size", size),
-	)
-	if err != nil {
-		log.Print(err)
-	}
-}

src/storage/migration.go

@@ -19,6 +19,7 @@ var migrations = []func(*sql.Tx) error{
 	m09_change_item_index,
 	m10_add_item_medialinks,
 	m11_add_item_last_arrived,
+	m12_remove_feed_sizes,
 }
 
 var maxVersion = int64(len(migrations))
@@ -339,3 +340,8 @@ func m11_add_item_last_arrived(tx *sql.Tx) error {
 	_, err := tx.Exec(sql)
 	return err
 }
+
+func m12_remove_feed_sizes(tx *sql.Tx) error {
+	_, err := tx.Exec(`drop table if exists feed_sizes`)
+	return err
+}

src/worker/worker.go

@@ -124,7 +124,6 @@ func (w *Worker) refresher(feeds []storage.Feed) {
 		items := <-dstqueue
 		if len(items) > 0 {
 			w.db.CreateItems(items)
-			w.db.SetFeedSize(items[0].FeedId, len(items))
 		}
 		atomic.AddInt32(w.pending, -1)
 		w.db.SyncSearch()