feat: status updates

Author: alexcambose

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

@@ -38,7 +38,7 @@ export const GET = async (
   const filteredFeeds = feeds.filter((feed) =>
     feed.price.priceComponents.some((c) => c.publisher === publisher),
   );
-
+console.log({filteredFeeds: filteredFeeds.length, feeds: feeds.length})
   return new Response(stringify(filteredFeeds), {
     headers: {
       "Content-Type": "application/json",

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

@@ -120,6 +120,7 @@ export const ResolvedPriceComponentsCard = <
   const logger = useLogger();
   const collator = useCollator();
   const filter = useFilter({ sensitivity: "base", usage: "search" });
+
   const { selectComponent } = usePriceComponentDrawer({
     components: priceComponents,
     identifiesPublisher,

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

@@ -9,6 +9,8 @@ import { Cluster } from "../../services/pyth";
 import type { PriceComponent } from "../PriceComponentsCard";
 import { PriceComponentsCard } from "../PriceComponentsCard";
 import { PublisherTag } from "../PublisherTag";
+import { useLivePriceData } from '../../hooks/use-live-price-data';
+import { Status } from '../../status';
 
 type PublishersCardProps =
   | { isLoading: true }
@@ -29,7 +31,7 @@ type ResolvedPublishersCardProps = {
   symbol: string;
   displaySymbol: string;
   assetClass: string;
-  publishers: Omit<PriceComponent, "symbol" | "displaySymbol" | "assetClass">[];
+  publishers: Omit<PriceComponent, "status" | "symbol" | "displaySymbol" | "assetClass">[];
   metricsTime?: Date | undefined;
 };
 
@@ -38,6 +40,7 @@ const ResolvedPublishersCard = ({
   ...props
 }: ResolvedPublishersCardProps) => {
   const logger = useLogger();
+const data = useLivePriceData(Cluster.Pythnet, publishers[0]?.feedKey);
 
   const [includeTestFeeds, setIncludeTestFeeds] = useQueryState(
     "includeTestFeeds",
@@ -63,11 +66,26 @@ const ResolvedPublishersCard = ({
     [includeTestFeeds, publishers],
   );
 
+  const publishersWithStatus = useMemo(() => {
+    const currentSlot = data.current?.validSlot;
+    const isInactive = (publishSlot: number, currentSlot: number) => publishSlot < currentSlot - 100;
+
+    return publishersFilteredByCluster.map((publisher) => {
+      const lastPublishedSlot = data.current?.priceComponents.find((price) => price.publisher.toString() === publisher.publisherKey.toString())?.latest.publishSlot;
+      const isPublisherInactive = isInactive(Number(lastPublishedSlot ?? 0), Number(currentSlot ?? 0));
+
+      return {
+      ...publisher,
+      status: isPublisherInactive ? Status.Down : Status.Live,
+      };
+    });
+  }, [publishersFilteredByCluster, data]);
+
   return (
     <PublishersCardImpl
       includeTestFeeds={includeTestFeeds}
       updateIncludeTestFeeds={updateIncludeTestFeeds}
-      publishers={publishersFilteredByCluster}
+      publishers={publishersWithStatus}
       {...props}
     />
   );

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

@@ -7,7 +7,6 @@ import {
 } from "../../server/pyth";
 import { getRankingsBySymbol } from "../../services/clickhouse";
 import { Cluster, ClusterToName } from "../../services/pyth";
-import { getStatus } from "../../status";
 import { PublisherIcon } from "../PublisherIcon";
 import { PublisherTag } from "../PublisherTag";
 import { PublishersCard } from "./publishers-card";
@@ -34,7 +33,6 @@ export const Publishers = async ({ params }: Props) => {
   const metricsTime = pythnetPublishers.find(
     (publisher) => publisher.ranking !== undefined,
   )?.ranking?.time;
-
   return feed === undefined ? (
     notFound()
   ) : (
@@ -44,7 +42,7 @@ export const Publishers = async ({ params }: Props) => {
       displaySymbol={feed.product.display_symbol}
       assetClass={feed.product.asset_type}
       publishers={publishers.map(
-        ({ ranking, publisher, status, cluster, knownPublisher }) => ({
+        ({ ranking, publisher, cluster, knownPublisher }) => ({
           id: `${publisher}-${ClusterToName[cluster]}`,
           feedKey:
             cluster === Cluster.Pythnet
@@ -55,7 +53,6 @@ export const Publishers = async ({ params }: Props) => {
           deviationScore: ranking?.deviation_score,
           stalledScore: ranking?.stalled_score,
           cluster,
-          status,
           publisherKey: publisher,
           rank: ranking?.final_rank,
           firstEvaluation: ranking?.first_ranking_time,
@@ -94,7 +91,6 @@ const getPublishers = async (cluster: Cluster, symbol: string) => {
     return {
       ranking,
       publisher,
-      status: getStatus(ranking),
       cluster,
       knownPublisher: lookupPublisher(publisher),
     };

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

@@ -1,7 +1,6 @@
 import { getFeedsForPublisherRequest } from "../../server/pyth";
 import { getRankingsByPublisher } from "../../services/clickhouse";
 import { Cluster, ClusterToName } from "../../services/pyth";
-import { getStatus } from "../../status";
 
 export const getPriceFeeds = async (cluster: Cluster, key: string) => {
   const [feeds, rankings] = await Promise.all([
@@ -17,7 +16,6 @@ export const getPriceFeeds = async (cluster: Cluster, key: string) => {
     return {
       ranking,
       feed,
-      status: getStatus(ranking),
     };
   });
 };

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

@@ -8,6 +8,7 @@ import type { PriceComponent } from "../PriceComponentsCard";
 import { PriceComponentsCard } from "../PriceComponentsCard";
 import { PriceFeedIcon } from "../PriceFeedIcon";
 import { PriceFeedTag } from "../PriceFeedTag";
+import { useLivePriceData } from '../../hooks/use-live-price-data';
 
 type Props = {
   params: Promise<{
@@ -33,7 +34,7 @@ export const PriceFeeds = async ({ params }: Props) => {
       metricsTime={metricsTime}
       publisherKey={key}
       cluster={parsedCluster}
-      priceFeeds={feeds.map(({ ranking, feed, status }) => ({
+      priceFeeds={feeds.map(({ ranking, feed }) => ({
         symbol: feed.symbol,
         name: (
           <PriceFeedTag
@@ -52,7 +53,6 @@ export const PriceFeeds = async ({ params }: Props) => {
         uptimeScore: ranking?.uptime_score,
         deviationScore: ranking?.deviation_score,
         stalledScore: ranking?.stalled_score,
-        status,
         feedKey: feed.product.price_account,
         nameAsString: feed.product.display_symbol,
         id: feed.product.price_account,
@@ -72,12 +72,12 @@ type PriceFeedsCardProps =
       isLoading?: false | undefined;
       publisherKey: string;
       cluster: Cluster;
-      priceFeeds: Omit<PriceComponent, "cluster" | "publisherKey">[];
+      priceFeeds: Omit<PriceComponent, "status" | "cluster" | "publisherKey">[];
       metricsTime?: Date | undefined;
     };
 
-const PriceFeedsCard = (props: PriceFeedsCardProps) => (
-  <PriceComponentsCard
+const PriceFeedsCard = (props: PriceFeedsCardProps) =>
+<PriceComponentsCard
     label="Price Feeds"
     searchPlaceholder="Feed symbol"
     nameLoadingSkeleton={<PriceFeedTag isLoading />}
@@ -103,5 +103,4 @@ const PriceFeedsCard = (props: PriceFeedsCardProps) => (
             ),
           })),
         })}
-  />
-);
+        />

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

@@ -10,28 +10,28 @@ export const Status = ({ status }: { status: StatusType }) => (
 
 const getVariant = (status: StatusType) => {
   switch (status) {
-    case StatusType.Active: {
+    case StatusType.Live: {
       return "success";
     }
-    case StatusType.Inactive: {
+    case StatusType.Down: {
       return "error";
     }
-    case StatusType.Unranked: {
-      return "disabled";
-    }
+    // case StatusType.Unranked: {
+    //   return "disabled";
+    // }
   }
 };
 
 const getText = (status: StatusType) => {
   switch (status) {
-    case StatusType.Active: {
-      return "Active";
-    }
-    case StatusType.Inactive: {
-      return "Inactive";
+    case StatusType.Live: {
+      return "Live";
     }
-    case StatusType.Unranked: {
-      return "Unranked";
+    case StatusType.Down: {
+      return "Down";
     }
+    // case StatusType.Unranked: {
+    //   return "Unranked";
+    // }
   }
 };

apps/insights/src/hooks/use-live-price-data.tsx

@@ -35,7 +35,7 @@ export const LivePriceDataProvider = (props: LivePriceDataProviderProps) => {
   return <LivePriceDataContext value={priceData} {...props} />;
 };
 
-export const useLivePriceData = (cluster: Cluster, feedKey: string) => {
+export const useLivePriceData = (cluster: Cluster, feedKey?: string) => {
   const { addSubscription, removeSubscription } =
     useLivePriceDataContext()[cluster];
 
@@ -45,6 +45,9 @@ export const useLivePriceData = (cluster: Cluster, feedKey: string) => {
   }>({ current: undefined, prev: undefined });
 
   useEffect(() => {
+    if(!feedKey) {
+      return;
+    }
     addSubscription(feedKey, setData);
     return () => {
       removeSubscription(feedKey, setData);

apps/insights/src/services/clickhouse.ts

@@ -37,8 +37,6 @@ const _getPublishers = async (cluster: Cluster) =>
               publisher,
               time,
               avg(final_score) AS averageScore,
-              countIf(uptime_score >= 0.5) AS activeFeeds,
-              countIf(uptime_score < 0.5) AS inactiveFeeds
             FROM publisher_quality_ranking
             WHERE cluster = {cluster:String}
             AND time = (

apps/insights/src/status.ts

@@ -1,35 +1,22 @@
 export enum Status {
-  Unranked,
-  Inactive,
-  Active,
+  Down,
+  Live,
 }
 
-export const getStatus = (ranking?: { uptime_score: number }): Status => {
-  if (ranking) {
-    return ranking.uptime_score >= 0.5 ? Status.Active : Status.Inactive;
-  } else {
-    return Status.Unranked;
-  }
-};
-
 export const STATUS_NAMES = {
-  [Status.Active]: "Active",
-  [Status.Inactive]: "Inactive",
-  [Status.Unranked]: "Unranked",
+  [Status.Live]: "Live",
+  [Status.Down]: "Down",
 } as const;
 
 export type StatusName = (typeof STATUS_NAMES)[Status];
 
 export const statusNameToStatus = (name: string): Status | undefined => {
   switch (name) {
-    case "Active": {
-      return Status.Active;
-    }
-    case "Inactive": {
-      return Status.Inactive;
+    case "Live": {
+      return Status.Live;
     }
-    case "Unranked": {
-      return Status.Unranked;
+    case "Down": {
+      return Status.Down;
     }
     default: {
       return undefined;