Feat: Web Provider RPC 🗣️

packages/key-management/src/chains/Mina/signingOperations.ts

@@ -30,10 +30,10 @@ export async function MinaSigningOperations<T extends MinaSignablePayload>(
       // in the object deanonimize the user. We should only return what the zkApp needs
       return minaClient.createNullifier(payload.messageNullifier, privateKey)
     } else {
-      throw new Error('Unsupported payload type.')
+      throw new Error(`Unsupported payload type of ${payload}.`)
     }
   } catch (err) {
     const errorMessage = errors.getRealErrorMsg(err) || 'Signing action failed.'
-    throw new Error(errorMessage)
+    throw new Error(`Error during Mina signing operations: ${errorMessage}`)
   }
 }

packages/mina-core/src/Mina/types/index.ts

@@ -4,6 +4,7 @@ export * from './Block'
 export * from './Fields'
 export * from './Message'
 export * from './Networks'
+export * from './Nullifier'
 export * from './Pagination'
 export * from './Transaction'
 export * from './ZkApp'

packages/mina-core/src/Providers/DaemonStatusProvider/index.ts

@@ -0,0 +1 @@
+export * from './types'

packages/mina-core/src/Providers/DaemonStatusProvider/types.ts

@@ -0,0 +1,16 @@
+import { Provider } from '../..'
+
+export interface DaemonStatus {
+  daemonStatus: {
+    chainId: string
+  }
+}
+
+export interface DaemonStatusProvider extends Provider {
+  /**
+   * Gets the daemon status.
+   *
+   * @returns {DaemonStatus} - An object with daemon status information
+   */
+  getDaemonStatus: () => Promise<DaemonStatus>
+}

packages/mina-core/src/Providers/UnifiedProvider.ts

@@ -4,6 +4,7 @@ import {
   TransactionsByAddressesArgs,
   TransactionsByIdsArgs
 } from './ChainHistoryProvider'
+import { DaemonStatus } from './DaemonStatusProvider'
 import { TxStatus, TxStatusArgs } from './TxStatusProvider'
 import { SubmitTxArgs, SubmitTxResult } from './TxSubmitProvider'
 
