wire get aval service

This commit is contained in:
hatim boufnichel 2020-09-05 20:15:55 +02:00
parent 90d67f0c72
commit 7db03de5f1
2 changed files with 28 additions and 5 deletions

View file

@ -21,6 +21,7 @@ const auth = require('../services/auth/auth')
const FS = require('../utils/fs')
const Encryption = require('../utils/encryptionStore')
const LightningServices = require('../utils/lightningServices')
const lndErrorManager = require('../utils/lightningServices/errors')
const GunDB = require('../services/gunDB/Mediator')
const {
unprotectedRoutes,
@ -63,7 +64,10 @@ module.exports = async (
return message
}
const getAvailableService = () =>
const getAvailableService = () => {
return lndErrorManager.getAvailableService()
}
/*
new Promise((resolve, reject) => {
const { lightning } = LightningServices.services
@ -105,13 +109,22 @@ module.exports = async (
success: true
})
})
})
})*/
const checkHealth = async () => {
logger.info('Getting service status...')
const serviceStatus = await getAvailableService()
logger.info('Received status:', serviceStatus)
const LNDStatus = serviceStatus
let LNDStatus = {}
try {
const serviceStatus = await getAvailableService()
logger.info('Received status:', serviceStatus)
LNDStatus = serviceStatus
} catch (e) {
LNDStatus = {
message: e.message,
success: false
}
}
try {
logger.info('Getting API status...')
const APIHealth = await Http.get(

View file

@ -25,6 +25,7 @@ class LNDErrorManager {
*/
_healthListeners = []
//rejects if(err && err.code !== 12)
getAvailableService(){
//require('shock-common').Utils.makePromise((res, rej) => ...)
@ -57,6 +58,15 @@ class LNDErrorManager {
walletStatus: 'unknown',
success: false
})
} else if(err.code === 4){
rej({
service: 'unknown',
message:
"LND Timeout",
code: 4,
walletStatus: 'unknown',
success: false
})
} else {
rej({
service: 'lightning',