mirrors/mempool
1
0
Fork 0
mirror of https://github.com/mempool/mempool.git synced 2024-12-26 16:24:26 +01:00
Code Issues Projects Releases Wiki Activity

Refactor pool ranking rxjs observable

Browse Source
This commit is contained in:
nymkappa 2022-06-01 14:07:01 +02:00
parent 3196c188f1
commit 429b4f2bc6
No known key found for this signature in database
GPG Key ID: E155910B16E8BD04
1 changed files with 14 additions and 21 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
frontend/src/app/components/pool-ranking/pool-ranking.component.ts
View File

@ -2,8 +2,8 @@ import { ChangeDetectionStrategy, Component, Input, NgZone, OnInit, HostBinding
import { FormBuilder, FormGroup } from '@angular/forms'; import { FormBuilder, FormGroup } from '@angular/forms';
import { Router } from '@angular/router'; import { Router } from '@angular/router';
import { EChartsOption, PieSeriesOption } from 'echarts'; import { EChartsOption, PieSeriesOption } from 'echarts';
import { combineLatest, Observable, of } from 'rxjs'; import { concat, Observable } from 'rxjs';
import { catchError, map, share, skip, startWith, switchMap, tap } from 'rxjs/operators'; import { map, share, startWith, switchMap, tap } from 'rxjs/operators';
import { SinglePoolStats } from 'src/app/interfaces/node-api.interface'; import { SinglePoolStats } from 'src/app/interfaces/node-api.interface';
import { SeoService } from 'src/app/services/seo.service'; import { SeoService } from 'src/app/services/seo.service';
import { StorageService } from '../..//services/storage.service'; import { StorageService } from '../..//services/storage.service';
@ -58,15 +58,7 @@ export class PoolRankingComponent implements OnInit {
this.radioGroupForm = this.formBuilder.group({ dateSpan: this.miningWindowPreference }); this.radioGroupForm = this.formBuilder.group({ dateSpan: this.miningWindowPreference });
this.radioGroupForm.controls.dateSpan.setValue(this.miningWindowPreference); this.radioGroupForm.controls.dateSpan.setValue(this.miningWindowPreference);
// When... this.miningStatsObservable$ = concat(
this.miningStatsObservable$ = combineLatest([
// ...a new block is mined
this.stateService.blocks$
.pipe(
// (we always receives some blocks at start so only trigger for the last one)
skip(this.stateService.env.MEMPOOL_BLOCKS_AMOUNT - 1),
),
// ...or we change the timespan
this.radioGroupForm.get('dateSpan').valueChanges this.radioGroupForm.get('dateSpan').valueChanges
.pipe( .pipe(
startWith(this.miningWindowPreference), // (trigger when the page loads) startWith(this.miningWindowPreference), // (trigger when the page loads)
@ -76,18 +68,19 @@ export class PoolRankingComponent implements OnInit {
this.storageService.setValue('miningWindowPreference', value); this.storageService.setValue('miningWindowPreference', value);
} }
this.miningWindowPreference = value; this.miningWindowPreference = value;
}),
switchMap(() => {
return this.miningService.getMiningStats(this.miningWindowPreference);
}) })
) ),
]) this.stateService.blocks$
// ...then refresh the mining stats
.pipe( .pipe(
switchMap(() => { switchMap(() => {
this.isLoading = true; return this.miningService.getMiningStats(this.miningWindowPreference);
return this.miningService.getMiningStats(this.miningWindowPreference) })
)
)
.pipe( .pipe(
catchError((e) => of(this.getEmptyMiningStat()))
);
}),
map(data => { map(data => {
data.pools = data.pools.map((pool: SinglePoolStats) => this.formatPoolUI(pool)); data.pools = data.pools.map((pool: SinglePoolStats) => this.formatPoolUI(pool));
data['minersLuck'] = (100 * (data.blockCount / 1008)).toFixed(2); // luck 1w data['minersLuck'] = (100 * (data.blockCount / 1008)).toFixed(2); // luck 1w