feat(wallet-gateway-remote): added connectivity status to login #1003
There are no files selected for viewing
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,53 @@ | ||
| // Copyright (c) 2025 Digital Asset (Switzerland) GmbH and/or its affiliates. All rights reserved. | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| import { LedgerClient } from '@canton-network/core-ledger-client' | ||
| import { Logger } from 'pino' | ||
| import { NetworkCacheStore } from '../cache/network-cache.js' | ||
|
|
||
| export async function startLedgerConnectivityTester( | ||
| networkCacheStore: NetworkCacheStore, | ||
| logger: Logger | ||
| ) { | ||
| const networks = await networkCacheStore.getStore().listNetworks() | ||
|
|
||
| networks.map(async (network) => { | ||
| try { | ||
| logger.debug( | ||
| `Testing connectivity for network ${network.name} (${network.id})...` | ||
| ) | ||
|
|
||
| //connectivity test | ||
| const ledgerClient = new LedgerClient({ | ||
| baseUrl: new URL(network.ledgerApi.baseUrl), | ||
| logger: logger, | ||
| }) | ||
| let connectivityCheck = false | ||
|
|
||
| try { | ||
| const version = await ledgerClient.get('/v2/version') | ||
| if (version.version) { | ||
| connectivityCheck = true | ||
| } | ||
| } catch (error) { | ||
| logger.debug( | ||
| `Failed to connect to ledger at ${network.name}(${network.ledgerApi.baseUrl}): ${JSON.stringify(error)}` | ||
| ) | ||
| } | ||
|
|
||
| networkCacheStore.getCache().set(network.id, { | ||
| ...network, | ||
| verified: connectivityCheck, | ||
| }) | ||
| logger.info( | ||
| connectivityCheck | ||
| ? `Network ${network.name} (${network.id}) verified successfully.` | ||
| : `Network ${network.name} (${network.id}) verification failed.` | ||
| ) | ||
| } catch (error) { | ||
| logger.error( | ||
| `Failed to verify network ${network.name} (${network.id}): ${error}` | ||
| ) | ||
| } | ||
| }) | ||
| } |
This file contains hidden or bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,75 @@ | ||
| // Copyright (c) 2025 Digital Asset (Switzerland) GmbH and/or its affiliates. All rights reserved. | ||
| // SPDX-License-Identifier: Apache-2.0 | ||
|
|
||
| import { LRUCache } from 'typescript-lru-cache' | ||
| import { | ||
| Store, | ||
| Network, | ||
| VerifiedNetwork, | ||
| } from '@canton-network/core-wallet-store' | ||
| import { Logger } from 'pino' | ||
|
|
||
| export const DEFAULT_MAX_CACHE_SIZE = 100 | ||
| export const DEFAULT_ENTRY_EXPIRATION_TIME = 10 * 60 * 1000 | ||
|
|
||
| const NetworkCache = new LRUCache<string, VerifiedNetwork>({ | ||
|
Contributor
There was a problem hiding this comment. Why not simply cache the status for each network With This way, when listing existing networks, nothing needs to change, except for an additional cache lookup to get the status. |
||
| maxSize: DEFAULT_MAX_CACHE_SIZE, | ||
| entryExpirationTimeInMS: DEFAULT_ENTRY_EXPIRATION_TIME, | ||
| }) | ||
|
|
||
| export class NetworkCacheStore { | ||
|
Contributor
There was a problem hiding this comment. I don't see the benefit of this. I'd separate concerns and only cache the |
||
| constructor( | ||
| private readonly store: Store, | ||
| private readonly logger: Logger | ||
| ) {} | ||
|
Comment on lines
+20
to
+24
Contributor
There was a problem hiding this comment. Do you need all this? I'm wondering why not decouple the cache from the underlying store? The network cache can just store In the controller you retrieve the network from the store directly, and merge based on ID to include the verified status
Contributor
There was a problem hiding this comment. if we wanted to go all out, we might even feel inclined to design a |
||
|
|
||
| getCache() { | ||
| return NetworkCache | ||
| } | ||
|
|
||
| getStore() { | ||
| return this.store | ||
| } | ||
|
|
||
| async getNetwork(networkId: string): Promise<VerifiedNetwork> { | ||
| const cachedNetwork = NetworkCache.get(networkId) | ||
| if (cachedNetwork) { | ||
| return cachedNetwork | ||
| } | ||
| return await this.store.getNetwork(networkId) | ||
| } | ||
|
|
||
| getCurrentNetwork(): Promise<VerifiedNetwork> { | ||
| return this.store.getCurrentNetwork() | ||
| } | ||
|
|
||
| listNetworks(): Promise<Array<VerifiedNetwork>> { | ||
| if (NetworkCache.size !== 0) { | ||
| return Promise.resolve(NetworkCache.values().toArray()) | ||
| } | ||
| return this.store.listNetworks() | ||
| } | ||
|
|
||
| updateNetwork(network: Network): Promise<void> { | ||
| NetworkCache.set(network.id, { | ||
| ...network, | ||
| verified: false, | ||
| }) | ||
|
|
||
| return this.store.updateNetwork(network) | ||
| } | ||
|
|
||
| addNetwork(network: Network): Promise<void> { | ||
| NetworkCache.set(network.id, { | ||
| ...network, | ||
| verified: false, | ||
| }) | ||
|
|
||
| return this.store.addNetwork(network) | ||
| } | ||
| removeNetwork(networkId: string): Promise<void> { | ||
| NetworkCache.delete(networkId) | ||
|
|
||
| return this.store.removeNetwork(networkId) | ||
| } | ||
| } | ||
Oops, something went wrong.
Oops, something went wrong.
Add this suggestion to a batch that can be applied as a single commit.
This suggestion is invalid because no changes were made to the code.
Suggestions cannot be applied while the pull request is closed.
Suggestions cannot be applied while viewing a subset of changes.
Only one suggestion per line can be applied in a batch.
Add this suggestion to a batch that can be applied as a single commit.
Applying suggestions on deleted lines is not supported.
You must change the existing code in this line in order to create a valid suggestion.
Outdated suggestions cannot be applied.
This suggestion has been applied or marked resolved.
Suggestions cannot be applied from pending reviews.
Suggestions cannot be applied on multi-line comments.
Suggestions cannot be applied while the pull request is queued to merge.
Suggestion cannot be applied right now. Please check back later.
Uh oh!
There was an error while loading. Please reload this page.