@ -1,17 +1,21 @@
import { Component , OnInit , OnDestroy , ViewChild } from '@angular/core' ;
import { Subject } from 'rxjs' ;
import { takeUntil } from 'rxjs/operators' ;
import { Store } from '@ngrx/store' ;
import { MatTableDataSource } from '@angular/material/table' ;
import { MatSort } from '@angular/material/sort' ;
import { MatPaginator , MatPaginatorIntl } from '@angular/material/paginator' ;
import { fa Water , faExclamationTriangle } from '@fortawesome/free-solid-svg-icons' ;
import { fa Bullhorn , faExclamationTriangle } from '@fortawesome/free-solid-svg-icons' ;
import { DataService } from '../../shared/services/data.service' ;
import { LoggerService } from '../../shared/services/logger.service' ;
import { CommonService } from '../../shared/services/common.service' ;
import { A PICallStatusEnum, getPaginatorLabel , PAGE_SIZE , PAGE_SIZE_OPTIONS , ScreenSizeEnum } from '../../shared/services/consts-enums-functions' ;
import { A lertTypeEnum, A PICallStatusEnum, DataType Enum, getPaginatorLabel , PAGE_SIZE , PAGE_SIZE_OPTIONS , ScreenSizeEnum } from '../../shared/services/consts-enums-functions' ;
import { LookupNode } from '../../shared/models/clnModels' ;
import { ApiCallStatusPayload } from '../../shared/models/apiCallsPayload' ;
import { openConfirmation } from '../../store/rtl.actions' ;
import { RTLState } from '../../store/rtl.state' ;
import { RTLEffects } from '../../store/rtl.effects' ;
@Component ( {
selector : 'rtl-cln-liquidity-ads' ,
@ -25,13 +29,15 @@ export class CLNLiquidityAdsComponent implements OnInit, OnDestroy {
@ViewChild ( MatSort , { static : false } ) sort : MatSort | undefined ;
@ViewChild ( MatPaginator , { static : false } ) paginator : MatPaginator | undefined ;
public askTooltipMsg = '' ;
public nodesTooltipMsg = '' ;
public displayedColumns : any [ ] = [ ] ;
public faWater = faWater ;
public fa Bullhorn = faBullhorn ;
public faExclamationTriangle = faExclamationTriangle ;
public channelAmount = 0 ;
public channelOpeningFeeRate = 0 ;
public nodeCapacity = ;
public channelCount = 0 ;
public nodeCapacity = 50000 0;
public channelCount = 5 ;
public liquidityNodesData : LookupNode [ ] = [ ] ;
public liquidityNodes : any ;
public flgSticky = false ;
@ -44,7 +50,10 @@ export class CLNLiquidityAdsComponent implements OnInit, OnDestroy {
public apiCallStatusEnum = APICallStatusEnum ;
private unSubs : Array < Subject < void > > = [ new Subject ( ) , new Subject ( ) , new Subject ( ) , new Subject ( ) ] ;
constructor ( private logger : LoggerService , private dataService : DataService , private commonService : CommonService ) {
constructor ( private logger : LoggerService , private store : Store < RTLState > , private dataService : DataService , private commonService : CommonService , private rtlEffects : RTLEffects ) {
this . askTooltipMsg = 'Specify the liquidity requirements for your node: \n 1. Channel Amount - Amount in Sats you need for the channel opened to your node \n 2. Channel opening fee rate - Rate in Sats/vByte that you are willing to pay to open the channel to you' ;
this . nodesTooltipMsg = 'These are the nodes which are advertising their liquidity offering on the network.\nYou should pay attention to the following aspects to evaluate each node offer: \n- The total bitcoin deployed on the node, the more the better\n' ;
this . nodesTooltipMsg = this . nodesTooltipMsg + '- The number of channels open on the node, the more the better\n- The channel open fee which the node will charge from you\n- The routing fee which the node will charge on the payments, the lesser the better\n- The reliability of the node, ideally uptime. Refer to the information being provided by the node explorers' ;
this . screenSize = this . commonService . getScreenSize ( ) ;
if ( this . screenSize === ScreenSizeEnum . XS ) {
this . flgSticky = false ;
@ -83,23 +92,60 @@ export class CLNLiquidityAdsComponent implements OnInit, OnDestroy {
onFilter() {
this . logger . info ( this . nodeCapacity ) ;
this . logger . info ( this . channelCount ) ;
// this.liquidityNodes.filter = this.nodeCapacity + ' ' + this.channelCount;
this . liquidityNodes . filter = this . nodeCapacity + ' ' + this . channelCount ;
}
loadLiqNodesTable ( liqNodes : LookupNode [ ] ) {
this . liquidityNodes = new MatTableDataSource < LookupNode > ( [ . . . liqNodes ] ) ;
this . liquidityNodes . sortingDataAccessor = ( data : any , sortHeaderId : string ) = > ( ( data [ sortHeaderId ] && isNaN ( data [ sortHeaderId ] ) ) ? data [ sortHeaderId ] . toLocaleLowerCase ( ) : data [ sortHeaderId ] ? + data [ sortHeaderId ] : null ) ;
this . liquidityNodes . sort = this . sort ;
this . liquidityNodes . filterPredicate = ( node : LookupNode , fltr : string ) = > JSON . stringify ( node ) . toLowerCase ( ) . includes ( fltr ) ;
this . liquidityNodes . filterPredicate = ( node : LookupNode , fltr : string ) = > {
console . warn ( node . channelCount ) ;
console . warn ( node . nodeCapacity ) ;
console . warn ( node . channelCount >= this . channelCount && node . nodeCapacity >= this . nodeCapacity ) ;
return node . channelCount >= this . channelCount && node . nodeCapacity >= this . nodeCapacity ;
}
this . liquidityNodes . paginator = this . paginator ;
this . onFilter ( ) ;
}
onOpenChannel ( lqNode : LookupNode ) {
}
onNodeClick ( lqNode : LookupNode ) {
}
onViewLeaseInfo ( lqNode : LookupNode ) {
const addArr = lqNode . addresses . reduce ( ( acc , curr ) = > {
if ( curr . address . length > 40 ) { curr . address = curr . address . substring ( 0 , 39 ) + '...' ; }
return acc . concat ( JSON . stringify ( curr ) . replace ( '{' , '' ) . replace ( '}' , '' ) . replace ( /:/g , ': ' ) . replace ( /,/g , ' ' ) . replace ( /"/g , '' ) ) ;
} , [ ] ) ;
const reorderedLQNode = [
[ { key : 'alias' , value : lqNode.alias , title : 'Node Alias' , width : 50 , type : DataTypeEnum . STRING } ,
{ key : 'last_timestamp' , value : lqNode.last_timestamp , title : 'Last Timestamp' , width : 50 , type : DataTypeEnum . DATE_TIME } ] ,
[ { key : 'nodeid' , value : lqNode.nodeid , title : 'Node ID' , width : 100 , type : DataTypeEnum . STRING } ] ,
[ { key : 'base_fee' , value : ( lqNode . option_will_fund . lease_fee_base_msat / 1000 ) , title : 'Lease Base Fee (Sats)' , width : 50 , type : DataTypeEnum . NUMBER } ,
{ key : 'fee_basis' , value : lqNode.option_will_fund.lease_fee_basis , title : 'Lease Base Basis (bps)' , width : 50 , type : DataTypeEnum . NUMBER } ] ,
[ { key : 'lease_fee_rate' , value : '-000' , title : 'Lease Fee Rate (ppm)' , width : 50 , type : DataTypeEnum . NUMBER } ,
{ key : 'funding_rate' , value : lqNode.option_will_fund.funding_weight , title : 'Channel Open Funding Rate' , width : 50 , type : DataTypeEnum . NUMBER } ] ,
[ { key : 'channel_max_base' , value : ( lqNode . option_will_fund . channel_fee_max_base_msat / 1000 ) , title : 'Max Channel Routing Base Fee (Sats)' , width : 50 , type : DataTypeEnum . NUMBER } ,
{ key : 'channel_max_rate' , value : lqNode.option_will_fund.channel_fee_max_proportional_thousandths , title : 'Max Channel Routing Fee Rate (ppm)' , width : 50 , type : DataTypeEnum . NUMBER } ] ,
[ { key : 'address' , value : addArr , title : 'Address' , width : 100 , type : DataTypeEnum . ARRAY } ]
] ;
this . store . dispatch ( openConfirmation ( {
payload : {
data : {
type : AlertTypeEnum . CONFIRM ,
alertTitle : 'Lease Information' ,
noBtnText : 'Close' ,
yesBtnText : 'Open Channel' ,
message : reorderedLQNode
}
}
} ) ) ;
this . rtlEffects . closeConfirm . pipe ( takeUntil ( this . unSubs [ 1 ] ) ) . subscribe ( ( confirmRes ) = > {
if ( confirmRes ) {
console . warn ( 'Open Channel Modal' ) ;
}
} ) ;
}
onDownloadCSV() {
Shahana Farooqui
2 years ago
committed by
ShahanaFarooqui