@@ -20,6 +21,7 @@ export interface UnifiedMinaProviderType {
   getAccountInfo(args: AccountInfoArgs): Promise<AccountInfo | undefined>
   getTransactionStatus(args: TxStatusArgs): Promise<TxStatus | undefined>
   submitTransaction(args: SubmitTxArgs): Promise<SubmitTxResult | undefined>
+  getDaemonStatus(): Promise<DaemonStatus | undefined>
 
   // Methods related to ProviderArchive
   getTransactions(

packages/mina-core/src/Providers/index.ts

@@ -1,5 +1,6 @@
 export * from './AccountInfoProvider'
 export * from './ChainHistoryProvider'
+export * from './DaemonStatusProvider'
 export * from './Provider'
 export * from './TxStatusProvider'
 export * from './TxSubmitProvider'

packages/mina-graphql/src/Providers/DaemonStatus/DaemonStatusProvider.ts

@@ -0,0 +1,88 @@
+import {
+  DaemonStatus,
+  DaemonStatusProvider,
+  HealthCheckResponse,
+  HealthCheckResponseData
+} from '@palladxyz/mina-core'
+import { gql, request } from 'graphql-request'
+
+import { getDaemonStatus, healthCheckQuery } from './queries'
+
+export class DaemonStatusGraphQLProvider implements DaemonStatusProvider {
+  private minaGql: string | null
+
+  constructor(minaGql: string) {
+    this.minaGql = minaGql
+  }
+
+  public async destroy(): Promise<void> {
+    console.log('Destroying DaemonStatusGraphQLProvider...')
+    this.minaGql = null
+  }
+
+  async changeNetwork(minaGql: string): Promise<void> {
+    this.minaGql = minaGql
+  }
+
+  async healthCheck(): Promise<HealthCheckResponse> {
+    console.log('Initiating health check...')
+    const query = gql`
+      ${healthCheckQuery}
+    `
+    try {
+      console.log('Sending request for health check...')
+      const data = (await request(
+        this.minaGql as string,
+        query
+      )) as HealthCheckResponseData
+      console.log('Received response for health check:', data)
+
+      if (data && data.__schema && data.__schema.types.length > 0) {
+        return { ok: true }
+      } else {
+        throw new Error('Invalid schema response')
+      }
+    } catch (error: unknown) {
+      console.error('Error in healthCheck:', error)
+      let errorMessage = 'Unknown error'
+      if (error instanceof Error) {
+        errorMessage = error.message
+      }
+      return { ok: false, message: errorMessage }
+    }
+  }
+
+  async getDaemonStatus(): Promise<DaemonStatus> {
+    console.log('Initiating getDaemonStatus')
+    const query = gql`
+      ${getDaemonStatus}
+    `
+    try {
+      console.log('Sending request for daemon status...')
+      const data = (await request(
+        this.minaGql as string,
+        query,
+        {}
+      )) as DaemonStatus
+      console.log('Received response for daemon status:', data)
+
+      if (!data || !data.daemonStatus || !data.daemonStatus.chainId) {
+        throw new Error('Invalid daemon status data response')
+      }
+      return data
+    } catch (error: unknown) {
+      // this can fail if the node is not available
+      // perform health check to see if the node is available
+      const healthCheckResponse = await this.healthCheck()
+      if (!healthCheckResponse.ok) {
+        throw new Error('Node is not available')
+      }
+      console.error('Error in getDaemonStatus:', error)
+      return {
+        daemonStatus: {
+          chainId: 'N/A'
+        }
+      }
+    }
+  }
+}

packages/mina-graphql/src/Providers/DaemonStatus/index.ts

@@ -0,0 +1 @@
+export * from './DaemonStatusProvider'

packages/mina-graphql/src/Providers/DaemonStatus/queries.ts

@@ -0,0 +1,17 @@
+export const healthCheckQuery = `
+  {
+    __schema {
+      types {
+        name
+      }
+    }
+  }
+`
+
+export const getDaemonStatus = `
+query {
+  daemonStatus {
+    chainId
+  }
+}
+`

packages/mina-graphql/src/Providers/index.ts

@@ -1,5 +1,6 @@
 export * from './AccountInfo'
 export * from './ChainHistory'
+export * from './DaemonStatus'
 export * from './provider'
 export * from './providerArchive'
 export * from './TxStatus'

packages/mina-graphql/src/Providers/provider.ts

@@ -1,14 +1,16 @@
 import {
   AccountInfo,
   AccountInfoArgs,
+  DaemonStatus,
+  HealthCheckResponse,
   SubmitTxArgs,
   SubmitTxResult,
   TxStatus,
   TxStatusArgs
 } from '@palladxyz/mina-core'
-import { HealthCheckResponse } from '@palladxyz/mina-core'
 
 import { AccountInfoGraphQLProvider } from './AccountInfo'
+import { DaemonStatusGraphQLProvider } from './DaemonStatus'
 import { TxStatusGraphQLProvider } from './TxStatus'
 import { TxSubmitGraphQLProvider } from './TxSubmit'
 import { ProviderNode } from './types'
@@ -17,12 +19,14 @@ export class MinaProvider implements ProviderNode {
   private accountInfoProvider: AccountInfoGraphQLProvider | null
   private txSubmitProvider: TxSubmitGraphQLProvider | null
   private txStatusProvider: TxStatusGraphQLProvider | null
+  private daemonStatusProvider: DaemonStatusGraphQLProvider | null
   public providerUrl: string
 
   constructor(nodeUrl: string) {
     this.accountInfoProvider = new AccountInfoGraphQLProvider(nodeUrl)
     this.txSubmitProvider = new TxSubmitGraphQLProvider(nodeUrl)
     this.txStatusProvider = new TxStatusGraphQLProvider(nodeUrl)
+    this.daemonStatusProvider = new DaemonStatusGraphQLProvider(nodeUrl)
     this.providerUrl = nodeUrl
   }
 
@@ -67,6 +71,10 @@ export class MinaProvider implements ProviderNode {
     return this.txSubmitProvider?.submitTx(args)
   }
 
+  public async getDaemonStatus(): Promise<DaemonStatus | undefined> {
+    return this.daemonStatusProvider?.getDaemonStatus()
+  }
+
   public async healthCheck(): Promise<HealthCheckResponse | undefined> {
     return this.accountInfoProvider?.healthCheck()
   }

packages/mina-graphql/src/Providers/types.ts

@@ -1,6 +1,7 @@
 import {
   AccountInfo,
   AccountInfoArgs,
+  DaemonStatus,
   Mina,
   SubmitTxArgs,
   SubmitTxResult,
@@ -35,6 +36,8 @@ export interface ProviderNode {
   getTransactionStatus(args: TxStatusArgs): Promise<TxStatus | undefined>
 
   submitTransaction(args: SubmitTxArgs): Promise<SubmitTxResult | undefined>
+
+  getDaemonStatus(): Promise<DaemonStatus | undefined>
 }
 
 /**

packages/mina-graphql/src/Providers/unifiedProvider.ts

@@ -1,6 +1,7 @@
 import {
   AccountInfo,
   AccountInfoArgs,
+  DaemonStatus,
   Mina,
   SubmitTxArgs,
   SubmitTxResult,
@@ -60,6 +61,10 @@ export class UnifiedMinaProvider implements ProviderNode, ProviderArchive {
     return this.nodeProvider.submitTransaction(args)
   }
 
+  public async getDaemonStatus(): Promise<DaemonStatus | undefined> {
+    return this.nodeProvider.getDaemonStatus()
+  }
+
   // Methods related to MinaArchiveProvider
   public async getTransactions(
     args: TransactionsByAddressesArgs

packages/mina-graphql/test/Providers/DaemonStatusProvider.test.ts

@@ -0,0 +1,18 @@
+import { DaemonStatusGraphQLProvider } from '../../src/Providers/DaemonStatus'
+
+const minaExplorerGql = 'https://proxy.devnet.minaexplorer.com/'
+
+describe('DaemonStatusGraphQLProvider', () => {
+  test('getDaemonStatus', async () => {
+    const provider = new DaemonStatusGraphQLProvider(minaExplorerGql)
+    const health = await provider.healthCheck()
+    console.log('Health check:', health)
+    if (!health) {
+      throw new Error('Health check failed')
+    }
+    const response = await provider.getDaemonStatus()
+    console.log('Response:', response)
+
+    expect(response).not.toBe({ daemonSatus: { chainId: 'N/A' } })
+  })
+})

packages/multi-chain-core/src/Multichain/Provider.ts

@@ -59,6 +59,25 @@ export class MultiChainProvider {
     throw new Error('Provider not initialized in Multichain getAccountInfo.')
   }
 
+  public async getChainId(): Promise<string | undefined> {
+    if (
+      this.network === Mina.Networks.MAINNET ||
+      this.network === Mina.Networks.DEVNET ||
+      this.network === Mina.Networks.BERKELEY ||
+      this.network === Mina.Networks.TESTWORLD
+    ) {
+      return await this.specificProvider?.getDaemonStatus().then((status) => {
+        if (status && status.daemonStatus && status.daemonStatus.chainId) {
+          return status.daemonStatus.chainId
+        }
+        throw new Error(
+          'Invalid daemon status data response in Multichain getChainId.'
+        )
+      })
+    }
+    throw new Error('Provider not initialized in Multichain getChainId.')
+  }
+
   public async getTransactionStatus(
     args: MultiChainTransactionStatusArgs
   ): Promise<MultiChainTransactionStatus | undefined> {

packages/multi-chain-core/test/Multichain/Provider.test.ts

@@ -3,19 +3,29 @@ import { Mina } from '@palladxyz/mina-core'
 import { MultiChainProvider } from '../../src/Multichain/Provider'
 
 describe('MultiChainProvider', () => {
-  it('should create a mina provider and query the network', async () => {
-    const provider = new MultiChainProvider(
+  let provider: MultiChainProvider
+
+  beforeAll(() => {
+    provider = new MultiChainProvider(
       {
         nodeUrl: 'https://proxy.berkeley.minaexplorer.com/',
         archiveUrl: 'https://berkeley.graphql.minaexplorer.com'
       },
       Mina.Networks.BERKELEY
     )
+  })
 
+  it('should create a mina provider and query the network', async () => {
     const accountInfo = await provider.getAccountInfo({
       publicKey: 'B62qs2mR2g7LB27P36MhxN5jnsnjS8t6azttZfCnAToVpCmTtRVT2nt'
     })
 
     expect(accountInfo).toBeDefined()
   })
+
+  it('should get the chainId', async () => {
+    const chainId = await provider.getChainId()
+
+    expect(chainId).not.toBe({ daemonSatus: { chainId: 'N/A' } })
+  })
 })

packages/vault/src/lib/Network/NetworkManager.ts

@@ -30,6 +30,14 @@ class NetworkManager<Networks extends Multichain.MultiChainNetworks> {
     }
   }
 
+  public async refreshChainIds(): Promise<void> {
+    await this.providerManager.refreshChainIds()
+  }
+
+  public getAvailableChainIds(): string[] {
+    return this.providerManager.getAvailableChainIds()
+  }
+
   public getActiveProvider(): Multichain.MultiChainProvider | null {
     return this.providerManager.getProvider(this.activeNetwork)
   }

packages/vault/src/lib/Provider/ProviderManager.ts

@@ -23,6 +23,7 @@ export class ProviderManager<Networks extends Multichain.MultiChainNetworks> {
   > = {} as Partial<
     Record<Multichain.MultiChainNetworks, Multichain.MultiChainProvider | null>
   >
+  public availableChainIds: string[] = []
 
   /**
    * Creates a new instance of ProviderManager.
@@ -42,6 +43,22 @@ export class ProviderManager<Networks extends Multichain.MultiChainNetworks> {
     }
   }
 
+  async refreshChainIds() {
+    for (const network in this.providers) {
+      const provider = this.providers[network as Networks]
+      this.availableChainIds.push((await provider?.getChainId()) || '')
+    }
+  }
+
+  /**
+   * Get the available chain ids.
+   * @returns The available chain ids.
+   */
+
+  getAvailableChainIds(): string[] {
+    return this.availableChainIds
+  }
+
   /**
    * Get the Provider for a given network.
    * @param network - The target network.

packages/vault/src/vault/vaultState.ts

@@ -62,6 +62,8 @@ export type GlobalVaultActions = {
     network: Networks,
     derivedCredential: GroupedCredentials
   ) => Promise<void>
+  getChainId: () => Promise<string | undefined>
+  getChainIds: () => Promise<string[] | undefined>
   getCurrentNetwork: () => Networks
   switchNetwork: (network: Multichain.MultiChainNetworks) => Promise<void>
   getCredentials: (query: SearchQuery, props: string[]) => StoredCredential[]