Frontend - Sentry sync events & transactions fix model #965

Frontend - Sentry sync events & transactions fix model

Author: directcuteo

frontend/package-lock.json

@@ -1,6 +1,6 @@
 {
   "name": "frontend",
-  "version": "1.0.44",
+  "version": "1.0.59",
   "scripts": {
     "install:deps": "npm install",
     "start": "npm install && ng serve --configuration local --open",
@@ -53,6 +53,7 @@
     "eigen": "^0.2.2",
     "express": "^4.18.2",
     "firebase": "^11.0.1",
+    "jszip": "^3.10.1",
     "mathjs": "^12.3.0",
     "mina-signer": "^3.0.7",
     "ngx-json-viewer": "^3.2.1",

frontend/package.json

@@ -32,7 +32,7 @@ class AssetMonitor {
         url: resource.toString(),
         startTime,
         progress: 0,
-        totalSize: 27355980,
+        totalSize: 30111552,
         status: 'pending',
         endTime: 0,
         duration: 0,

frontend/src/app/core/helpers/file-progress.helper.ts

@@ -18,6 +18,10 @@ export class RustService {
     this.node = node;
   }
 
+  get activeNodeIsWebNode(): boolean {
+    return this.node.isWebNode;
+  }
+
   get URL(): string {
     return this.node.url;
   }

frontend/src/app/core/services/rust.service.ts

@@ -0,0 +1,70 @@
+import { inject, Injectable } from '@angular/core';
+import { NodesOverviewLedger, NodesOverviewLedgerStepState } from '@shared/types/nodes/dashboard/nodes-overview-ledger.type';
+import * as Sentry from '@sentry/angular';
+import { NodesOverviewBlock, NodesOverviewNodeBlockStatus } from '@shared/types/nodes/dashboard/nodes-overview-block.type';
+import { lastItem, ONE_BILLION } from '@openmina/shared';
+import { RustService } from '@core/services/rust.service';
+
+@Injectable({
+  providedIn: 'root',
+})
+export class SentryService {
+
+  private ledgerIsSynced: boolean = false;
+  private blockIsSynced: boolean = false;
+  private rustService: RustService = inject(RustService);
+
+  updateLedgerSyncStatus(ledger: NodesOverviewLedger): void {
+    if (this.ledgerIsSynced) {
+      return;
+    }
+    if (ledger.rootStaged.state === NodesOverviewLedgerStepState.SUCCESS) {
+      this.ledgerIsSynced = true;
+      const syncDetails = {
+        stakingLedger: {
+          fetchHashes: ledger.stakingEpoch.snarked.fetchHashesDuration + 's',
+          fetchAccounts: ledger.stakingEpoch.snarked.fetchAccountsDuration + 's',
+        },
+        nextEpochLedger: {
+          fetchHashes: ledger.nextEpoch.snarked.fetchHashesDuration + 's',
+          fetchAccounts: ledger.nextEpoch.snarked.fetchAccountsDuration + 's',
+        },
+        snarkedRootLedger: {
+          fetchHashes: ledger.rootSnarked.snarked.fetchHashesDuration + 's',
+          fetchAccounts: ledger.rootSnarked.snarked.fetchAccountsDuration + 's',
+        },
+        stagedRootLedger: {
+          fetchParts: ledger.rootStaged.staged.fetchPartsDuration + 's',
+          reconstruct: ledger.rootStaged.staged.reconstructDuration + 's',
+        },
+      };
+
+      const syncedIn = Math.round((ledger.rootStaged.staged.reconstructEnd - ledger.stakingEpoch.snarked.fetchHashesStart) / ONE_BILLION);
+
+      Sentry.captureMessage(`Ledger synced in ${syncedIn}s`, {
+        level: 'info',
+        tags: { type: 'webnode', subType: 'sync.ledger' },
+        contexts: { ledger: syncDetails },
+      });
+    }
+  }
+
+  updateBlockSyncStatus(blocks: NodesOverviewBlock[], startTime: number): void {
+    if (this.blockIsSynced || !this.rustService.activeNodeIsWebNode) {
+      return;
+    }
+
+    const blocksSynced = blocks.every(b => b.status === NodesOverviewNodeBlockStatus.APPLIED);
+    if (blocksSynced && blocks[0]) {
+      this.blockIsSynced = true;
+      blocks = blocks.slice(1);
+      const bestTipBlock = blocks[0].height;
+      const root = lastItem(blocks).height;
+      Sentry.captureMessage(`Last 290 blocks synced in ${Math.round((Date.now() - startTime) / 1000)}s`, {
+        level: 'info',
+        tags: { type: 'webnode', subType: 'sync.block' },
+        contexts: { blocks: { bestTipBlock, root } },
+      });
+    }
+  }
+}

frontend/src/app/core/services/sentry.service.ts

@@ -1,7 +1,9 @@
 <mina-benchmarks-wallets-toolbar></mina-benchmarks-wallets-toolbar>
 <div class="h-minus-xl flex-column">
-  <mina-benchmarks-wallets-zkapp-toolbar *ngIf="!isWebNode"></mina-benchmarks-wallets-zkapp-toolbar>
-  <div [class.h-minus-xl]="!isWebNode"
+  @if (!isWebNode) {
+    <mina-benchmarks-wallets-zkapp-toolbar></mina-benchmarks-wallets-zkapp-toolbar>
+  }
+  <div [ngClass]="isWebNode ? 'h-100' : 'h-minus-xl'"
        class="flex-column">
     <mina-benchmarks-wallets-table></mina-benchmarks-wallets-table>
   </div>

frontend/src/app/features/benchmarks/wallets/benchmarks-wallets.component.html

@@ -2,7 +2,7 @@ import { Injectable } from '@angular/core';
 import { MinaState, selectMinaState } from '@app/app.setup';
 import { Actions, createEffect, ofType } from '@ngrx/effects';
 import { Effect } from '@openmina/shared';
-import { EMPTY, forkJoin, map, switchMap } from 'rxjs';
+import { combineLatest, EMPTY, map, switchMap } from 'rxjs';
 import { Store } from '@ngrx/store';
 import {
   BENCHMARKS_WALLETS_CLOSE,
@@ -11,8 +11,11 @@ import {
   BENCHMARKS_WALLETS_GET_WALLETS,
   BENCHMARKS_WALLETS_GET_WALLETS_SUCCESS,
   BENCHMARKS_WALLETS_SEND_TX_SUCCESS,
-  BENCHMARKS_WALLETS_SEND_TXS, BENCHMARKS_WALLETS_SEND_ZKAPPS, BENCHMARKS_WALLETS_SEND_ZKAPPS_SUCCESS,
-  BenchmarksWalletsActions, BenchmarksWalletsClose,
+  BENCHMARKS_WALLETS_SEND_TXS,
+  BENCHMARKS_WALLETS_SEND_ZKAPPS,
+  BENCHMARKS_WALLETS_SEND_ZKAPPS_SUCCESS,
+  BenchmarksWalletsActions,
+  BenchmarksWalletsClose,
   BenchmarksWalletsGetWallets,
   BenchmarksWalletsSendTxs,
 } from '@benchmarks/wallets/benchmarks-wallets.actions';
@@ -74,7 +77,7 @@ export class BenchmarksWalletsEffects extends MinaRustBaseEffect<BenchmarksWalle
     this.getAllTxs$ = createEffect(() => this.actions$.pipe(
       ofType(BENCHMARKS_WALLETS_GET_ALL_TXS),
       switchMap(() =>
-        forkJoin([
+        combineLatest([
           this.mempoolService.getTransactionPool(),
           this.benchmarksService.getAllIncludedTransactions(),
         ]),

frontend/src/app/features/benchmarks/wallets/benchmarks-wallets.effects.ts

@@ -1,4 +1,4 @@
-@if (isPending || nodeIsBootstrapping || isCalculatingVRF || isLoading) {
+@if ((isPending || nodeIsBootstrapping || isCalculatingVRF || isLoading) && emptySlots) {
   <div class="w-100 h-100 fx-col-full-cent"
        @fadeInOut>
     <mina-loading-spinner [size]="50" [borderWidth]="2"></mina-loading-spinner>

frontend/src/app/features/block-production/won-slots/block-production-won-slots.component.html

@@ -38,7 +38,7 @@ export class BlockProductionWonSlotsComponent extends StoreDispatcher implements
     total: number;
   };
   epoch: number;
-  emptySlots: boolean = false;
+  emptySlots: boolean = true;
   isLoading: boolean = true;
 
   constructor(protected el: ElementRef) { super(); }
@@ -82,8 +82,9 @@ export class BlockProductionWonSlotsComponent extends StoreDispatcher implements
 
   private listenToActiveEpoch(): void {
     this.select(BlockProductionWonSlotsSelectors.epoch, (activeEpoch) => {
-      this.epoch = activeEpoch.epochNumber;
+      this.epoch = activeEpoch?.epochNumber;
       this.vrfStats = activeEpoch.vrfStats;
+      this.isCalculatingVRF = activeEpoch.vrfStats?.evaluated < activeEpoch.vrfStats?.total;
       this.detect();
     });
   }

frontend/src/app/features/block-production/won-slots/block-production-won-slots.component.ts

@@ -26,7 +26,7 @@ export class BlockProductionWonSlotsService {
           }
           const attemptsSlots = response.attempts.map((attempt: Attempt) => {
             attempt.won_slot.slot_time = Math.floor(attempt.won_slot.slot_time / ONE_MILLION); // converted to milliseconds
-            attempt.active = BlockProductionWonSlotsService.getActive(attempt);
+            attempt.active = this.getActive(attempt);
             let slot = {
               epoch: attempt.won_slot.epoch,
               message: this.getMessage(attempt),
@@ -114,7 +114,7 @@ export class BlockProductionWonSlotsService {
       );
   }
 
-  private static getActive(attempt: Attempt): boolean {
+  private getActive(attempt: Attempt): boolean {
     const slotTime = attempt.won_slot.slot_time;
     const now = Date.now();
     return slotTime <= now && (now < 3 * 60 * 1000 + slotTime) && !attempt.times?.discarded;