entry_unread.go 2.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798
  1. // SPDX-FileCopyrightText: Copyright The Miniflux Authors. All rights reserved.
  2. // SPDX-License-Identifier: Apache-2.0
  3. package ui // import "miniflux.app/v2/internal/ui"
  4. import (
  5. "net/http"
  6. "miniflux.app/v2/internal/http/request"
  7. "miniflux.app/v2/internal/http/response"
  8. "miniflux.app/v2/internal/model"
  9. "miniflux.app/v2/internal/ui/view"
  10. )
  11. func (h *handler) showUnreadEntryPage(w http.ResponseWriter, r *http.Request) {
  12. user, err := h.store.UserByID(request.UserID(r))
  13. if err != nil {
  14. response.HTMLServerError(w, r, err)
  15. return
  16. }
  17. entryID := request.RouteInt64Param(r, "entryID")
  18. entry, err := h.store.NewEntryQueryBuilder(user.ID).
  19. WithEntryID(entryID).
  20. GetEntry()
  21. if err != nil {
  22. response.HTMLServerError(w, r, err)
  23. return
  24. }
  25. if entry == nil {
  26. response.HTMLRedirect(w, r, h.routePath("/unread"))
  27. return
  28. }
  29. // Make sure we always get the pagination in unread mode even if the page is refreshed.
  30. if entry.Status == model.EntryStatusRead {
  31. err = h.store.SetEntriesStatus(user.ID, []int64{entry.ID}, model.EntryStatusUnread)
  32. if err != nil {
  33. response.HTMLServerError(w, r, err)
  34. return
  35. }
  36. }
  37. prevEntry, nextEntry, err := h.store.NewEntryPaginationBuilder(user.ID, entry.ID, user.EntryOrder, user.EntryDirection).
  38. WithStatus(model.EntryStatusUnread).
  39. WithGloballyVisible().
  40. Entries()
  41. if err != nil {
  42. response.HTMLServerError(w, r, err)
  43. return
  44. }
  45. nextEntryRoute := ""
  46. if nextEntry != nil {
  47. nextEntryRoute = h.routePath("/unread/entry/%d", nextEntry.ID)
  48. }
  49. prevEntryRoute := ""
  50. if prevEntry != nil {
  51. prevEntryRoute = h.routePath("/unread/entry/%d", prevEntry.ID)
  52. }
  53. if entry.ShouldMarkAsReadOnView(user) {
  54. entry.Status = model.EntryStatusRead
  55. }
  56. // Restore entry read status if needed after fetching the pagination.
  57. if entry.Status == model.EntryStatusRead {
  58. err = h.store.SetEntriesStatus(user.ID, []int64{entry.ID}, model.EntryStatusRead)
  59. if err != nil {
  60. response.HTMLServerError(w, r, err)
  61. return
  62. }
  63. }
  64. if user.AlwaysOpenExternalLinks {
  65. response.HTMLRedirect(w, r, entry.URL)
  66. return
  67. }
  68. view := view.New(h.tpl, r)
  69. view.Set("entry", entry)
  70. view.Set("prevEntry", prevEntry)
  71. view.Set("nextEntry", nextEntry)
  72. view.Set("nextEntryRoute", nextEntryRoute)
  73. view.Set("prevEntryRoute", prevEntryRoute)
  74. view.Set("menu", "unread")
  75. view.Set("user", user)
  76. // Fetching the counters here avoids being off by one.
  77. navMetadata, _ := h.store.GetNavMetadata(user.ID)
  78. view.Set("countUnread", navMetadata.CountUnread)
  79. view.Set("countErrorFeeds", navMetadata.CountErrorFeeds)
  80. view.Set("hasSaveEntry", navMetadata.HasSaveEntry)
  81. response.HTML(w, r, view.Render("entry"))
  82. }