feat(insights): add more cached methods 2

Author: alexcambose

apps/insights/src/components/Publisher/get-price-feeds.tsx

@@ -1,12 +1,12 @@
-import { getRankingsByPublisher } from "../../services/clickhouse";
-import type { Cluster } from "../../services/pyth";
-import { ClusterToName, getFeedsForPublisher } from "../../services/pyth";
+import { getRankingsByPublisherCached } from '../../server/clickhouse';
+import { getFeedsForPublisherCached } from "../../server/pyth";
+import { Cluster, ClusterToName } from "../../services/pyth";
 import { getStatus } from "../../status";
 
 export const getPriceFeeds = async (cluster: Cluster, key: string) => {
   const [feeds, rankings] = await Promise.all([
-    getFeedsForPublisher(cluster, key),
-    getRankingsByPublisher(key),
+    getFeedsForPublisherCached(cluster, key),
+    getRankingsByPublisherCached(key),
   ]);
   return feeds.map((feed) => {
     const ranking = rankings.find(

apps/insights/src/components/Publisher/layout.tsx

@@ -16,10 +16,10 @@ import type { ReactNode } from "react";
 import { Suspense } from "react";
 
 import {
-  getPublisherRankingHistory,
-  getPublisherAverageScoreHistory,
-  getPublishers,
-} from "../../services/clickhouse";
+  getPublishersCached,
+  getPublisherRankingHistoryCached,
+  getPublisherAverageScoreHistoryCached,
+} from "../../server/clickhouse";
 import { getPublisherCaps } from "../../services/hermes";
 import { ClusterToName, parseCluster, Cluster } from "../../services/pyth";
 import { getPublisherPoolData } from "../../services/staking";
@@ -150,7 +150,7 @@ const RankingCard = async ({
   cluster: Cluster;
   publisherKey: string;
 }) => {
-  const rankingHistory = await getPublisherRankingHistory(
+  const rankingHistory = await getPublisherRankingHistoryCached(
     cluster,
     publisherKey,
   );
@@ -234,7 +234,7 @@ const ScoreCard = async ({
   cluster: Cluster;
   publisherKey: string;
 }) => {
-  const averageScoreHistory = await getPublisherAverageScoreHistory(
+  const averageScoreHistory = await getPublisherAverageScoreHistoryCached(
     cluster,
     publisherKey,
   );
@@ -338,7 +338,7 @@ const ActiveFeedsCard = async ({
   publisherKey: string;
 }) => {
   const [publishers, priceFeeds] = await Promise.all([
-    getPublishers(cluster),
+    getPublishersCached(cluster),
     getPriceFeeds(cluster, publisherKey),
   ]);
   const publisher = publishers.find(

apps/insights/src/components/Publisher/performance.tsx

@@ -15,7 +15,7 @@ import type { ReactNode, ComponentProps } from "react";
 import { getPriceFeeds } from "./get-price-feeds";
 import styles from "./performance.module.scss";
 import { TopFeedsTable } from "./top-feeds-table";
-import { getPublishers } from "../../services/clickhouse";
+import { getPublishersCached } from "../../server/clickhouse";
 import type { Cluster } from "../../services/pyth";
 import { ClusterToName, parseCluster } from "../../services/pyth";
 import { Status } from "../../status";
@@ -48,7 +48,7 @@ export const Performance = async ({ params }: Props) => {
     notFound();
   }
   const [publishers, priceFeeds] = await Promise.all([
-    getPublishers(parsedCluster),
+    getPublishersCached(parsedCluster),
     getPriceFeeds(parsedCluster, key),
   ]);
   const slicedPublishers = sliceAround(

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

@@ -7,7 +7,7 @@ import { lookup as lookupPublisher } from "@pythnetwork/known-publishers";
 
 import styles from "./index.module.scss";
 import { PublishersCard } from "./publishers-card";
-import { getPublishers } from "../../services/clickhouse";
+import { getPublishersCached } from "../../server/clickhouse";
 import { getPublisherCaps } from "../../services/hermes";
 import { Cluster } from "../../services/pyth";
 import {
@@ -27,8 +27,8 @@ const INITIAL_REWARD_POOL_SIZE = 60_000_000_000_000n;
 export const Publishers = async () => {
   const [pythnetPublishers, pythtestConformancePublishers, oisStats] =
     await Promise.all([
-      getPublishers(Cluster.Pythnet),
-      getPublishers(Cluster.PythtestConformance),
+      getPublishersCached(Cluster.Pythnet),
+      getPublishersCached(Cluster.PythtestConformance),
       getOisStats(),
     ]);
 
@@ -150,7 +150,7 @@ const toTableRow = ({
   permissionedFeeds,
   activeFeeds,
   averageScore,
-}: Awaited<ReturnType<typeof getPublishers>>[number]) => {
+}: Awaited<ReturnType<typeof getPublishersCached>>[number]) => {
   const knownPublisher = lookupPublisher(key);
   return {
     id: key,

apps/insights/src/server/clickhouse.ts

@@ -1,7 +1,28 @@
 
-import { getRankingsBySymbol } from "../services/clickhouse";
+import { getPublisherAverageScoreHistory, getPublisherRankingHistory, getPublishers, getRankingsByPublisher, getRankingsBySymbol } from "../services/clickhouse";
+import { Cluster } from "../services/pyth";
 
 export const getRankingsBySymbolCached = async (symbol: string) => {
   "use cache";
   return getRankingsBySymbol(symbol);
+};
+
+export const getRankingsByPublisherCached = async (publisherKey: string) => {
+  "use cache";
+  return getRankingsByPublisher(publisherKey);
+};
+
+export const getPublisherAverageScoreHistoryCached = async (cluster: Cluster, key: string) => {
+  "use cache";
+  return getPublisherAverageScoreHistory(cluster, key);
+};
+
+export const getPublisherRankingHistoryCached = async (cluster: Cluster, key: string) => {
+  "use cache";
+  return getPublisherRankingHistory(cluster, key);
+};
+
+export const getPublishersCached = async (cluster: Cluster) => {
+  "use cache";
+  return getPublishers(cluster);
 };

apps/insights/src/server/pyth.ts

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