diff --git a/src/server/routes.go b/src/server/routes.go index c040fbe..b563768 100644 --- a/src/server/routes.go +++ b/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) diff --git a/src/storage/feed.go b/src/storage/feed.go index 5588bae..0988b37 100644 --- a/src/storage/feed.go +++ b/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) - } -} diff --git a/src/storage/migration.go b/src/storage/migration.go index 9793e76..2b785cb 100644 --- a/src/storage/migration.go +++ b/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 +} diff --git a/src/worker/worker.go b/src/worker/worker.go index c64cd97..5302572 100644 --- a/src/worker/worker.go +++ b/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()