Feat: Add daily transactions statistics

api/src/models/influx/nova/IInfluxDbCache.ts

@@ -1,11 +1,12 @@
-import { IBlocksDailyInflux } from "./IInfluxTimedEntries";
+import { IBlocksDailyInflux, ITransactionsDailyInflux } from "./IInfluxTimedEntries";
 import { DayKey } from "../types";
 
 /**
  * The cache for influx graphs (daily).
  */
 export interface IInfluxDailyCache {
     blocksDaily: Map<DayKey, IBlocksDailyInflux>;
+    transactionsDaily: Map<DayKey, ITransactionsDailyInflux>;
 }
 
 /**
@@ -14,4 +15,5 @@ export interface IInfluxDailyCache {
  */
 export const initializeEmptyDailyCache = () => ({
     blocksDaily: new Map(),
+    transactionsDaily: new Map(),
 });

api/src/models/influx/nova/IInfluxTimedEntries.ts

@@ -6,3 +6,8 @@ export type IBlocksDailyInflux = ITimedEntry & {
     validation: number | null;
     candidacy: number | null;
 };
+
+export type ITransactionsDailyInflux = ITimedEntry & {
+    finalized: number | null;
+    failed: number | null;
+};

api/src/routes/nova/analytics/influx/daily/get.ts

@@ -2,7 +2,7 @@ import { ServiceFactory } from "../../../../../factories/serviceFactory";
 import { INetworkBoundGetRequest } from "../../../../../models/api/INetworkBoundGetRequest";
 import { IConfiguration } from "../../../../../models/configuration/IConfiguration";
 import { NOVA } from "../../../../../models/db/protocolVersion";
-import { IBlocksDailyInflux } from "../../../../../models/influx/nova/IInfluxTimedEntries";
+import { IBlocksDailyInflux, ITransactionsDailyInflux } from "../../../../../models/influx/nova/IInfluxTimedEntries";
 import { NetworkService } from "../../../../../services/networkService";
 import { InfluxServiceNova } from "../../../../../services/nova/influx/influxServiceNova";
 import { ValidationHelper } from "../../../../../utils/validationHelper";
@@ -13,6 +13,7 @@ import { ValidationHelper } from "../../../../../utils/validationHelper";
 export interface IDailyAnalyticsResponse {
     error?: string;
     blocksDaily?: IBlocksDailyInflux[];
+    transactionsDaily?: ITransactionsDailyInflux[];
 }
 
 /**
@@ -36,6 +37,7 @@ export async function get(_: IConfiguration, request: INetworkBoundGetRequest):
     return influxService
         ? {
               blocksDaily: influxService.blocksDaily,
+              transactionsDaily: influxService.transactionsDaily,
           }
         : {
               error: "Influx service not found for this network.",

api/src/services/nova/influx/influxQueries.ts

@@ -20,3 +20,22 @@ export const BLOCK_DAILY_QUERY = {
         GROUP BY time(1d) fill(null)
     `,
 };
+
+export const TRANSACTION_DAILY_QUERY = {
+    full: `
+        SELECT
+            sum("finalized_count") AS "finalized",
+            sum("failed_count") AS "failed"
+        FROM "iota_block_activity"
+        WHERE time < $to
+        GROUP BY time(1d) fill(null)
+    `,
+    partial: `
+        SELECT
+            sum("finalized_count") AS "finalized",
+            sum("failed_count") AS "failed"
+        FROM "iota_block_activity"
+        WHERE time >= $from and time <= $to
+        GROUP BY time(1d) fill(null)
+    `,
+};

api/src/services/nova/influx/influxServiceNova.ts

@@ -1,9 +1,9 @@
 import { InfluxDB } from "influx";
-import { BLOCK_DAILY_QUERY } from "./influxQueries";
+import { BLOCK_DAILY_QUERY, TRANSACTION_DAILY_QUERY } from "./influxQueries";
 import logger from "../../../logger";
 import { INetwork } from "../../../models/db/INetwork";
 import { IInfluxDailyCache, initializeEmptyDailyCache } from "../../../models/influx/nova/IInfluxDbCache";
-import { IBlocksDailyInflux } from "../../../models/influx/nova/IInfluxTimedEntries";
+import { IBlocksDailyInflux, ITransactionsDailyInflux } from "../../../models/influx/nova/IInfluxTimedEntries";
 import { InfluxDbClient } from "../../influx/influxClient";
 
 export class InfluxServiceNova extends InfluxDbClient {
@@ -31,6 +31,10 @@ export class InfluxServiceNova extends InfluxDbClient {
         return this.mapToSortedValuesArray(this._dailyCache.blocksDaily);
     }
 
+    public get transactionsDaily() {
+        return this.mapToSortedValuesArray(this._dailyCache.transactionsDaily);
+    }
+
     protected setupDataCollection() {
         const network = this._network.network;
         logger.verbose(`[InfluxNova] Setting up data collection for (${network}).`);
@@ -46,5 +50,6 @@ export class InfluxServiceNova extends InfluxDbClient {
     private async collectGraphsDaily() {
         logger.verbose(`[InfluxNova] Collecting daily stats for "${this._network.network}"`);
         this.updateCacheEntry<IBlocksDailyInflux>(BLOCK_DAILY_QUERY, this._dailyCache.blocksDaily, "Blocks Daily", true);
+        this.updateCacheEntry<ITransactionsDailyInflux>(TRANSACTION_DAILY_QUERY, this._dailyCache.transactionsDaily, "Transactions Daily");
     }
 }

client/src/app/components/nova/statistics/InfluxChartsTab.tsx

@@ -6,7 +6,7 @@ import Modal from "../../Modal";
 import StackedLineChart from "../../stardust/statistics/charts/StackedLineChart";
 
 export const InfluxChartsTab: React.FC = () => {
-    const { dailyBlocks } = useChartsState();
+    const { dailyBlocks, dailyTransactions } = useChartsState();
 
     const ids = idGenerator();
 
@@ -27,6 +27,15 @@ export const InfluxChartsTab: React.FC = () => {
                         colors={["#4140DF", "#14CABF", "#36A1AC", "#99BEE1"]}
                         data={dailyBlocks}
                     />
+                    <StackedLineChart
+                        chartId={ids.next().value}
+                        title="Daily Transactions"
+                        info={graphMessages.dailyTransactions}
+                        subgroups={["finalized", "failed"]}
+                        groupLabels={["Finalized", "Failed"]}
+                        colors={["#00E0CA", "#36A1AC"]}
+                        data={dailyTransactions}
+                    />
                 </div>
             </div>
         </div>

client/src/helpers/nova/hooks/useChartsState.ts

@@ -9,10 +9,14 @@ import { DataPoint, IStatisticsGraphsData, mapDailyStatsToGraphsData } from "../
  * State holder for Statistics page chart section.
  * @returns The charts state.
  */
