Prevent mediator from being attached to LND socket
This commit is contained in:
parent
17da950df9
commit
b5a1db76ee
2 changed files with 10 additions and 9 deletions
|
|
@ -1,5 +1,3 @@
|
||||||
|
|
||||||
|
|
||||||
const grpc = require("grpc");
|
const grpc = require("grpc");
|
||||||
const protoLoader = require("@grpc/proto-loader");
|
const protoLoader = require("@grpc/proto-loader");
|
||||||
const fs = require("../../utils/fs");
|
const fs = require("../../utils/fs");
|
||||||
|
|
|
||||||
|
|
@ -162,11 +162,12 @@ module.exports = (
|
||||||
|
|
||||||
logger.info('socket.handshake', socket.handshake)
|
logger.info('socket.handshake', socket.handshake)
|
||||||
|
|
||||||
/** printing out the client who joined */
|
|
||||||
logger.info('New socket client connected (id=' + socket.id + ').')
|
|
||||||
|
|
||||||
const isOneTimeUseSocket = !!socket.handshake.query.IS_GUN_AUTH
|
const isOneTimeUseSocket = !!socket.handshake.query.IS_GUN_AUTH
|
||||||
const isLNDSocket = !!socket.handshake.query.IS_LND_SOCKET
|
const isLNDSocket = !!socket.handshake.query.IS_LND_SOCKET
|
||||||
|
if (!isLNDSocket) {
|
||||||
|
/** printing out the client who joined */
|
||||||
|
logger.info('New socket client connected (id=' + socket.id + ').')
|
||||||
|
}
|
||||||
|
|
||||||
if (isOneTimeUseSocket) {
|
if (isOneTimeUseSocket) {
|
||||||
logger.info('New socket is one time use')
|
logger.info('New socket is one time use')
|
||||||
|
|
@ -191,14 +192,16 @@ module.exports = (
|
||||||
}
|
}
|
||||||
})
|
})
|
||||||
} else {
|
} else {
|
||||||
|
if (isLNDSocket) {
|
||||||
|
logger.info('[LND] New LND Socket created')
|
||||||
|
onNewInvoice(socket)
|
||||||
|
onNewTransaction(socket)
|
||||||
|
return
|
||||||
|
}
|
||||||
logger.info('New socket is NOT one time use')
|
logger.info('New socket is NOT one time use')
|
||||||
// this is where we create the websocket connection
|
// this is where we create the websocket connection
|
||||||
// with the GunDB service.
|
// with the GunDB service.
|
||||||
Mediator.createMediator(socket)
|
Mediator.createMediator(socket)
|
||||||
if (isLNDSocket) {
|
|
||||||
onNewInvoice(socket)
|
|
||||||
onNewTransaction(socket)
|
|
||||||
}
|
|
||||||
|
|
||||||
/** listening if client has disconnected */
|
/** listening if client has disconnected */
|
||||||
socket.on('disconnect', () => {
|
socket.on('disconnect', () => {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue