feat: support read/unread state tracking and setting

Author: DCsunset

backend/lfreader_server/app.py

@@ -37,7 +37,7 @@
 
 from .storage import Storage
 from .config import Config
-from .models import AppState, AppStatus, QueryEntriesArgs, FetchFeedsArgs, ArchiveFeedsArgs, CleanFeedsArgs, DeleteFeedsArgs, UpdateFeedsArgs
+from .models import AppState, AppStatus, QueryEntriesArgs, FetchFeedsArgs, ArchiveFeedsArgs, CleanFeedsArgs, DeleteFeedsArgs, UpdateFeedsArgs, UpdateEntriesArgs
 
 
 try:
@@ -142,9 +142,28 @@ async def feed_action_api(
       storage.update_feeds(args.feeds)
       state.update()
     case _:
-      raise HTTPException(status_code=400, detail=f"Invalid action: {args.action}")
+      raise HTTPException(status_code=400, detail=f"Invalid feed action: {args.action}")
   return {}
 
+
+"""
+Entry Action API
+"""
+@app.post("/entries")
+async def entry_action_api(
+  args: UpdateEntriesArgs
+):
+  match args.action:
+    case "update":
+      storage.update_entries(args.entries)
+      state.update()
+    case _:
+      raise HTTPException(status_code=400, detail=f"Invalid entry action: {args.action}")
+  return {}
+
+
+
+
 ## Error handlers
 
 # use plaintext for HTTP and validation exceptions

backend/lfreader_server/models.py

@@ -88,3 +88,20 @@ class UpdateFeedsArgs(BaseModel):
   action: Literal["update"]
   feeds: list[FeedInfo]
 
+
+### Entry Action API (tagged union)
+
+class EntryInfo(BaseModel):
+  feed_url: str
+  entry_id: str
+  user_data: dict
+
+  # allow using subscript to access
+  def __getitem__(self, item):
+    return getattr(self, item)
+
+
+class UpdateEntriesArgs(BaseModel):
+  action: Literal["update"]
+  entries: list[EntryInfo]
+

backend/lfreader_server/storage.py

@@ -35,7 +35,7 @@
 from .archive import Archiver
 from .config import Config
 from .utils import async_map, sql_update_field
-from .models import QueryEntry, FeedInfo
+from .models import QueryEntry, FeedInfo, EntryInfo
 
 # for logging
 def entry_title(e):
@@ -484,6 +484,15 @@ def get_entries(
   ) -> list[dict]:
     return self.get_entries_cursor(feed_urls, entries, offset, limit, columns).fetchall()
 
+  def update_entries(self, entries: list[EntryInfo]):
+    cur = self.db.cursor()
+    for e in entries:
+      cur.execute(
+        "UPDATE entries SET user_data = ? WHERE feed_url = ? AND id = ?",
+        (pack_data(e.user_data), e.feed_url, e.entry_id)
+      )
+    self.db.commit()
+
   def update_feeds(self, feeds: list[FeedInfo]):
     cur = self.db.cursor()
     for f in feeds:

frontend/package-lock.json

@@ -18,6 +18,7 @@
 		"@preact/signals": "^2.0.4",
 		"@types/katex": "^0.16.7",
 		"highlight.js": "^11.11.1",
+		"immutable": "^5.1.1",
 		"js-base64": "^3.7.7",
 		"katex": "^0.16.22",
 		"luxon": "^3.6.1",

frontend/package.json

@@ -16,8 +16,8 @@
 
 import { computed, signal } from "@preact/signals";
 import { createRef } from "preact";
-import { appState, computedState, lookupEntry, lookupFeed  } from "../store/state";
-import { textCategories, Enclosure, Feed, getEntryTitle, getFeedTitle, toEntryId } from "../store/feed";
+import { appState, computedState, lookupEntryUrl, lookupFeed } from "../store/state";
+import { textCategories, Enclosure, getEntryTitle, getFeedTitle, toEntryId } from "../store/feed";
 import Icon from "@mdi/react";
 import renderMathInElement from "katex/contrib/auto-render";
 import hljs from "highlight.js";
@@ -118,7 +118,7 @@ export default function Entry() {
       element.querySelectorAll("a").forEach((el: HTMLElement) => {
         try {
           const url = new URL(el.getAttribute("href") || "");
-          const e = lookupEntry(url.origin);
+          const e = lookupEntryUrl(url.origin);
           if (e) {
             // replace external link with internal link
             el.setAttribute("href", `/?${new URLSearchParams({