Skip to content

Commit

Permalink
fixup! fix(wallet): stop querying the StakePoolProvider for all poo…
Browse files Browse the repository at this point in the history
…ls when no delegation certs found
  • Loading branch information
mkazlauskas committed Aug 8, 2022
1 parent d0f088f commit 1d331b2
Showing 1 changed file with 20 additions and 6 deletions.
Expand Up @@ -3,13 +3,15 @@
/* eslint-disable prettier/prettier */
import { Cardano, RewardsProvider } from '@cardano-sdk/core';
import { EMPTY, Observable, of } from 'rxjs';
import { KeyValueStore } from '../../../src/persistence';
import { InMemoryStakePoolsStore, KeyValueStore } from '../../../src/persistence';
import { RetryBackoffConfig } from 'backoff-rxjs';
import {
StakeKeyStatus,
TrackedStakePoolProvider,
addressKeyStatuses,
addressRewards,
createDelegateeTracker,
createQueryStakePoolsProvider,
createRewardsProvider,
fetchRewardsTrigger$,
getStakePoolIdAtEpoch
Expand Down Expand Up @@ -262,24 +264,36 @@ describe('RewardAccounts', () => {
test('does not query the StakePoolProvider when there are no delegations certs provided', () => {
createTestScheduler().run(({ cold, expectObservable, flush }) => {
const epoch$ = cold('-a', { a: currentEpoch.number });
const stakePoolQueryResult = [{ id: poolId1 }, { id: poolId2 }];
const stakePoolProvider = jest.fn().mockReturnValue(cold('-a', { a: stakePoolQueryResult }));
const trackedStakePoolProvider = {
queryStakePools: jest.fn(),
setStatInitialized: jest.fn(),
stats: { queryStakePools$: {} }
};
const observableStakePoolProvider = createQueryStakePoolsProvider(
trackedStakePoolProvider as unknown as TrackedStakePoolProvider,
new InMemoryStakePoolsStore(),
{ initialInterval: 10 }
);
const target$ = createDelegateeTracker(
stakePoolProvider,
observableStakePoolProvider,
epoch$,
cold('a', {
a: []
})
);
expectObservable(target$).toBe('--a', {
expectObservable(target$).toBe('-a', {
a: {
currentEpoch: undefined,
nextEpoch: undefined,
nextNextEpoch: undefined
}
});
flush();
expect(stakePoolProvider).toBeCalledTimes(0);
expect(trackedStakePoolProvider.queryStakePools).toBeCalledTimes(0);
expect(trackedStakePoolProvider.setStatInitialized).toBeCalledTimes(1);
expect(trackedStakePoolProvider.setStatInitialized).toBeCalledWith(
trackedStakePoolProvider.stats.queryStakePools$
);
});
});
});
Expand Down

0 comments on commit 1d331b2

Please sign in to comment.