aboutsummaryrefslogtreecommitdiff
path: root/internal/ui/entry_scraper.go
diff options
context:
space:
mode:
authorGravatar Frédéric Guillot <f@miniflux.net> 2023-08-10 19:46:45 -0700
committerGravatar Frédéric Guillot <f@miniflux.net> 2023-08-10 20:29:34 -0700
commit168a870c025bfef6efdeb46e166e79a16093c157 (patch)
tree4d8ab69c7e3ef03a7ade06e7b5e5053429a64c3b /internal/ui/entry_scraper.go
parentc2349032552891745cbbc3d2a9e772845a0239f4 (diff)
downloadv2-168a870c025bfef6efdeb46e166e79a16093c157.tar.gz
v2-168a870c025bfef6efdeb46e166e79a16093c157.tar.zst
v2-168a870c025bfef6efdeb46e166e79a16093c157.zip
Move internal packages to an internal folder
For reference: https://go.dev/doc/go1.4#internalpackages
Diffstat (limited to 'internal/ui/entry_scraper.go')
-rw-r--r--internal/ui/entry_scraper.go70
1 files changed, 70 insertions, 0 deletions
diff --git a/internal/ui/entry_scraper.go b/internal/ui/entry_scraper.go
new file mode 100644
index 00000000..b26bf04c
--- /dev/null
+++ b/internal/ui/entry_scraper.go
@@ -0,0 +1,70 @@
+// SPDX-FileCopyrightText: Copyright The Miniflux Authors. All rights reserved.
+// SPDX-License-Identifier: Apache-2.0
+
+package ui // import "miniflux.app/v2/internal/ui"
+
+import (
+ "net/http"
+
+ "miniflux.app/v2/internal/http/request"
+ "miniflux.app/v2/internal/http/response/json"
+ "miniflux.app/v2/internal/locale"
+ "miniflux.app/v2/internal/model"
+ "miniflux.app/v2/internal/proxy"
+ "miniflux.app/v2/internal/reader/processor"
+ "miniflux.app/v2/internal/storage"
+)
+
+func (h *handler) fetchContent(w http.ResponseWriter, r *http.Request) {
+ loggedUserID := request.UserID(r)
+ entryID := request.RouteInt64Param(r, "entryID")
+
+ entryBuilder := h.store.NewEntryQueryBuilder(loggedUserID)
+ entryBuilder.WithEntryID(entryID)
+ entryBuilder.WithoutStatus(model.EntryStatusRemoved)
+
+ entry, err := entryBuilder.GetEntry()
+ if err != nil {
+ json.ServerError(w, r, err)
+ return
+ }
+
+ if entry == nil {
+ json.NotFound(w, r)
+ return
+ }
+
+ user, err := h.store.UserByID(entry.UserID)
+ if err != nil {
+ json.ServerError(w, r, err)
+ }
+ if user == nil {
+ json.NotFound(w, r)
+ }
+
+ feedBuilder := storage.NewFeedQueryBuilder(h.store, loggedUserID)
+ feedBuilder.WithFeedID(entry.FeedID)
+ feed, err := feedBuilder.GetFeed()
+ if err != nil {
+ json.ServerError(w, r, err)
+ return
+ }
+
+ if feed == nil {
+ json.NotFound(w, r)
+ return
+ }
+
+ if err := processor.ProcessEntryWebPage(feed, entry, user); err != nil {
+ json.ServerError(w, r, err)
+ return
+ }
+
+ if err := h.store.UpdateEntryContent(entry); err != nil {
+ json.ServerError(w, r, err)
+ }
+
+ readingTime := locale.NewPrinter(user.Language).Plural("entry.estimated_reading_time", entry.ReadingTime, entry.ReadingTime)
+
+ json.OK(w, r, map[string]string{"content": proxy.ProxyRewriter(h.router, entry.Content), "reading_time": readingTime})
+}