refactor: minor fixes

Author: alexcambose

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

@@ -1,6 +1,6 @@
 import { NextResponse } from "next/server";
 
-import { getPublishersForCluster } from "../../../../../server/pyth/get-publishers-for-cluster";
+import { getPublishersForClusterCached } from "../../../../../server/pyth/get-publishers-for-cluster";
 import { Cluster } from "../../../../../services/pyth";
 
 export const GET = async (request: Request, { params }: { params: Promise<{ symbol: string }> }) => {
@@ -18,7 +18,7 @@ export const GET = async (request: Request, { params }: { params: Promise<{ symb
     return NextResponse.json({ error: "Symbol is required" }, { status: 400 });
   }
 
-  const map = await getPublishersForCluster(cluster);
-  
+  const map = await getPublishersForClusterCached(cluster);
+
   return NextResponse.json(map[symbol] ?? []);
 };

apps/insights/src/server/pyth/get-feeds.ts

@@ -1,9 +1,9 @@
-import { getPythMetadata } from './get-metadata';
+import { getPythMetadataCached } from './get-metadata';
 import { Cluster, priceFeedsSchema } from "../../services/pyth";
 import { redisCache } from '../../utils/cache';
 
-const _getFeeds = async (cluster: Cluster) => {
-  const unfilteredData = await getPythMetadata(cluster);
+const getFeeds = async (cluster: Cluster) => {
+  const unfilteredData = await getPythMetadataCached(cluster);
   const filtered = unfilteredData.symbols
     .filter(
       (symbol) =>
@@ -29,5 +29,5 @@ const _getFeeds = async (cluster: Cluster) => {
 
 export const getFeedsCached = redisCache.define(
   "getFeeds",
-  _getFeeds,
+  getFeeds,
 ).getFeeds;

apps/insights/src/server/pyth/get-metadata.ts

@@ -2,12 +2,12 @@
 import { clients, Cluster } from '../../services/pyth';
 import { memoryOnlyCache } from '../../utils/cache';
 
-const _getPythMetadata = async (cluster: Cluster) => {
+const getPythMetadata = async (cluster: Cluster) => {
   return clients[cluster].getData();
 };
 
-export const getPythMetadata = memoryOnlyCache.define(
+export const getPythMetadataCached = memoryOnlyCache.define(
   "getPythMetadata",
-  _getPythMetadata,
+  getPythMetadata,
 ).getPythMetadata;
 

apps/insights/src/server/pyth/get-publishers-for-cluster.ts

@@ -1,9 +1,9 @@
-import { getPythMetadata } from './get-metadata';
+import { getPythMetadataCached } from './get-metadata';
 import { Cluster } from '../../services/pyth';
 import { redisCache } from '../../utils/cache';
 
-const _computePublishers = async (cluster: Cluster) => {
-  const data = await getPythMetadata(cluster);
+const getPublishersForCluster = async (cluster: Cluster) => {
+  const data = await getPythMetadataCached(cluster);
   const result: Record<string, string[]> = {};
   for (const key of data.productPrice.keys()) {
     const price = data.productPrice.get(key);
@@ -13,7 +13,7 @@ const _computePublishers = async (cluster: Cluster) => {
   return result;
 };
 
-export const getPublishersForCluster = redisCache.define(
+export const getPublishersForClusterCached = redisCache.define(
   "getPublishersForCluster",
-  _computePublishers,
+  getPublishersForCluster,
 ).getPublishersForCluster;