-export function useChartsState(): { dailyBlocks: DataPoint[] } {
+export function useChartsState(): {
+    dailyBlocks: DataPoint[];
+    dailyTransactions: DataPoint[];
+} {
     const { name: network } = useNetworkInfoNova((s) => s.networkInfo);
     const [apiClient] = useState(ServiceFactory.get<NovaApiClient>(`api-client-${NOVA}`));
     const [dailyBlocks, setDailyBlocks] = useState<DataPoint[]>([]);
+    const [dailyTransactions, setDailyTransactions] = useState<DataPoint[]>([]);
 
     useEffect(() => {
         apiClient
@@ -22,12 +26,13 @@ export function useChartsState(): { dailyBlocks: DataPoint[] } {
                     const graphsData: IStatisticsGraphsData = mapDailyStatsToGraphsData(influxStats);
 
                     setDailyBlocks(graphsData.blocksDaily);
+                    setDailyTransactions(graphsData.transactionsDaily);
                 } else {
                     console.error("Fetching influx stats failed", influxStats.error);
                 }
             })
             .catch((e) => console.error("Influx analytics fetch failed", e));
     }, [network]);
 
-    return { dailyBlocks };
+    return { dailyBlocks, dailyTransactions };
 }

client/src/helpers/nova/statisticsUtils.ts

@@ -3,6 +3,7 @@ import { IInfluxDailyResponse } from "~models/api/nova/influx/IInfluxDailyRespon
 
 export interface IStatisticsGraphsData {
     blocksDaily: DataPoint[];
+    transactionsDaily: DataPoint[];
 }
 
 export interface DataPoint {
@@ -25,6 +26,12 @@ export function mapDailyStatsToGraphsData(data: IInfluxDailyResponse): IStatisti
                 validation: day.validation ?? 0,
                 candidacy: day.candidacy ?? 0,
             })) ?? [],
+        transactionsDaily:
+            data.transactionsDaily?.map((t) => ({
+                time: moment(t.time).add(1, "minute").unix(),
+                finalized: t.finalized ?? 0,
+                failed: t.failed ?? 0,
+            })) ?? [],
     };
 }
 

client/src/models/api/nova/influx/IInfluxDailyResponse.ts

@@ -8,6 +8,13 @@ interface IBlocksDailyInflux {
     candidacy: number | null;
 }
 
+interface ITransactionsDailyInflux {
+    time: Date;
+    finalized: number | null;
+    failed: number | null;
+}
+
 export interface IInfluxDailyResponse extends IResponse {
     blocksDaily?: IBlocksDailyInflux[];
+    transactionsDaily?: ITransactionsDailyInflux[];
 }