Sending multiple zkapps (#775)

Author: directcuteo

frontend/src/app/app.service.ts

@@ -32,7 +32,7 @@ export class AppService {
       .pipe(
         map((data: NodeDetailsResponse) => ({
           status: this.getStatus(data),
-          blockHeight: data.transition_frontier.best_tip.height,
+          blockHeight: data.transition_frontier.best_tip?.height,
           blockTime: data.transition_frontier.sync.time,
           peers: data.peers.filter(p => p.connection_status === 'Connected').length,
           download: 0,

frontend/src/app/features/benchmarks/wallets/benchmarks-wallets-zk.service.ts

@@ -1,5 +1,5 @@
 import { Injectable } from '@angular/core';
-import { BehaviorSubject, filter, map, Observable, switchMap } from 'rxjs';
+import { BehaviorSubject, catchError, filter, forkJoin, map, Observable, of, switchMap } from 'rxjs';
 import { BenchmarksZkapp } from '@shared/types/benchmarks/transactions/benchmarks-zkapp.type';
 import { fromPromise } from 'rxjs/internal/observable/innerFrom';
 import { CONFIG } from '@shared/constants/config';
@@ -24,17 +24,29 @@ export class BenchmarksWalletsZkService {
     return this.o1jsInterface.pipe(
       filter(Boolean),
       switchMap((o1js: any) => {
-        // return fromPromise(o1js.deployZkApp(CONFIG.globalConfig?.graphQL, zkApps[0], this.updates));
-        return fromPromise(o1js.updateZkApp(CONFIG.globalConfig?.graphQL, zkApps[0], this.updates));
+        const executeSequentially = async (): Promise<any[]> => {
+          const results: any[] = [];
+          for (const zkApp of zkApps) {
+            const response = await o1js.updateZkApp(CONFIG.globalConfig?.graphQL, zkApp, this.updates);
+            results.push(response);
+          }
+          return results;
+        };
+
+        return fromPromise(executeSequentially());
       }),
-      map((response: any) => {
-        if (response.errors[0]) {
-          let error = new Error(response.errors[0]);
-          error.name = response.status;
+      map((responses: any[]) => {
+        const errors = responses.filter(response => response.errors && response.errors[0]);
+        if (errors.length > 0) {
+          let error = new Error(errors[0].errors[0]);
+          error.name = errors[0].status;
           return { error, zkApps };
         }
         return { zkApps };
       }),
+      catchError((error: Error) => {
+        return of({ error, zkApps });
+      }),
     );
   }
 

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

@@ -41,7 +41,10 @@
         </div>
       </button>
       <div class="tertiary text-italic ml-10" *ngIf="updates$ | async as updates">
-        {{ updates.step }} <span class="secondary">{{ updates.duration }}<span *ngIf="updates.duration">s</span></span>
+        <ng-container *ngIf="updates.step">
+          {{ updates.step }} <span class="secondary">{{ updates.duration }}<span
+          *ngIf="updates.duration">s</span></span>
+        </ng-container>
       </div>
     </form>
   </div>

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

@@ -227,7 +227,6 @@ export function reducer(state: BenchmarksWalletsState = initialState, action: Be
 
     case BENCHMARKS_WALLETS_GET_ALL_TXS_SUCCESS: {
       const allTxs = [...action.payload.mempoolTxs, ...action.payload.includedTxs];
-      console.log(allTxs);
       return {
         ...state,
         wallets: state.wallets.map((w: BenchmarksWallet) => {

frontend/src/assets/o1js/o1jsWrapper.js

@@ -0,0 +1 @@
+Subproject commit a371c609e65ed37d7870eb23d129e101108fa1d8