@ -4,12 +4,14 @@ import { Router } from '@angular/router';
import { Store } from '@ngrx/store' ; import { Store } from '@ngrx/store' ;
import { Actions , Effect , ofType } from '@ngrx/effects' ; import { Actions , Effect , ofType } from '@ngrx/effects' ;
import { of , Subject } from 'rxjs' ; import { of , Subject } from 'rxjs' ;
import { map , mergeMap , catchError , take , withLatestFrom } from 'rxjs/operators' ; import { map , mergeMap , catchError , withLatestFrom } from 'rxjs/operators' ;
import { Location } from '@angular/common' ;
import { MatDialog } from '@angular/material' ; import { MatDialog } from '@angular/material' ;
import { environment , API_URL } from '../../../environments/environment' ; import { environment , API_URL } from '../../../environments/environment' ;
import { LoggerService } from '../../shared/services/logger.service' ; import { LoggerService } from '../../shared/services/logger.service' ;
import { SessionService } from '../../shared/services/session.service' ;
import { GetInfo , GetInfoChain , Fees , Balance , NetworkInfo , Payment , GraphNode , Transaction , SwitchReq , ListInvoices } from '../../shared/models/lndModels' ; import { GetInfo , GetInfoChain , Fees , Balance , NetworkInfo , Payment , GraphNode , Transaction , SwitchReq , ListInvoices } from '../../shared/models/lndModels' ;
import * as RTLActions from '../../store/rtl.actions' ; import * as RTLActions from '../../store/rtl.actions' ;
@ -26,22 +28,23 @@ export class LNDEffects implements OnDestroy {
private httpClient : HttpClient ,
private httpClient : HttpClient ,
private store : Store < fromRTLReducer.RTLState > ,
private store : Store < fromRTLReducer.RTLState > ,
private logger : LoggerService ,
private logger : LoggerService ,
private sessionService : SessionService ,
public dialog : MatDialog ,
public dialog : MatDialog ,
private router : Router ) { }
private router : Router ,
private location : Location ) { }
@Effect ( )
@Effect ( )
infoFetch = this . actions $ . pipe (
infoFetch = this . actions $ . pipe (
ofType ( RTLActions . FETCH_INFO ) ,
ofType ( RTLActions . FETCH_INFO ) ,
withLatestFrom ( this . store . select ( 'root' ) ) ,
withLatestFrom ( this . store . select ( 'root' ) ) ,
mergeMap ( ( [ action , store ] ) = > {
mergeMap ( ( [ action , store ] : [ RTLActions . FetchInfo , fromRTLReducer . RootState ] ) = > {
this . store . dispatch ( new RTLActions . ClearEffectErrorLnd ( 'FetchInfo' ) ) ;
this . store . dispatch ( new RTLActions . ClearEffectErrorLnd ( 'FetchInfo' ) ) ;
return this . httpClient . get < GetInfo > ( this . CHILD_API_URL + environment . GETINFO_API )
return this . httpClient . get < GetInfo > ( this . CHILD_API_URL + environment . GETINFO_API )
. pipe (
. pipe (
map ( ( info ) = > {
map ( ( info ) = > {
this . logger . info ( info ) ;
this . logger . info ( info ) ;
if ( undefined === info . identity_pubkey ) {
if ( undefined === info . identity_pubkey ) {
sessionStorag . removeItem ( 'lndUnlocked' ) ;
this . sessionServic . removeItem ( 'lndUnlocked' ) ;
this . logger . info ( 'Redirecting to Unlock' ) ;
this . logger . info ( 'Redirecting to Unlock' ) ;
this . router . navigate ( [ '/lnd/unlocklnd' ] ) ;
this . router . navigate ( [ '/lnd/unlocklnd' ] ) ;
return {
return {
@ -49,33 +52,7 @@ export class LNDEffects implements OnDestroy {
payload : { }
payload : { }
} ;
} ;
} else {
} else {
sessionStorage . setItem ( 'lndUnlocked' , 'true' ) ;
this . initializeRemainingData ( info , action . payload . loadPage ) ;
if ( undefined !== info . chains ) {
if ( typeof info . chains [ 0 ] === 'string' ) {
info . smaller_currency_unit = ( info . chains [ 0 ] . toString ( ) . toLowerCase ( ) . indexOf ( 'bitcoin' ) < 0 ) ? 'Litoshis' : 'Sats' ;
info . currency_unit = ( info . chains [ 0 ] . toString ( ) . toLowerCase ( ) . indexOf ( 'bitcoin' ) < 0 ) ? 'LTC' : 'BTC' ;
} else if ( typeof info . chains [ 0 ] === 'object' && info . chains [ 0 ] . hasOwnProperty ( 'chain' ) ) {
const getInfoChain = < GetInfoChain > info . chains [ 0 ] ;
info . smaller_currency_unit = ( getInfoChain . chain . toLowerCase ( ) . indexOf ( 'bitcoin' ) < 0 ) ? 'Litoshis' : 'Sats' ;
info . currency_unit = ( getInfoChain . chain . toLowerCase ( ) . indexOf ( 'bitcoin' ) < 0 ) ? 'LTC' : 'BTC' ;
}
info . version = ( undefined === info . version ) ? '' : info . version . split ( ' ' ) [ 0 ] ;
} else {
info . smaller_currency_unit = 'Sats' ;
info . currency_unit = 'BTC' ;
info . version = ( undefined === info . version ) ? '' : info . version . split ( ' ' ) [ 0 ] ;
}
const node_data = {
identity_pubkey : info.identity_pubkey ,
alias : info.alias ,
testnet : info.testnet ,
chains : info.chains ,
version : info.version ,
currency_unit : info.currency_unit ,
smaller_currency_unit : info.smaller_currency_unit ,
numberOfPendingChannels : info.num_pending_channels
} ;
this . store . dispatch ( new RTLActions . SetNodeData ( node_data ) ) ;
return {
return {
type : RTLActions . SET_INFO ,
type : RTLActions . SET_INFO ,
payload : ( undefined !== info ) ? info : { }
payload : ( undefined !== info ) ? info : { }
@ -83,14 +60,31 @@ export class LNDEffects implements OnDestroy {
}
}
} ) ,
} ) ,
catchError ( ( err ) = > {
catchError ( ( err ) = > {
this . logger . error ( err ) ;
if ( ( typeof err . error . error === 'string' && err . error . error . includes ( 'Not Found' ) ) || err . status === 502 ) {
if ( err . status === 401 ) {
this . sessionService . removeItem ( 'lndUnlocked' ) ;
this . logger . info ( 'Redirecting to Signin' ) ;
return of ( { type : RTLActions . SIGNOUT } ) ;
} else {
this . logger . info ( 'Redirecting to Unlock' ) ;
this . logger . info ( 'Redirecting to Unlock' ) ;
this . router . navigate ( [ '/lnd/unlocklnd' ] ) ;
this . router . navigate ( [ '/lnd/unlocklnd' ] ) ;
return of ( ) ;
this . handleErrorWithoutAlert ( 'FetchInfo' , err ) ;
} else {
let code = err . status ? err . status : '' ;
let message = err . error . message ? err . error . message + ' ' : '' ;
if ( err . error && err . error . error ) {
if ( err . error . error . code ) {
code = err . error . error . code ;
} else if ( err . error . error . message && err . error . error . message . code ) {
code = err . error . error . message . code ;
}
if ( typeof err . error . error === 'string' ) {
message = message + err . error . error ;
} else if ( err . error . error . error ) {
message = message + err . error . error . error ;
} else if ( err . error . error . errno ) {
message = message + err . error . error . errno ;
}
}
this . router . navigate ( [ '/error' ] , { state : { errorCode : code , errorMessage : message } } ) ;
this . handleErrorWithoutAlert ( 'FetchInfo' , err ) ;
return of ( { type : RTLActions . VOID } ) ;
}
}
} )
} )
) ;
) ;
@ -112,12 +106,11 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'FetchPeers' , code : err.status , message : err.error.error } ) ) ;
this . handleErrorWithoutAlert ( 'FetchPeers' , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of ( ) ;
} )
} )
) ;
) ;
}
}
) ) ;
) ) ;
@Effect ( )
@Effect ( )
@ -136,22 +129,11 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Add Peer Failed' , this . CHILD_API_URL + environment . PEERS_API , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of (
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Add Peer Failed' ,
message : JSON.stringify ( { code : err.status , Message : err.error.error } )
}
}
}
) ;
} )
} )
) ;
) ;
}
}
) ) ;
) ) ;
@Effect ( )
@Effect ( )
@ -170,22 +152,11 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Unable to Detach Peer. Try again later.' , this . CHILD_API_URL + environment . PEERS_API + '/' + action . payload . pubkey , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of (
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Unable to Detach Peer. Try again later.' ,
message : JSON.stringify ( { code : err.status , Message : err.error.error } )
}
}
}
) ;
} )
} )
) ;
) ;
}
}
) ) ;
) ) ;
@Effect ( )
@Effect ( )
@ -216,19 +187,8 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Add Invoice Failed' , this . CHILD_API_URL + environment . INVOICES_API , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of (
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Add Invoice Failed' ,
message : JSON.stringify ( { code : err.status , Message : err.error.error } )
}
}
}
) ;
} )
} )
) ;
) ;
}
}
@ -255,23 +215,12 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Open Channel Failed' , this . CHILD_API_URL + environment . CHANNELS_API , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of (
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Open Channel Failed' ,
message : JSON.stringify ( { code : err.status , Message : err.error.error } )
}
}
}
) ;
} )
} )
) ;
) ;
}
}
) ) ; ) ) ;
@Effect ( )
@Effect ( )
updateChannel = this . actions $ . pipe (
updateChannel = this . actions $ . pipe (
@ -290,23 +239,12 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Update Channel Failed' , this . CHILD_API_URL + environment . CHANNELS_API + '/chanPolicy' , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of (
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Update Channel Failed' ,
message : JSON.stringify ( { code : err.status , Message : err.error.error } )
}
}
}
) ;
} )
} )
) ;
) ;
}
}
) ) ; ) ) ;
@Effect ( )
@Effect ( )
closeChannel = this . actions $ . pipe (
closeChannel = this . actions $ . pipe (
@ -332,23 +270,12 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Unable to Close Channel. Try again later.' , this . CHILD_API_URL + environment . CHANNELS_API + '/' + action . payload . channelPoint + '?force=' + action . payload . forcibly , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of (
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Unable to Close Channel. Try again later.' ,
message : JSON.stringify ( { code : err.status , Message : err.error.error.message } )
}
}
}
) ;
} )
} )
) ;
) ;
}
}
) ) ; ) ) ;
@Effect ( )
@Effect ( )
backupChannels = this . actions $ . pipe (
backupChannels = this . actions $ . pipe (
@ -367,24 +294,13 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . logger . error ( err ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'BackupChannels' , code : err.status , message : err.error.error } ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'BackupChannels' , code : err.status , message : err.error.error } ) ) ;
return of (
this . handleErrorWithAlert ( 'ERROR' , action . payload . showMessage + ' ' + 'Unable to Backup Channel. Try again later.' , this . CHILD_API_URL + environment . CHANNELS_BACKUP_API + '/' + action . payload . channelPoint , err ) ;
{
return of ( { type : RTLActions . VOID } ) ;
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : action.payload.showMessage + ' ' + 'Unable to Backup Channel. Try again later.' ,
message : JSON.stringify ( { code : err.status , Message : err.error.message } )
}
}
}
) ;
} )
} )
) ;
) ;
}
}
) ) ; ) ) ;
@Effect ( )
@Effect ( )
verifyChannels = this . actions $ . pipe (
verifyChannels = this . actions $ . pipe (
@ -403,23 +319,12 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . logger . error ( err ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'VerifyChannels' , code : err.status , message : err.error.error } ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'VerifyChannels' , code : err.status , message : err.error.error } ) ) ;
return of (
this . handleErrorWithAlert ( 'ERROR' , 'Unable to Verify Channel. Try again later.' , this . CHILD_API_URL + environment . CHANNELS_BACKUP_API + '/verify/' + action . payload . channelPoint , err ) ;
{
return of ( { type : RTLActions . VOID } ) ;
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Unable to Verify Channel. Try again later.' ,
message : JSON.stringify ( { code : err.status , Message : err.error.message } )
}
}
}
) ;
} )
} )
) ;
) ;
}
}
) ) ;
) ) ;
@Effect ( )
@Effect ( )
@ -440,20 +345,9 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . logger . error ( err ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'RestoreChannels' , code : err.status , message : err.error.error } ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'RestoreChannels' , code : err.status , message : err.error.error } ) ) ;
return of (
this . handleErrorWithAlert ( 'ERROR' , 'Unable to Restore Channel. Try again later.' , this . CHILD_API_URL + environment . CHANNELS_BACKUP_API + '/restore/' + action . payload . channelPoint , err ) ;
{
return of ( { type : RTLActions . VOID } ) ;
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Unable to Restore Channel. Try again later.' ,
message : JSON.stringify ( { code : err.status , Message : err.error.error } )
}
}
}
) ;
} )
} )
) ;
) ;
}
}
@ -474,11 +368,10 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . logger . error ( err ) ;
this . handleErrorWithoutAlert ( 'FetchFees' , err ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'FetchFees' , code : err.status , message : err.error.error } ) ) ;
return of ( { type : RTLActions . VOID } ) ;
return of ( ) ;
} )
}
) ;
) ) ;
@Effect ( )
@Effect ( )
balanceFetch = this . actions $ . pipe (
balanceFetch = this . actions $ . pipe (
@ -499,13 +392,12 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . logger . error ( err ) ;
this . handleErrorWithoutAlert ( 'FetchBalance/' + action . payload , err ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'FetchBalance/' + action . payload , code : err.status , message : err.error.error } ) ) ;
return of ( { type : RTLActions . VOID } ) ;
return of ( ) ;
}
}
) ) ;
) ) ;
}
}
) ) ; ) ) ;
@Effect ( )
@Effect ( )
networkInfoFetch = this . actions $ . pipe (
networkInfoFetch = this . actions $ . pipe (
@ -522,11 +414,10 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . logger . error ( err ) ;
this . handleErrorWithoutAlert ( 'FetchNetwork' , err ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'FetchNetwork' , code : err.status , message : err.error.error } ) ) ;
return of ( { type : RTLActions . VOID } ) ;
return of ( ) ;
}
}
) ) ; ) ) ;
@Effect ( )
@Effect ( )
channelsFetch = this . actions $ . pipe (
channelsFetch = this . actions $ . pipe (
@ -571,14 +462,13 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
}
}
} ,
} ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . logger . error ( err ) ;
this . handleErrorWithoutAlert ( 'FetchChannels/' + action . payload . routeParam , err ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'FetchChannels/' + action . payload . routeParam , code : err.status , message : err.error.error } ) ) ;
return of ( { type : RTLActions . VOID } ) ;
return of ( ) ;
} )
} )
) ) ;
) ) ;
}
}
) ) ; ) ) ;
@Effect ( )
@Effect ( )
invoicesFetch = this . actions $ . pipe (
invoicesFetch = this . actions $ . pipe (
@ -599,13 +489,12 @@ export class LNDEffects implements OnDestroy {
payload : res
payload : res
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . logger . error ( err ) ;
this . handleErrorWithoutAlert ( 'FetchInvoices' , err ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'FetchInvoices' , code : err.status , message : err.error.error } ) ) ;
return of ( { type : RTLActions . VOID } ) ;
return of ( ) ;
}
}
) ) ;
) ) ;
} ) ) ;
} ) ) ;
@Effect ( )
@Effect ( )
transactionsFetch = this . actions $ . pipe (
transactionsFetch = this . actions $ . pipe (
@ -622,11 +511,10 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . logger . error ( err ) ;
this . handleErrorWithoutAlert ( 'FetchTransactions' , err ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'FetchTransactions' , code : err.status , message : err.error.error } ) ) ;
return of ( { type : RTLActions . VOID } ) ;
return of ( ) ;
}
}
) ) ; ) ) ;
@Effect ( )
@Effect ( )
paymentsFetch = this . actions $ . pipe (
paymentsFetch = this . actions $ . pipe (
@ -643,11 +531,10 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . logger . error ( err ) ;
this . handleErrorWithoutAlert ( 'FetchPayments' , err ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'FetchPayments' , code : err.status , message : err.error.error } ) ) ;
return of ( { type : RTLActions . VOID } ) ;
return of ( ) ;
}
}
) ) ; ) ) ;
@Effect ( )
@Effect ( )
decodePayment = this . actions $ . pipe (
decodePayment = this . actions $ . pipe (
@ -664,19 +551,8 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Decode Payment Failed' , this . CHILD_API_URL + environment . PAYREQUEST_API + '/' + action . payload , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of (
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Decode Payment Failed' ,
message : JSON.stringify ( { Code : err.status , Message : err.error.error , URL : this.CHILD_API_URL + environment . PAYREQUEST_API + '/' + action . payload } )
}
}
}
) ;
} )
} )
) ;
) ;
} )
} )
@ -709,7 +585,7 @@ export class LNDEffects implements OnDestroy {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
if ( sendRes . payment_error ) {
if ( sendRes . payment_error ) {
this . logger . error ( 'Error: ' + sendRes . payment_error ) ;
this . logger . error ( 'Error: ' + sendRes . payment_error ) ;
return of ( {
return {
type : RTLActions . OPEN_ALERT ,
type : RTLActions . OPEN_ALERT ,
payload : {
payload : {
width : '70%' , data : {
width : '70%' , data : {
@ -719,7 +595,7 @@ export class LNDEffects implements OnDestroy {
)
)
}
}
}
}
} ) ;
}
} else {
} else {
const confirmationMsg = { 'Destination' : action . payload [ 1 ] . destination , 'Timestamp' : action . payload [ 1 ] . timestamp_str , 'Expiry' : action . payload [ 1 ] . expiry } ;
const confirmationMsg = { 'Destination' : action . payload [ 1 ] . destination , 'Timestamp' : action . payload [ 1 ] . timestamp_str , 'Expiry' : action . payload [ 1 ] . expiry } ;
confirmationMsg [ 'Amount (' + ( ( undefined === store . nodeData . smaller_currency_unit ) ?
confirmationMsg [ 'Amount (' + ( ( undefined === store . nodeData . smaller_currency_unit ) ?
@ -742,19 +618,8 @@ export class LNDEffects implements OnDestroy {
}
}
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Send Payment Failed' , this . CHILD_API_URL + environment . CHANNELS_API + '/transactions' , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of (
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Send Payment Failed' ,
message : JSON.stringify ( { code : err.status , Message : err.error.error , URL : this.CHILD_API_URL + environment . CHANNELS_API + '/transactions/' + action . payload [ 0 ] } )
}
}
}
) ;
} )
} )
) ;
) ;
} )
} )
@ -773,23 +638,12 @@ export class LNDEffects implements OnDestroy {
payload : ( undefined !== graphNode ) ? graphNode : { }
payload : ( undefined !== graphNode ) ? graphNode : { }
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Get Node Address Failed' , this . CHILD_API_URL + environment . NETWORK_API + '/node/' + action . payload , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of (
} ) ) ;
{
}
type : RTLActions . OPEN_ALERT ,
) ) ;
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Get Node Address Failed' ,
message : JSON.stringify ( { Code : err.status , Message : err.error.error } )
}
}
}
) ;
} ) ) ;
}
) ) ;
@Effect ( { dispatch : false } )
@Effect ( { dispatch : false } )
setGraphNode = this . actions $ . pipe (
setGraphNode = this . actions $ . pipe (
@ -813,21 +667,10 @@ export class LNDEffects implements OnDestroy {
payload : ( undefined !== newAddress && undefined !== newAddress . address ) ? newAddress . address : { }
payload : ( undefined !== newAddress && undefined !== newAddress . address ) ? newAddress . address : { }
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Generate New Address Failed' , this . CHILD_API_URL + environment . NEW_ADDRESS_API + '?type=' + action . payload . addressId , err ) ;
this . logger . error ( err ) ;
return of ( { type : RTLActions . VOID } ) ;
return of (
} ) ) ;
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Generate New Address Failed' ,
message : JSON.stringify ( { Code : err.status , Message : err.error.error , URL : this.CHILD_API_URL + environment . NEW_ADDRESS_API + '?type=' + action . payload . addressId } )
}
}
}
) ;
} ) ) ;
} )
} )
) ;
) ;
@ -859,22 +702,11 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'SetChannelTransaction' , code : err.status , message : err.error.error } ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'SetChannelTransaction' , code : err.status , message : err.error.error } ) ) ;
this . logger . error ( err ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Sending Fund Failed' , this . CHILD_API_URL + environment . TRANSACTIONS_API , err ) ;
return of (
return of ( { type : RTLActions . VOID } ) ;
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Sending Fund Failed' ,
message : JSON.stringify ( { Code : err.status , Message : err.error.error } )
}
}
}
) ;
} ) ) ;
} ) ) ;
} )
} )
) ;
) ;
@Effect ( )
@Effect ( )
@ -896,18 +728,8 @@ export class LNDEffects implements OnDestroy {
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'GetForwardingHistory' , code : err.status , message : err.error.error } ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'GetForwardingHistory' , code : err.status , message : err.error.error } ) ) ;
this . logger . error ( err ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Get Forwarding History Failed' , this . CHILD_API_URL + environment . SWITCH_API , err ) ;
return of (
return of ( { type : RTLActions . VOID } ) ;
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Get Forwarding History Failed' ,
message : JSON.stringify ( { code : err.status , Message : err.error.error , URL : this.CHILD_API_URL + environment . SWITCH_API } )
}
}
}
) ;
} )
} )
) ;
) ;
} )
} )
@ -928,18 +750,8 @@ export class LNDEffects implements OnDestroy {
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . SetQueryRoutes ( { } ) ) ;
this . store . dispatch ( new RTLActions . SetQueryRoutes ( { } ) ) ;
this . logger . error ( err ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Get Query Routes Failed' , this . CHILD_API_URL + environment . NETWORK_API , err ) ;
return of (
return of ( { type : RTLActions . VOID } ) ;
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Get Query Routes Failed' ,
message : JSON.stringify ( { code : err.status , Message : err.error.error.error , URL : this.CHILD_API_URL + environment . NETWORK_API } )
}
}
}
) ;
} )
} )
) ;
) ;
}
}
@ -969,14 +781,34 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err ) = > {
catchError ( ( err ) = > {
this . handleErrorWithAlert ( 'ERROR' , err . error . message + ' ' + err . error . error . code , this . CHILD_API_URL + environment . WALLET_API + '/genseed/' + action . payload , err ) ;
return of ( { type : RTLActions . VOID } ) ;
} )
) ;
}
) ) ;
@Effect ( )
updateSelNodeOptions = this . actions $ . pipe (
ofType ( RTLActions . UPDATE_SELECTED_NODE_OPTIONS ) ,
mergeMap ( ( action : RTLActions.UpdateSelectedNodeOptions ) = > {
return this . httpClient . get ( this . CHILD_API_URL + environment . WALLET_API + '/updateSelNodeOptions' )
. pipe (
map ( ( postRes : any ) = > {
this . logger . info ( 'Update Sel Node Successfull' ) ;
this . logger . info ( postRes ) ;
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . OpenAlert ( { width : '70%' , data : { type : 'ERROR' , titleMessage : err.error.message + ' ' + err . error . error . code } } ) ) ;
return {
this . logger . error ( err . error . error ) ;
type : RTLActions . VOID
return of ( ) ;
} ;
} ) ,
catchError ( ( err ) = > {
this . handleErrorWithAlert ( 'ERROR' , 'Update macaroon for newly initialized node failed! Please check the macaroon path and restart the server!' , 'Update Macaroon' , err ) ;
return of ( { type : RTLActions . VOID } ) ;
} )
} )
) ;
) ;
}
}
) ) ;
) ) ;
@Effect ( { dispatch : false } )
@Effect ( { dispatch : false } )
genSeedResponse = this . actions $ . pipe (
genSeedResponse = this . actions $ . pipe (
@ -1014,14 +846,12 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err ) = > {
catchError ( ( err ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , err . error . error , this . CHILD_API_URL + environment . WALLET_API + '/initwallet' , err ) ;
this . store . dispatch ( new RTLActions . OpenAlert ( { width : '70%' , data : { type : 'ERROR' , titleMessage : err.error.error } } ) ) ;
return of ( { type : RTLActions . VOID } ) ;
this . logger . error ( err . error . error ) ;
return of ( ) ;
} )
} )
) ;
) ;
}
}
) ) ; ) ) ;
@Effect ( { dispatch : false } )
@Effect ( { dispatch : false } )
unlockWallet = this . actions $ . pipe (
unlockWallet = this . actions $ . pipe (
@ -1034,20 +864,17 @@ export class LNDEffects implements OnDestroy {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . OpenSpinner ( 'Initializing Node...' ) ) ;
this . store . dispatch ( new RTLActions . OpenSpinner ( 'Initializing Node...' ) ) ;
this . logger . info ( 'Successfully Unlocked!' ) ;
this . logger . info ( 'Successfully Unlocked!' ) ;
sessionStorag . setItem ( 'lndUnlocked' , 'true' ) ;
this . sessionServic . setItem ( 'lndUnlocked' , 'true' ) ;
setTimeout ( ( ) = > {
setTimeout ( ( ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . logger . info ( 'Successfully Initialized!' ) ;
this . logger . info ( 'Successfully Initialized!' ) ;
this . store . dispatch ( new RTLActions . InitAppData ( ) ) ;
this . store . dispatch ( new RTLActions . FetchInfo ( { loadPage : 'HOME' } ) ) ;
this . router . navigate ( [ '/lnd/' ] ) ;
} , 1000 * 90 ) ;
} , 1000 * 90 ) ;
return of ( { } ) ;
return { type : RTLActions . VOID } ;
} ) ,
} ) ,
catchError ( ( err ) = > {
catchError ( ( err ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . handleErrorWithAlert ( 'ERROR' , err . error . error , this . CHILD_API_URL + environment . WALLET_API + '/unlockwallet' , err ) ;
this . store . dispatch ( new RTLActions . OpenAlert ( { width : '70%' , data : { type : 'ERROR' , titleMessage : err.error.error } } ) ) ;
return of ( { type : RTLActions . VOID } ) ;
this . logger . error ( err . error . error ) ;
return of ( ) ;
} )
} )
) ;
) ;
}
}
@ -1069,20 +896,9 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'Lookup' , code : err.status , message : err.error.message } ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'Lookup' , code : err.status , message : err.error.message } ) ) ;
this . logger . error ( err ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Peer Lookup Failed' , this . CHILD_API_URL + environment . NETWORK_API + '/node/' + action . payload , err ) ;
return of (
return of ( { type : RTLActions . VOID } ) ;
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Peer Lookup Failed' ,
message : JSON.stringify ( { Code : err.status , Message : err.error.error , URL : this.CHILD_API_URL + environment . NETWORK_API + '/node/' + action . payload } )
}
}
}
) ;
} )
} )
) ;
) ;
} )
} )
@ -1104,20 +920,9 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'Lookup' , code : err.status , message : err.error.message } ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'Lookup' , code : err.status , message : err.error.message } ) ) ;
this . logger . error ( err ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Channel Lookup Failed' , this . CHILD_API_URL + environment . NETWORK_API + '/edge/' + action . payload , err ) ;
return of (
return of ( { type : RTLActions . VOID } ) ;
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Channel Lookup Failed' ,
message : JSON.stringify ( { Code : err.status , Message : err.error.error , URL : this.CHILD_API_URL + environment . NETWORK_API + '/edge/' + action . payload } )
}
}
}
) ;
} )
} )
) ;
) ;
} )
} )
@ -1139,20 +944,9 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'Lookup' , code : err.status , message : err.error.message } ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'Lookup' , code : err.status , message : err.error.message } ) ) ;
this . logger . error ( err ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Invoice Lookup Failed' , this . CHILD_API_URL + environment . INVOICES_API + '/' + action . payload , err ) ;
return of (
return of ( { type : RTLActions . VOID } ) ;
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Invoice Lookup Failed' ,
message : JSON.stringify ( { Code : err.status , Message : err.error.error , URL : this.CHILD_API_URL + environment . INVOICES_API + '/' + action . payload } )
}
}
}
) ;
} )
} )
) ;
) ;
} )
} )
@ -1184,20 +978,9 @@ export class LNDEffects implements OnDestroy {
} ;
} ;
} ) ,
} ) ,
catchError ( ( err : any ) = > {
catchError ( ( err : any ) = > {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'RestoreChannelsList' , code : err.status , message : err.error.message } ) ) ;
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : 'RestoreChannelsList' , code : err.status , message : err.error.message } ) ) ;
this . logger . error ( err ) ;
this . handleErrorWithAlert ( 'ERROR' , 'Restore Channels List Failed' , this . CHILD_API_URL + environment . CHANNELS_BACKUP_API , err ) ;
return of (
return of ( { type : RTLActions . VOID } ) ;
{
type : RTLActions . OPEN_ALERT ,
payload : {
width : '70%' , data : {
type : 'ERROR' , titleMessage : 'Restore Channels List Failed' ,
message : JSON.stringify ( { Code : err.status , Message : err.error , URL : this.CHILD_API_URL + environment . CHANNELS_BACKUP_API } )
}
}
}
) ;
} )
} )
) ;
) ;
} )
} )
@ -1212,6 +995,79 @@ export class LNDEffects implements OnDestroy {
} )
} )
) ;
) ;
initializeRemainingData ( info : any , landingPage : string ) {
this . sessionService . setItem ( 'lndUnlocked' , 'true' ) ;
if ( undefined !== info . chains ) {
if ( typeof info . chains [ 0 ] === 'string' ) {
info . smaller_currency_unit = ( info . chains [ 0 ] . toString ( ) . toLowerCase ( ) . indexOf ( 'bitcoin' ) < 0 ) ? 'Litoshis' : 'Sats' ;
info . currency_unit = ( info . chains [ 0 ] . toString ( ) . toLowerCase ( ) . indexOf ( 'bitcoin' ) < 0 ) ? 'LTC' : 'BTC' ;
} else if ( typeof info . chains [ 0 ] === 'object' && info . chains [ 0 ] . hasOwnProperty ( 'chain' ) ) {
const getInfoChain = < GetInfoChain > info . chains [ 0 ] ;
info . smaller_currency_unit = ( getInfoChain . chain . toLowerCase ( ) . indexOf ( 'bitcoin' ) < 0 ) ? 'Litoshis' : 'Sats' ;
info . currency_unit = ( getInfoChain . chain . toLowerCase ( ) . indexOf ( 'bitcoin' ) < 0 ) ? 'LTC' : 'BTC' ;
}
info . version = ( undefined === info . version ) ? '' : info . version . split ( ' ' ) [ 0 ] ;
} else {
info . smaller_currency_unit = 'Sats' ;
info . currency_unit = 'BTC' ;
info . version = ( undefined === info . version ) ? '' : info . version . split ( ' ' ) [ 0 ] ;
}
const node_data = {
identity_pubkey : info.identity_pubkey ,
alias : info.alias ,
testnet : info.testnet ,
chains : info.chains ,
version : info.version ,
currency_unit : info.currency_unit ,
smaller_currency_unit : info.smaller_currency_unit ,
numberOfPendingChannels : info.num_pending_channels
} ;
this . store . dispatch ( new RTLActions . SetNodeData ( node_data ) ) ;
this . store . dispatch ( new RTLActions . FetchFees ( ) ) ;
this . store . dispatch ( new RTLActions . FetchPeers ( ) ) ;
this . store . dispatch ( new RTLActions . FetchBalance ( 'channels' ) ) ;
this . store . dispatch ( new RTLActions . FetchNetwork ( ) ) ;
this . store . dispatch ( new RTLActions . FetchChannels ( { routeParam : 'all' } ) ) ;
this . store . dispatch ( new RTLActions . FetchChannels ( { routeParam : 'pending' } ) ) ;
this . store . dispatch ( new RTLActions . FetchInvoices ( { num_max_invoices : 25 , reversed : true } ) ) ;
this . store . dispatch ( new RTLActions . FetchPayments ( ) ) ;
let newRoute = this . location . path ( ) ;
if ( newRoute . includes ( '/unlock' ) || newRoute . includes ( '/login' ) || newRoute . includes ( '/error' ) || newRoute === '' || landingPage === 'HOME' || newRoute . includes ( '?access-key=' ) ) {
newRoute = '/lnd/home' ;
} else {
if ( newRoute . includes ( '/cl/' ) ) {
newRoute = newRoute . replace ( '/cl/' , '/lnd/' ) ;
}
}
this . router . navigate ( [ newRoute ] ) ;
}
handleErrorWithoutAlert ( actionName : string , err : { status : number , error : any } ) {
this . logger . error ( 'ERROR IN: ' + actionName + '\n' + JSON . stringify ( err ) ) ;
if ( err . status === 401 ) {
this . logger . info ( 'Redirecting to Signin' ) ;
this . store . dispatch ( new RTLActions . Signout ( ) ) ;
} else {
this . store . dispatch ( new RTLActions . EffectErrorLnd ( { action : actionName , code : err.status.toString ( ) , message : err.error.error } ) ) ;
}
}
handleErrorWithAlert ( alertType : string , alertTitle : string , errURL : string , err : { status : number , error : any } ) {
this . logger . error ( err ) ;
if ( err . status === 401 ) {
this . logger . info ( 'Redirecting to Signin' ) ;
this . store . dispatch ( new RTLActions . Signout ( ) ) ;
} else {
this . store . dispatch ( new RTLActions . CloseSpinner ( ) ) ;
this . store . dispatch ( new RTLActions . OpenAlert ( {
width : '70%' , data : {
type : alertType , titleMessage : alertTitle ,
message : JSON.stringify ( { code : err.status , Message : err.error.error , URL : errURL } )
}
} ) ) ;
}
}
ngOnDestroy() {
ngOnDestroy() {
this . unSubs . forEach ( completeSub = > {
this . unSubs . forEach ( completeSub = > {
completeSub . next ( ) ;
completeSub . next ( ) ;
Shahana Farooqui
5 years ago