feat: add cached methods

Author: Alexandru Cambose

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

@@ -2,7 +2,8 @@ import type { Metadata } from "next";
 import { notFound } from "next/navigation";
 import type { ReactNode } from "react";
 
-import { Cluster, getFeeds } from "../../../services/pyth";
+import { getFeedsCached } from "../../../server/pyth";
+import { Cluster } from "../../../services/pyth";
 
 export { PriceFeedLayout as default } from "../../../components/PriceFeed/layout";
 
@@ -19,7 +20,7 @@ export const generateMetadata = async ({
 }: Props): Promise<Metadata> => {
   const [{ slug }, feeds] = await Promise.all([
     params,
-    getFeeds(Cluster.Pythnet),
+    getFeedsCached(Cluster.Pythnet),
   ]);
   const symbol = decodeURIComponent(slug);
   const feed = feeds.find((item) => item.symbol === symbol);

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

@@ -9,7 +9,8 @@ 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 { Cluster, getFeeds } from "../../services/pyth";
+import { getFeedsCached } from "../../server/pyth";
+import { Cluster } from "../../services/pyth";
 import {
   totalVolumeTraded,
   activeChains,
@@ -23,7 +24,7 @@ import { FormattedDate } from "../FormattedDate";
 import { FormattedNumber } from "../FormattedNumber";
 
 export const Overview = async () => {
-  const priceFeeds = await getFeeds(Cluster.Pythnet);
+  const priceFeeds = await getFeedsCached(Cluster.Pythnet);
   const today = new Date();
   const feedCounts = [
     ...activeFeeds.map(({ date, numFeeds }) => ({

apps/insights/src/components/PriceFeed/get-feed.tsx

@@ -1,20 +1,16 @@
 import { notFound } from "next/navigation";
 
-import { Cluster, getFeeds } from "../../services/pyth";
+import { getFeedsCached } from "../../server/pyth";
+import { Cluster } from "../../services/pyth";
 
 export const getFeed = async (params: Promise<{ slug: string }>) => {
   "use cache";
 
-  const [{ slug }, feeds] = await Promise.all([params, getPythnetFeeds()]);
+  const [{ slug }, feeds] = await Promise.all([params, getFeedsCached(Cluster.Pythnet)]);
   const symbol = decodeURIComponent(slug);
   return {
     feeds,
     feed: feeds.find((item) => item.symbol === symbol) ?? notFound(),
     symbol,
   } as const;
 };
-
-const getPythnetFeeds = async () => {
-  "use cache";
-  return getFeeds(Cluster.Pythnet);
-};

apps/insights/src/components/PriceFeed/publishers.tsx

@@ -1,17 +1,16 @@
 import { lookup as lookupPublisher } from "@pythnetwork/known-publishers";
 import { notFound } from "next/navigation";
 
+import { PublishersCard } from "./publishers-card";
+import { getFeedsCached, getPublishersForFeedCached } from "../../server/pyth";
 import { getRankingsBySymbol } from "../../services/clickhouse";
 import {
   Cluster,
   ClusterToName,
-  getFeeds,
-  getPublishersForFeed,
 } from "../../services/pyth";
 import { getStatus } from "../../status";
 import { PublisherIcon } from "../PublisherIcon";
 import { PublisherTag } from "../PublisherTag";
-import { PublishersCard } from "./publishers-card";
 
 type Props = {
   params: Promise<{
@@ -28,8 +27,8 @@ export const Publishers = async ({ params }: Props) => {
     pythnetPublishers,
     pythtestConformancePublishers,
   ] = await Promise.all([
-    getFeeds(Cluster.Pythnet),
-    getFeeds(Cluster.PythtestConformance),
+    getFeedsCached(Cluster.Pythnet),
+    getFeedsCached(Cluster.PythtestConformance),
     getPublishers(Cluster.Pythnet, symbol),
     getPublishers(Cluster.PythtestConformance, symbol),
   ]);
@@ -87,7 +86,7 @@ export const PublishersLoading = () => <PublishersCard isLoading />;
 
 const getPublishers = async (cluster: Cluster, symbol: string) => {
   const [publishers, rankings] = await Promise.all([
-    getPublishersForFeed(cluster, symbol),
+    getPublishersForFeedCached(cluster, symbol),
     getRankingsBySymbol(symbol),
   ]);
 

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

@@ -19,7 +19,8 @@ import { AssetClassTable } from "./asset-class-table";
 import { ComingSoonList } from "./coming-soon-list";
 import styles from "./index.module.scss";
 import { PriceFeedsCard } from "./price-feeds-card";
-import { Cluster, getFeeds } from "../../services/pyth";
+import { getFeedsCached } from "../../server/pyth";
+import { Cluster } from "../../services/pyth";
 import { priceFeeds as priceFeedsStaticConfig } from "../../static-data/price-feeds";
 import { activeChains } from "../../static-data/stats";
 import { Cards } from "../Cards";
@@ -289,7 +290,7 @@ const FeaturedFeedsCard = <T extends ElementType>({
 );
 
 const getPriceFeeds = async () => {
-  const priceFeeds = await getFeeds(Cluster.Pythnet);
+  const priceFeeds = await getFeedsCached(Cluster.Pythnet);
   const activeFeeds = priceFeeds.filter((feed) => isActive(feed));
   const comingSoon = priceFeeds.filter((feed) => !isActive(feed));
   return { activeFeeds, comingSoon };

apps/insights/src/server/pyth.ts

@@ -0,0 +1,11 @@
+import { Cluster, getFeeds, getPublishersForFeed } from "../services/pyth";
+
+export const getFeedsCached = async (cluster: Cluster) => {
+  "use cache";
+  return getFeeds(cluster);
+};
+
+export const getPublishersForFeedCached = async (cluster: Cluster, symbol: string) => {
+  "use cache";
+  return getPublishersForFeed(cluster, symbol);
+};