From c018f66e4d7ee939a2e1162eba67f74e72df4136 Mon Sep 17 00:00:00 2001 From: Jaco Greeff Date: Fri, 7 Sep 2018 12:29:24 +0200 Subject: [PATCH] FIXME around RxJs (with types) upgrade --- .../ui-react-rx/src/ApiObservable/index.ts | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) diff --git a/packages/ui-react-rx/src/ApiObservable/index.ts b/packages/ui-react-rx/src/ApiObservable/index.ts index dfe7155ef2..7716eb91e5 100644 --- a/packages/ui-react-rx/src/ApiObservable/index.ts +++ b/packages/ui-react-rx/src/ApiObservable/index.ts @@ -36,7 +36,8 @@ export default class ObservableApi implements ObservableApiInterface { private combine = (observables: Array>, mapfn: MapFn = defaultMapFn): Observable => { return combineLatest(...observables).pipe( - defaultIfEmpty([]), + // FIXME There are a couple of places now where this casting happens after rxjs 6.3.2 + defaultIfEmpty([] as any), map(mapfn) ); } @@ -58,6 +59,7 @@ export default class ObservableApi implements ObservableApiInterface { return this .rawStorageMulti([key, ...params] as KeyWithParams) .pipe( + // @ts-ignore After upgrade to 6.3.2 map(([result]: Array): T => result ) @@ -110,6 +112,7 @@ export default class ObservableApi implements ObservableApiInterface { return this .rawStorage(storage.democracy.public.proposals) .pipe( + // @ts-ignore After upgrade to 6.3.2 map((proposals: Array = []) => proposals .map((result: ResultProposal): RxProposal | undefined => @@ -142,6 +145,7 @@ export default class ObservableApi implements ObservableApiInterface { return this .rawStorage(storage.democracy.public.depositOf, proposalId) .pipe( + // @ts-ignore After upgrade to 6.3.2 map((result: ResultProposalDeposits): RxProposalDeposits | undefined => result && result[0] ? { @@ -161,6 +165,7 @@ export default class ObservableApi implements ObservableApiInterface { return this .rawStorage(storage.democracy.public.referendumInfoOf, referendumId) .pipe( + // @ts-ignore After upgrade to 6.3.2 map((result: ResultReferendum) => result && result[1] ? { @@ -209,6 +214,7 @@ export default class ObservableApi implements ObservableApiInterface { this.democracyNextTally() ] ).pipe( + // @ts-ignore After upgrade to 6.3.2 switchMap(([referendumCount, nextTally]: [OptBN, OptBN]): Observable> => referendumCount && nextTally && referendumCount.gt(nextTally) && referendumCount.gtn(0) ? this.democracyReferendumInfos( @@ -238,6 +244,7 @@ export default class ObservableApi implements ObservableApiInterface { return this .rawStorage(storage.democracy.public.votersFor, index) .pipe( + // @ts-ignore After upgrade to 6.3.2 map((voters: Array = []) => voters ) @@ -251,7 +258,7 @@ export default class ObservableApi implements ObservableApiInterface { switchMap((voters: Array = []) => this.votingBalances(...voters) ), - defaultIfEmpty([]), + defaultIfEmpty([] as any), map((balances: Array) => balances.map(({ votingBalance }) => votingBalance @@ -267,7 +274,7 @@ export default class ObservableApi implements ObservableApiInterface { switchMap((voters: Array = []) => this.democracyVotesOf(referendumId, voters) ), - defaultIfEmpty([]) + defaultIfEmpty([] as any) ); } @@ -428,6 +435,7 @@ export default class ObservableApi implements ObservableApiInterface { return this .rawStorage(storage.session.public.validators) .pipe( + // @ts-ignore After upgrade to 6.3.2 map((validators: Array = []) => validators ) @@ -438,6 +446,7 @@ export default class ObservableApi implements ObservableApiInterface { return this .rawStorage(storage.staking.public.intentions) .pipe( + // @ts-ignore After upgrade to 6.3.2 map((intentions: Array = []) => intentions ) @@ -452,6 +461,7 @@ export default class ObservableApi implements ObservableApiInterface { return this .rawStorage(storage.staking.public.nominatorsFor, address) .pipe( + // @ts-ignore After upgrade to 6.3.2 map((nominators: Array = []) => nominators ) @@ -539,7 +549,7 @@ export default class ObservableApi implements ObservableApiInterface { switchMap((nominators: Array) => this.votingBalances(...nominators) ), - defaultIfEmpty([]) + defaultIfEmpty([] as any) ); }