chore: try with fetch again

Author: alexcambose

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/config/server.ts

@@ -1,6 +1,6 @@
 // Disable the following rule because this file is the intended place to declare
 // and load all env variables.
-/* eslint-disable n/no-process-env, @typescript-eslint/no-non-null-assertion, turbo/no-undeclared-env-vars */
+/* eslint-disable n/no-process-env */
 
 import { Redis } from 'ioredis';
 import "server-only";
@@ -63,10 +63,7 @@ export const ENABLE_ACCESSIBILITY_REPORTING =
 let redisClient: Redis | undefined;
 
 export function getRedis(): Redis {
-  const url = process.env.REDIS_URL;
-  if (!url) {
-    throw new Error('REDIS_URL must be set');
-  }
+  const url = demand("REDIS_URL");
   if(redisClient) {
     return redisClient;
   }
@@ -76,13 +73,14 @@ export function getRedis(): Redis {
 
 export const PUBLIC_URL = (() => {
   if (IS_PRODUCTION_SERVER) {
-
-    return `https://${process.env.VERCEL_PROJECT_PRODUCTION_URL!}`;
+    const productionUrl = demand("VERCEL_PROJECT_PRODUCTION_URL");
+    return `https://${productionUrl}`;
   } else if (IS_PREVIEW_SERVER) {
-    return `https://${process.env.VERCEL_URL!}`;
+    const previewUrl = demand("VERCEL_URL");
+    return `https://${previewUrl}`;
   } else {
     return `http://localhost:3003`;
   }
 })();
 
-export const VERCEL_AUTOMATION_BYPASS_SECRET = process.env.VERCEL_AUTOMATION_BYPASS_SECRET!;
+export const VERCEL_AUTOMATION_BYPASS_SECRET = demand("VERCEL_AUTOMATION_BYPASS_SECRET");

apps/insights/src/server/pyth.ts

@@ -38,6 +38,7 @@ export async function getFeedsForPublisherCached(
 }
 
 export const getFeedsCached = async (cluster: Cluster) => {
+  const start = Date.now();
   const data = await fetch(`${PUBLIC_URL}/api/pyth/get-feeds?cluster=${cluster.toString()}&excludePriceComponents=true`, {
     next: {
       revalidate: DEFAULT_CACHE_TTL,
@@ -48,10 +49,14 @@ export const getFeedsCached = async (cluster: Cluster) => {
   });
   const dataJson = await data.text();
   const feeds: Omit<z.infer<typeof priceFeedsSchema>[0], "price">[] = parse(dataJson);
+  const end = Date.now();
+  // eslint-disable-next-line no-console
+  console.log("getFeedsCached", cluster, end - start);
   return feeds;
 }
 
 export const getFeedForSymbolCached = async ({symbol, cluster = Cluster.Pythnet}: {symbol: string, cluster?: Cluster}): Promise<z.infer<typeof priceFeedsSchema>[0] | undefined> => {
+  const start = Date.now();
   const data = await fetch(`${PUBLIC_URL}/api/pyth/get-feeds/${encodeURIComponent(symbol)}?cluster=${cluster.toString()}`, {
     next: {
       revalidate: DEFAULT_CACHE_TTL,
@@ -60,12 +65,15 @@ export const getFeedForSymbolCached = async ({symbol, cluster = Cluster.Pythnet}
       'x-vercel-protection-bypass': VERCEL_AUTOMATION_BYPASS_SECRET,
     },
   });
-  
+
   if(!data.ok) {
     return undefined;
   }
 
   const dataJson = await data.text();
   const feed: z.infer<typeof priceFeedsSchema>[0] = parse(dataJson);
+  const end = Date.now();
+  // eslint-disable-next-line no-console
+  console.log("getFeedForSymbolCached", symbol, cluster, end - start);
   return feed;
 }

apps/insights/turbo.json

@@ -16,7 +16,8 @@
         "DISABLE_ACCESSIBILITY_REPORTING",
         "NEXT_PUBLIC_PYTHNET_RPC",
         "NEXT_PUBLIC_PYTHTEST_CONFORMANCE_RPC",
-        "REDIS_URL"
+        "REDIS_URL",
+        "VERCEL_PROJECT_PRODUCTION_URL"
       ]
     },
     "fix:lint": {