-
diff --git a/src/server/earnings/headline.ts b/src/server/earnings/headline.ts
new file mode 100644
index 000000000..5091429ee
--- /dev/null
+++ b/src/server/earnings/headline.ts
@@ -0,0 +1,56 @@
+import { Redis } from '@upstash/redis'
+import {
+ lifetimeEarningsHeadlineSchema,
+ type TLifetimeEarningsHeadline
+} from '@/components/shared/utils/schemas/lifetimeEarningsSchema'
+
+export const LIFETIME_EARNINGS_REDIS_KEY = 'lifetime_yield:headline'
+
+const rawHeadlineSchema = lifetimeEarningsHeadlineSchema.omit({ value: true, computed_at_ms: true })
+
+const redisState: { client: Redis | null } = { client: null }
+
+function getRedisClient(): Redis {
+ if (!redisState.client) {
+ const url = process.env.UPSTASH_REDIS_REST_URL_EARNINGS || process.env.UPSTASH_REDIS_REST_URL
+ const token = process.env.UPSTASH_REDIS_REST_TOKEN_EARNINGS || process.env.UPSTASH_REDIS_REST_TOKEN
+ if (!url || !token) {
+ throw new Error(
+ 'UPSTASH_REDIS_REST_URL_EARNINGS and UPSTASH_REDIS_REST_TOKEN_EARNINGS (or the unsuffixed fallbacks) must both be set'
+ )
+ }
+
+ redisState.client = new Redis({ url, token })
+ }
+
+ return redisState.client
+}
+
+/**
+ * Read the raw snapshot from Redis and extrapolate it to "now" on the server.
+ * Runs at ISR revalidation time; the client keeps extrapolating from
+ * `computed_at_ms` using `rate_usd_per_sec`. The 30d-averaged rate makes the
+ * figure tolerant of long stale periods by design, so no live re-sync channel
+ * is needed.
+ */
+export async function getLifetimeEarningsHeadline(): Promise {
+ const blob = await getRedisClient().get(LIFETIME_EARNINGS_REDIS_KEY)
+ if (blob === null || blob === undefined) {
+ throw new Error(`Redis key ${LIFETIME_EARNINGS_REDIS_KEY} is missing`)
+ }
+
+ const raw = rawHeadlineSchema.parse(typeof blob === 'string' ? JSON.parse(blob) : blob)
+ const computedAtMs = Date.now()
+ const value = raw.net_yield_usd + (raw.rate_usd_per_sec * (computedAtMs - raw.as_of_ms)) / 1000
+ return { ...raw, value, computed_at_ms: computedAtMs }
+}
+
+/** Null on any failure — the badge simply does not render without data. */
+export async function getLifetimeEarningsHeadlineOrNull(): Promise {
+ try {
+ return await getLifetimeEarningsHeadline()
+ } catch (error) {
+ console.warn('[SSR] Failed to read lifetime earnings headline', error)
+ return null
+ }
+}
diff --git a/src/server/ssr/publicDataHydration.test.ts b/src/server/ssr/publicDataHydration.test.ts
index d0399086f..2cf200a12 100644
--- a/src/server/ssr/publicDataHydration.test.ts
+++ b/src/server/ssr/publicDataHydration.test.ts
@@ -1,16 +1,8 @@
import { afterEach, beforeEach, describe, expect, it, vi } from 'vitest'
import { YVBTC_CHAIN_ID, YVBTC_UNLOCKED_ADDRESS } from '@/components/pages/vaults/utils/yvBtc'
import { YVUSD_CHAIN_ID, YVUSD_LOCKED_ADDRESS, YVUSD_UNLOCKED_ADDRESS } from '@/components/pages/vaults/utils/yvUsd'
-import {
- buildVaultSnapshotEndpoint,
- YEARN_TVL_ENDPOINT,
- YEARN_VAULT_LIST_ENDPOINT
-} from '@/components/shared/data/publicQueryEndpoints'
-import {
- getLandingPageDehydratedState,
- getVaultDetailPageDehydratedState,
- getVaultsPageDehydratedState
-} from './publicDataHydration'
+import { buildVaultSnapshotEndpoint, YEARN_VAULT_LIST_ENDPOINT } from '@/components/shared/data/publicQueryEndpoints'
+import { getVaultDetailPageDehydratedState, getVaultsPageDehydratedState } from './publicDataHydration'
const DETAIL_ADDRESS = '0x0000000000000000000000000000000000000001'
@@ -41,9 +33,6 @@ describe('public data SSR hydration', () => {
'fetch',
vi.fn(async (url: string | URL | Request) => {
const requestUrl = url.toString()
- if (requestUrl === YEARN_TVL_ENDPOINT) {
- return jsonResponse(123456)
- }
if (requestUrl === YEARN_VAULT_LIST_ENDPOINT) {
return jsonResponse([])
}
@@ -59,13 +48,6 @@ describe('public data SSR hydration', () => {
vi.unstubAllGlobals()
})
- it('hydrates the landing TVL query', async () => {
- const state = await getLandingPageDehydratedState()
-
- expect(queryKeys(state)).toContainEqual(['fetch', YEARN_TVL_ENDPOINT])
- expect(state.queries[0]?.state.data).toBe(123456)
- })
-
it('hydrates only the main vault list query used by the vaults page', async () => {
const state = await getVaultsPageDehydratedState()
const keys = queryKeys(state)
diff --git a/src/server/ssr/publicDataHydration.ts b/src/server/ssr/publicDataHydration.ts
index 4ca1712f9..00d4b24c4 100644
--- a/src/server/ssr/publicDataHydration.ts
+++ b/src/server/ssr/publicDataHydration.ts
@@ -1,5 +1,5 @@
import { type DehydratedState, dehydrate, QueryClient } from '@tanstack/react-query'
-import * as z from 'zod'
+import type * as z from 'zod'
import {
buildVaultsInitialPayload,
type TVaultsInitialPayload
@@ -11,19 +11,13 @@ import {
YVUSD_UNLOCKED_ADDRESS
} from '@/components/pages/vaults/utils/yvUsd'
import { PUBLIC_VAULT_DATA_CACHE_TIME } from '@/components/shared/data/publicQueryCache'
-import {
- buildVaultSnapshotEndpoint,
- YEARN_TVL_ENDPOINT,
- YEARN_VAULT_LIST_ENDPOINT
-} from '@/components/shared/data/publicQueryEndpoints'
+import { buildVaultSnapshotEndpoint, YEARN_VAULT_LIST_ENDPOINT } from '@/components/shared/data/publicQueryEndpoints'
import { fetchWithSchema, getFetchQueryKey } from '@/components/shared/utils/fetchQuery'
import { kongVaultListSchema } from '@/components/shared/utils/schemas/kongVaultListSchema'
import { kongVaultSnapshotSchema } from '@/components/shared/utils/schemas/kongVaultSnapshotSchema'
-const LANDING_TVL_STALE_TIME = 2 * 60 * 1000
const VAULT_LIST_STALE_TIME = PUBLIC_VAULT_DATA_CACHE_TIME
const VAULT_SNAPSHOT_STALE_TIME = PUBLIC_VAULT_DATA_CACHE_TIME
-const LANDING_TVL_TIMEOUT_MS = 1500
const VAULT_LIST_TIMEOUT_MS = 3500
const VAULT_SNAPSHOT_TIMEOUT_MS = 7000
@@ -124,20 +118,6 @@ async function prefetchRelatedVaultDetailSnapshots(
])
}
-export async function getLandingPageDehydratedState(): Promise {
- const queryClient = createSsrQueryClient()
-
- await prefetchPublicQuery({
- queryClient,
- endpoint: YEARN_TVL_ENDPOINT,
- schema: z.number(),
- staleTime: LANDING_TVL_STALE_TIME,
- timeoutMs: LANDING_TVL_TIMEOUT_MS
- })
-
- return dehydrateQueryClient(queryClient)
-}
-
export async function getVaultsPageDehydratedState(): Promise {
const queryClient = createSsrQueryClient()
+
+ )
+}
diff --git a/src/components/shared/components/TvlStat.tsx b/src/components/shared/components/TvlStat.tsx
deleted file mode 100644
index ae4ce982a..000000000
--- a/src/components/shared/components/TvlStat.tsx
+++ /dev/null
@@ -1,20 +0,0 @@
-import { formatAmount } from '@shared/utils'
-
-import type { ReactElement } from 'react'
-
-export function TvlStat({ tvl }: { tvl: number }): ReactElement {
- return (
-
+ {'$'}
+
{'Lifetime earned by Yearn Vaults'}
+
-
- )
-}
diff --git a/src/components/shared/data/publicQueryEndpoints.ts b/src/components/shared/data/publicQueryEndpoints.ts
index 3b4be864f..5f8224a12 100644
--- a/src/components/shared/data/publicQueryEndpoints.ts
+++ b/src/components/shared/data/publicQueryEndpoints.ts
@@ -2,7 +2,6 @@ import { KONG_REST_BASE } from '@pages/vaults/utils/kongRest'
import { isAddress } from 'viem'
import { toAddress } from '../utils'
-export const YEARN_TVL_ENDPOINT = 'https://api.llama.fi/tvl/yearn'
export const YEARN_VAULT_LIST_ENDPOINT = `${KONG_REST_BASE}/list/vaults`
export function buildVaultSnapshotEndpoint(chainId?: number | string, address?: string): string | null {
diff --git a/src/components/shared/utils/schemas/lifetimeEarningsSchema.ts b/src/components/shared/utils/schemas/lifetimeEarningsSchema.ts
new file mode 100644
index 000000000..d2c0fe338
--- /dev/null
+++ b/src/components/shared/utils/schemas/lifetimeEarningsSchema.ts
@@ -0,0 +1,21 @@
+import * as z from 'zod'
+
+/**
+ * Lifetime-earnings headline served by /api/earnings/headline.
+ *
+ * A compute bot writes the raw snapshot fields to Redis; the server
+ * extrapolates them to `value` at `computed_at_ms` and the client keeps the
+ * number moving from there using `rate_usd_per_sec`.
+ */
+export const lifetimeEarningsHeadlineSchema = z.object({
+ net_yield_usd: z.number(),
+ as_of_ms: z.number(),
+ rate_usd_per_sec: z.number().nonnegative(),
+ prev_net_yield_usd: z.number(),
+ prev_as_of_ms: z.number(),
+ run_id: z.string(),
+ value: z.number(),
+ computed_at_ms: z.number()
+})
+
+export type TLifetimeEarningsHeadline = z.infer
-
-
-
- - {'$'} - {formatAmount(tvl ?? 0, 0, 0)} - {' deposited in Yearn Vaults'} - {' in Yearn'} -
-