Skip to content

Commit 1aae901

Browse files
fixup! feat: asset tracker now uses local cache before fetching asset metadata
1 parent 2cbd5e3 commit 1aae901

File tree

2 files changed

+23
-10
lines changed

2 files changed

+23
-10
lines changed

packages/util-rxjs/src/coldObservableProvider.ts

Lines changed: 11 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -51,14 +51,24 @@ export const coldObservableProvider = <T>({
5151
: // emit value, but also throw error to force retryBackoff to kick in
5252
concat(
5353
of(v),
54-
throwError(() => new Error('polling'))
54+
defer(() => {
55+
// Add logging here
56+
// eslint-disable-next-line no-console
57+
console.error('Poll until condition not met. Value:', v);
58+
// eslint-disable-next-line no-console
59+
console.error('Emitting error to trigger retry.');
60+
return throwError(() => new Error('polling'));
61+
})
5562
)
5663
)
5764
)
5865
).pipe(
5966
retryBackoff({
6067
...retryBackoffConfig,
6168
shouldRetry: (error) => {
69+
// eslint-disable-next-line no-console
70+
console.error('Retrying due to error:', error.message);
71+
6272
if (retryBackoffConfig.shouldRetry && !retryBackoffConfig.shouldRetry(error)) return false;
6373

6474
if (error instanceof InvalidStringError) {

packages/wallet/src/services/AssetsTracker.ts

Lines changed: 12 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -126,16 +126,19 @@ export const createAssetService =
126126
coldObservableProvider({
127127
onFatalError,
128128
pollUntil: isEveryAssetInfoComplete,
129-
provider: async () => {
129+
provider: () => {
130130
// eslint-disable-next-line no-console
131-
console.error(assetIdsChunk);
132-
const result = await assetProvider.getAssets({
133-
assetIds: assetIdsChunk,
134-
extraData: { nftMetadata: true, tokenMetadata: true }
135-
});
136-
// eslint-disable-next-line no-console
137-
console.error(result);
138-
return result;
131+
console.error('Fetching asset info for assetIds:', assetIdsChunk);
132+
return assetProvider
133+
.getAssets({
134+
assetIds: assetIdsChunk,
135+
extraData: { nftMetadata: true, tokenMetadata: true }
136+
})
137+
.then((assets) => {
138+
// eslint-disable-next-line no-console
139+
console.error('Fetched assets:', assets);
140+
return assets;
141+
});
139142
},
140143
retryBackoffConfig,
141144
trigger$: of(true) // fetch only once

0 commit comments

Comments
 (0)