machankura/mempool
3
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Fix address tracking issues.

Browse Source
This commit is contained in:
softsimon
2020-05-20 17:00:50 +07:00
parent 9a2fb1fe44
commit e5dfeed63c
7 changed files with 29 additions and 27 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
frontend/src/app/components/about/about.component.html
View File

@@ -67,7 +67,7 @@
<br><br>
<span class="text-small">
Push transactions related to address: <span class="code">{{ '{' }} 'track-address': '3PbJ...bF9B' {{ '}' }}</span>
to receive all new transactions containing that address as input or output. Returns an array of transactions. 'address-transactions' for new mempool transactions and 'address-block-transactions' for new block confirmed transactions.
to receive all new transactions containing that address as input or output. Returns an array of transactions. 'address-transactions' for new mempool transactions and 'block-transactions' for new block confirmed transactions.
</span>
</td>
</tr>

2
frontend/src/app/components/asset/asset.component.ts
View File

@@ -142,7 +142,7 @@ export class AssetComponent implements OnInit, OnDestroy {
this.isLoadingAsset = false;
});
this.stateService.assetTransactions$
this.stateService.mempoolTransactions$
.subscribe((transaction) => {
if (this.transactions.some((t) => t.txid === transaction.txid)) {
return;

2
frontend/src/app/components/start/start.component.ts
View File

@@ -7,8 +7,6 @@ import { WebsocketService } from 'src/app/services/websocket.service';
styleUrls: ['./start.component.scss']
})
export class StartComponent implements OnInit {
view: 'blocks' | 'transactions' = 'blocks';
constructor(
private websocketService: WebsocketService,
) { }

2
frontend/src/app/components/transaction/transaction.component.ts
View File

@@ -30,8 +30,6 @@ export class TransactionComponent implements OnInit, OnDestroy {
transactionTime = -1;
subscription: Subscription;
rightPosition = 0;
constructor(
private route: ActivatedRoute,
private electrsApiService: ElectrsApiService,

3
frontend/src/app/services/state.service.ts
View File

@@ -25,7 +25,6 @@ export class StateService {
mempoolBlocks$ = new ReplaySubject<MempoolBlock[]>(1);
txConfirmed$ = new Subject<Block>();
mempoolTransactions$ = new Subject<Transaction>();
assetTransactions$ = new Subject<Transaction>();
blockTransactions$ = new Subject<Transaction>();
live2Chart$ = new Subject<OptimizedMempoolStats>();
@@ -33,7 +32,7 @@ export class StateService {
viewFiat$ = new BehaviorSubject<boolean>(false);
connectionState$ = new BehaviorSubject<0 | 1 | 2>(2);
markBlock$ = new Subject<MarkBlockState>();
markBlock$ = new ReplaySubject<MarkBlockState>();
keyNavigation$ = new Subject<KeyboardEvent>();
constructor(

16
frontend/src/app/services/websocket.service.ts
View File

@@ -111,20 +111,8 @@ export class WebsocketService {
});
}
if (response['address-block-transactions']) {
response['address-block-transactions'].forEach((addressTransaction: Transaction) => {
this.stateService.blockTransactions$.next(addressTransaction);
});
}
if (response['asset-transactions']) {
response['asset-transactions'].forEach((assetTransaction: Transaction) => {
this.stateService.assetTransactions$.next(assetTransaction);
});
}
if (response['asset-block-transactions']) {
response['asset-block-transactions'].forEach((addressTransaction: Transaction) => {
if (response['block-transactions']) {
response['block-transactions'].forEach((addressTransaction: Transaction) => {
this.stateService.blockTransactions$.next(addressTransaction);
});
}