{entries.data?.pages.map((page) =>
page.data?.map((entry) => (
-
)),
)}
diff --git a/src/renderer/src/queries/entries.ts b/src/renderer/src/queries/entries.ts
index 58a1a19708..e671615bf5 100644
--- a/src/renderer/src/queries/entries.ts
+++ b/src/renderer/src/queries/entries.ts
@@ -1,10 +1,8 @@
-import {
- UnprocessableEntityError,
-} from "@renderer/biz/error"
+import { UnprocessableEntityError } from "@renderer/biz/error"
import { useBizInfiniteQuery } from "@renderer/hooks/useBizQuery"
-import { levels } from "@renderer/lib/constants"
import { defineQuery } from "@renderer/lib/defineQuery"
import { apiClient } from "@renderer/queries/api-fetch"
+import { entryActions } from "@renderer/store/entry"
export const entries = {
entries: ({
@@ -20,26 +18,15 @@ export const entries = {
}) =>
defineQuery(
["entries", level, id, view, read],
- async ({ pageParam }) => {
- const params: {
- feedId?: string
- feedIdList?: string[]
- } = {}
- if (level === levels.folder) {
- params.feedIdList = `${id}`.split(",")
- } else if (level === levels.feed) {
- params.feedId = `${id}`
- }
- const res = await apiClient.entries.$post({
- json: {
- publishedAfter: pageParam as string,
- view,
- read,
- ...params,
- },
- })
- return await res.json()
- },
+ async ({ pageParam }) =>
+
+ entryActions.fetchEntries({
+ level,
+ id,
+ view,
+ read,
+ pageParam: pageParam as string,
+ }),
{
rootKey: ["entries"],
},
diff --git a/src/renderer/src/store/entry.ts b/src/renderer/src/store/entry.ts
new file mode 100644
index 0000000000..43ba33637c
--- /dev/null
+++ b/src/renderer/src/store/entry.ts
@@ -0,0 +1,120 @@
+import { levels } from "@renderer/lib/constants"
+import type { EntryModel } from "@renderer/lib/types"
+import { apiClient } from "@renderer/queries/api-fetch"
+import type { InferResponseType } from "hono/client"
+import { produce } from "immer"
+import { create } from "zustand"
+
+type EntriesIdTable = Record
>
+
+interface EntryState {
+ entries: EntriesIdTable
+
+ flatMapEntries: Record
+}
+
+interface EntryActions {
+ fetchEntries: (params: {
+ level?: string
+ id?: number | string
+ view?: number
+ read?: boolean
+
+ pageParam?: string
+ }) => Promise>
+ upsert: (feedId: string, entry: EntryModel) => void
+ optimisticUpdate: (entryId: string, changed: Partial) => void
+ getFlattenMapEntries: () => Record
+}
+
+export const useEntryStore = create(
+ (set, get) => ({
+ entries: {},
+ flatMapEntries: {},
+
+ actions: {
+ fetchEntries: async ({
+ level,
+ id,
+ view,
+ read,
+
+ pageParam,
+ }: {
+ level?: string
+ id?: number | string
+ view?: number
+ read?: boolean
+
+ pageParam?: string
+ }) => {
+ const params: {
+ feedId?: string
+ feedIdList?: string[]
+ } = {}
+ if (level === levels.folder) {
+ params.feedIdList = `${id}`.split(",")
+ } else if (level === levels.feed) {
+ params.feedId = `${id}`
+ }
+ const res = await apiClient.entries.$post({
+ json: {
+ publishedAfter: pageParam as string,
+ view,
+ read,
+ ...params,
+ },
+ })
+
+ const data = await res.json()
+
+ if (data.data) {
+ data.data.forEach((entry: EntryModel) => {
+ get().actions.upsert(entry.feeds.id, entry)
+ })
+ }
+ return data
+ },
+
+ getFlattenMapEntries() {
+ return get().flatMapEntries
+ },
+ optimisticUpdate(entryId: string, changed: Partial) {
+ set((state) =>
+ produce(state, (draft) => {
+ const entry = draft.flatMapEntries[entryId]
+ if (!entry) return
+ Object.assign(entry, changed)
+ return draft
+ }),
+ )
+ },
+
+ upsert(feedId: string, entry: EntryModel) {
+ set((state) =>
+ produce(state, (draft) => {
+ if (!draft.entries[feedId]) {
+ draft.entries[feedId] = {}
+ }
+ draft.entries[feedId][entry.entries.id] = entry
+ draft.flatMapEntries[entry.entries.id] = entry
+ return draft
+ }),
+ )
+ },
+ },
+ }),
+)
+
+export const entryActions = useEntryStore.getState().actions
+
+export const useEntriesByFeedId = (feedId: string) =>
+ useEntryStore((state) => state.entries[feedId])
+export const useEntry = (entryId: string) =>
+ useEntryStore((state) => state.flatMapEntries[entryId])
+
+Object.assign(window, {
+ get __entry() {
+ return useEntryStore.getState()
+ },
+})