chore: test with unstable_cache

Author: alexcambose

apps/insights/src/app/api/pyth/get-feeds/[symbol]/route.ts

@@ -1,7 +1,7 @@
 import { NextResponse } from "next/server";
 import { stringify } from 'superjson';
 
-import { getFeedsCached } from "../../../../../server/pyth/get-feeds";
+import { getFeedsCached } from "../../../../../server/pyth";
 import { Cluster } from "../../../../../services/pyth";
 
 export const GET = async (request: Request, { params }: { params: Promise<{ symbol: string }> }) => {

apps/insights/src/app/price-feeds/[slug]/layout.ts

@@ -2,7 +2,7 @@ import type { Metadata } from "next";
 import { notFound } from "next/navigation";
 import type { ReactNode } from "react";
 
-import { getFeedsCached } from "../../../server/pyth/get-feeds";
+import { getFeedsCached } from "../../../server/pyth";
 import { Cluster } from "../../../services/pyth";
 
 export { PriceFeedLayout as default } from "../../../components/PriceFeed/layout";

apps/insights/src/components/Overview/index.tsx

@@ -9,7 +9,7 @@ import PriceFeedsLight from "./price-feeds-light.svg";
 import PublishersDark from "./publishers-dark.svg";
 import PublishersLight from "./publishers-light.svg";
 import { TabList } from "./tab-list";
-import { getFeedsCached } from "../../server/pyth/get-feeds";
+import { getFeedsCached } from "../../server/pyth";
 import { Cluster } from "../../services/pyth";
 import {
   totalVolumeTraded,

apps/insights/src/components/Root/index.tsx

@@ -11,7 +11,7 @@ import {
 } from "../../config/server";
 import { LivePriceDataProvider } from "../../hooks/use-live-price-data";
 import { getPublishersCached } from '../../server/clickhouse';
-import { getFeedsCached } from '../../server/pyth/get-feeds';
+import { getFeedsCached } from '../../server/pyth';
 import { Cluster } from "../../services/pyth";
 import { PriceFeedIcon } from "../PriceFeedIcon";
 import { PublisherIcon } from "../PublisherIcon";

apps/insights/src/server/pyth.ts

@@ -1,9 +1,11 @@
+import { unstable_cache } from "next/cache";
 import { parse, } from "superjson";
 import { z } from "zod";
 
 import { PUBLIC_URL, VERCEL_AUTOMATION_BYPASS_SECRET } from '../config/server';
 import { Cluster, priceFeedsSchema } from "../services/pyth";
 import { DEFAULT_CACHE_TTL } from "../utils/cache";
+import { getFeedsCached as _getFeedsCached } from "./pyth/get-feeds";
 
 export async function getPublishersForFeedCached(
   cluster: Cluster,
@@ -36,19 +38,39 @@ export async function getFeedsForPublisherCached(
   return parse<z.infer<typeof priceFeedsSchema>>(rawData);
 }
 
+const _privateGetFeeds  =unstable_cache(async (cluster: Cluster) => {
+  const start = Date.now();
+  const feeds = await _getFeedsCached(cluster) as Omit<z.infer<typeof priceFeedsSchema>[number], 'price'>[];
+  const end = Date.now();
+  // eslint-disable-next-line no-console
+  console.log("internal getFeedsCached", cluster, end - start);
+  return feeds.map((feed) => ({
+    ...feed,
+    price: undefined,
+  }));
+  // const data = await fetch(`${PUBLIC_URL}/api/pyth/get-feeds?cluster=${cluster.toString()}&excludePriceComponents=true`, {
+  //   next: {
+  //     revalidate: DEFAULT_CACHE_TTL,
+  //   },
+  //   headers: {
+  //     'x-vercel-protection-bypass': VERCEL_AUTOMATION_BYPASS_SECRET,
+  //   },
+  // });
+  // const dataJson = await data.text();
+  // const feeds: Omit<z.infer<typeof priceFeedsSchema>[0], "price">[] = parse(dataJson);
+  // return feeds;
+}, [], {
+  revalidate: DEFAULT_CACHE_TTL,
+});
+
 export const getFeedsCached = async (cluster: Cluster) => {
-  const data = await fetch(`${PUBLIC_URL}/api/pyth/get-feeds?cluster=${cluster.toString()}&excludePriceComponents=true`, {
-    next: {
-      revalidate: DEFAULT_CACHE_TTL,
-    },
-    headers: {
-      'x-vercel-protection-bypass': VERCEL_AUTOMATION_BYPASS_SECRET,
-    },
-  });
-  const dataJson = await data.text();
-  const feeds: Omit<z.infer<typeof priceFeedsSchema>[0], "price">[] = parse(dataJson);
-  return feeds;
-}
+  const start = Date.now();
+  const data = await _privateGetFeeds(cluster);
+  const end = Date.now();
+  // eslint-disable-next-line no-console
+  console.log("getFeedsCached", end - start);
+  return data;
+};
 
 export const getFeedForSymbolCached = async ({symbol, cluster = Cluster.Pythnet}: {symbol: string, cluster?: Cluster}): Promise<z.infer<typeof priceFeedsSchema>[0] | undefined> => {
   const data = await fetch(`${PUBLIC_URL}/api/pyth/get-feeds/${encodeURIComponent(symbol)}?cluster=${cluster.toString()}`, {