Add NanoSpeed API as first class to get the conf time on the home pag…

…e to bypass innacurate confirmation_history RPC
running-coder · Nov 6, 2023 · 81910e7 · 81910e7
1 parent b75cd87
commit 81910e7
Show file tree

Hide file tree

Showing 5 changed files with 46 additions and 2 deletions.
diff --git a/server/constants.js b/server/constants.js
@@ -48,6 +48,7 @@ const REDIS_RICH_LIST = "RICH_LIST";
 const PARTICIPANTS = "PARTICIPANTS";
 const NANOTICKER_STATS = "NANOTICKER_STATS";
 const NANOTPS_STATS = "NANOTPS_STATS";
+const NANOSPEED_STATS = "NANOSPEED_STATS";
 const NANOBROWSERQUEST_PLAYERS = "NANOBROWSERQUEST_PLAYERS";
 const NANOBROWSERQUEST_LEADERBOARD = "NANOBROWSERQUEST_LEADERBOARD";
 const YOUTUBE_PLAYLIST = "YOUTUBE_PLAYLIST";
@@ -112,6 +113,7 @@ module.exports = {
   PARTICIPANTS,
   NANOTICKER_STATS,
   NANOTPS_STATS,
+  NANOSPEED_STATS,
   NANOBROWSERQUEST_PLAYERS,
   NANOBROWSERQUEST_LEADERBOARD,
   YOUTUBE_PLAYLIST,

diff --git a/server/cron/nanospeed.js b/server/cron/nanospeed.js
@@ -0,0 +1,24 @@
+const cron = require("node-cron");
+const fetch = require("node-fetch");
+const { Sentry } = require("../sentry");
+const { nodeCache } = require("../client/cache");
+const { NANOSPEED_STATS } = require("../constants");
+
+const doNanoSpeedStats = async () => {
+  try {
+    const res = await fetch("https://api.nanospeed.info/conf-times-box-global?period=1D");
+
+    const { q90: avgConfTimep90, median } = await res.json();
+
+    nodeCache.set(NANOSPEED_STATS, { avgConfTimep90, median });
+  } catch (err) {
+    Sentry.captureException(err);
+  }
+};
+
+// Every 15 smins
+cron.schedule("*/15 * * * *", async () => {
+  doNanoSpeedStats();
+});
+
+doNanoSpeedStats();
diff --git a/server/server.js b/server/server.js
@@ -14,6 +14,7 @@ require("./cron/coingeckoStats");
 require("./cron/btcTransactionFees");
 require("./cron/nanotickerStats");
 require("./cron/nanotpsStats");
+require("./cron/nanospeed");
 require("./cron/nanobrowserquestStats");
 require("./cron/2minersStats");
 require("./cron/youtubePlaylist");
@@ -37,6 +38,7 @@ const {
   NANOBROWSERQUEST_PLAYERS,
   NANOBROWSERQUEST_LEADERBOARD,
   NANOTPS_STATS,
+  NANOSPEED_STATS,
 } = require("./constants");
 const {
   getBtcTransactionFees,
@@ -145,6 +147,7 @@ app.get("/api/market-statistics", async (req, res) => {
   const cachedConfirmations48h = nodeCache.get(TOTAL_CONFIRMATIONS_48H);
   const cachedVolume48h = nodeCache.get(TOTAL_VOLUME_48H);
   const nanotpsStats = nodeCache.get(NANOTPS_STATS);
+  const nanoSpeedStats = nodeCache.get(NANOSPEED_STATS);
 
   const { btcTransactionFees24h, btcTransactionFees48h } = await getBtcTransactionFees();
   const { marketStats, priceStats } = await getCoingeckoStats({
@@ -161,6 +164,7 @@ app.get("/api/market-statistics", async (req, res) => {
     [BITCOIN_TOTAL_TRANSACTION_FEES_48H]: btcTransactionFees48h,
     [BITCOIN_TOTAL_TRANSACTION_FEES_48H]: btcTransactionFees48h,
     [NANOTPS_STATS]: nanotpsStats,
+    [NANOSPEED_STATS]: nanoSpeedStats,
     ...marketStats,
     priceStats: {
       ...{ bitcoin: { usd: 0 } },

diff --git a/src/api/contexts/MarketStatistics.tsx b/src/api/contexts/MarketStatistics.tsx
@@ -11,6 +11,7 @@ export const TOTAL_VOLUME_48H = "TOTAL_VOLUME_48H";
 export const BITCOIN_TOTAL_TRANSACTION_FEES_24H = "BITCOIN_TOTAL_TRANSACTION_FEES_24H";
 export const BITCOIN_TOTAL_TRANSACTION_FEES_48H = "BITCOIN_TOTAL_TRANSACTION_FEES_48H";
 export const NANOTPS_STATS = "NANOTPS_STATS";
+export const NANOSPEED_STATS = "NANOSPEED_STATS";
 
 export interface Response {
   [TOTAL_CONFIRMATIONS_24H]: number;
@@ -20,6 +21,7 @@ export interface Response {
   [BITCOIN_TOTAL_TRANSACTION_FEES_24H]: number;
   [BITCOIN_TOTAL_TRANSACTION_FEES_48H]: number;
   [NANOTPS_STATS]: any;
+  [NANOTPS_STATS]: any;
   marketCapRank: number;
   marketCapRank24h: number;
   marketCap: number;
@@ -30,6 +32,10 @@ export interface Response {
   totalSupply: number;
   circulatingSupply: number;
   priceStats: any;
+  NANOSPEED_STATS: {
+    median: number | null;
+    avgConfTimep90: number | null;
+  };
 }
 
 export interface Context {
@@ -51,7 +57,12 @@ export const MarketStatisticsContext = React.createContext<Context>({
     [TOTAL_VOLUME_48H]: 0,
     [BITCOIN_TOTAL_TRANSACTION_FEES_24H]: 0,
     [BITCOIN_TOTAL_TRANSACTION_FEES_48H]: 0,
+
     NANOTPS_STATS: {},
+    [NANOSPEED_STATS]: {
+      median: null,
+      avgConfTimep90: null,
+    },
     marketCapRank: 0,
     marketCapRank24h: 0,
     marketCap: 0,

diff --git a/src/pages/Home/index.tsx b/src/pages/Home/index.tsx
@@ -46,12 +46,15 @@ const HomePage = () => {
     volume24h,
     priceStats,
     NANOTPS_STATS = {},
+    NANOSPEED_STATS: { median = null } = {},
   } = marketStatistics;
 
   const { send } = NANOTPS_STATS;
 
   const { count } = React.useContext(BlockCountContext);
   const { confirmation_stats: { average = 0 } = {} } = React.useContext(ConfirmationHistoryContext);
+
+  let medianConfTime = median || average;
   const { representatives } = React.useContext(RepresentativesContext);
   const {
     nodeStatus: { ledgerSize },
@@ -148,10 +151,10 @@ const HomePage = () => {
                   }
                 />
                 <LoadingStatistic
-                  isLoading={!average}
+                  isLoading={!medianConfTime}
                   title={t("pages.home.avgConfirmationTime")}
                   tooltip={t<string>("tooltips.avgConfirmationTime")}
-                  value={new BigNumber(average).dividedBy(1000).toNumber()}
+                  value={new BigNumber(medianConfTime).dividedBy(1000).toNumber()}
                 />
 
                 {/* {!isSmallAndLower ? (