aiolabs/lightning-pub
2
0
Fork 0
Code Issues 9 Pull requests 4 Projects Releases Packages Wiki Activity Actions

LND Sockets added

Browse source
This commit is contained in:
emad-salah 2020-04-05 18:09:42 +01:00
parent 3ec4b6bd69
commit e456496010
2 changed files with 55 additions and 44 deletions
Download patch file Download diff file Expand all files Collapse all files

23
src/server.js
View file

@ -207,17 +207,17 @@ const server = program => {
const CA = LightningServices.servicesConfig.lndCertPath const CA = LightningServices.servicesConfig.lndCertPath
const CA_KEY = CA.replace('cert', 'key') const CA_KEY = CA.replace('cert', 'key')
const createServer = async () => { const createServer = () => {
try { try {
if (LightningServices.servicesConfig.lndCertPath && program.usetls) { // if (LightningServices.servicesConfig.lndCertPath && program.usetls) {
const [key, cert] = await Promise.all([ // const [key, cert] = await Promise.all([
FS.readFile(CA_KEY), // FS.readFile(CA_KEY),
FS.readFile(CA) // FS.readFile(CA)
]) // ])
const httpsServer = Https.createServer({ key, cert }, app) // const httpsServer = Https.createServer({ key, cert }, app)
return httpsServer // return httpsServer
} // }
const httpServer = Http.Server(app) const httpServer = Http.Server(app)
return httpServer return httpServer
@ -236,7 +236,10 @@ const server = program => {
const io = require('socket.io')(serverInstance) const io = require('socket.io')(serverInstance)
const Sockets = require('./sockets')(io, lnd) const Sockets = require('./sockets')(
io,
LightningServices.services.lightning
)
require('./routes')(app, defaults, Sockets, { require('./routes')(app, defaults, Sockets, {
serverHost: module.serverHost, serverHost: module.serverHost,

74
src/sockets.js
View file

@ -5,41 +5,49 @@ const logger = require("winston");
module.exports = ( module.exports = (
/** @type {import('socket.io').Server} */ /** @type {import('socket.io').Server} */
io, io,
lnd, lightning,
) => { ) => {
const Mediator = require("../services/gunDB/Mediator/index.js"); const Mediator = require("../services/gunDB/Mediator/index.js");
const EventEmitter = require("events");
class MySocketsEvents extends EventEmitter {} const onNewInvoice = socket => {
const stream = lightning.subscribeInvoice({});
const mySocketsEvents = new MySocketsEvents(); stream.on("data", data => {
socket.emit("invoice:new", data)
// register the lnd invoices listener })
const registerLndInvoiceListener = socket => { stream.on("end", () => {
socket._invoiceListener = { logger.info("New invoice stream ended, starting a new one...")
dataReceived(data) { onNewInvoice(socket);
socket.emit("invoice", data); })
stream.on("error", err => {
logger.error("New invoice stream error:", err);
})
stream.on("status", status => {
logger.error("New invoice stream status:", status);
if (status.code === 14) {
onNewInvoice(socket);
}
})
} }
};
lnd.registerInvoiceListener(socket._invoiceListener);
};
// unregister the lnd invoices listener
const unregisterLndInvoiceListener = socket => {
lnd.unregisterInvoiceListener(socket._invoiceListener);
};
// register the socket listeners
const registerSocketListeners = socket => {
registerLndInvoiceListener(socket);
};
// unregister the socket listeners
const unregisterSocketListeners = socket => {
unregisterLndInvoiceListener(socket);
};
const onNewTransaction = socket => {
const stream = lightning.subscribeTransaction({});
stream.on("data", data => {
socket.emit("transaction:new", data)
})
stream.on("end", () => {
logger.info("New invoice stream ended, starting a new one...")
onNewTransaction(socket);
})
stream.on("error", err => {
logger.error("New invoice stream error:", err);
})
stream.on("status", status => {
logger.error("New invoice stream status:", status);
if (status.code === 14) {
onNewTransaction(socket);
}
})
}
io.on("connection", socket => { io.on("connection", socket => {
logger.info(`io.onconnection`) logger.info(`io.onconnection`)
@ -78,15 +86,15 @@ module.exports = (
// 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);
registerSocketListeners(socket); onNewInvoice(socket);
onNewTransaction(socket);
/** listening if client has disconnected */ /** listening if client has disconnected */
socket.on("disconnect", () => { socket.on("disconnect", () => {
unregisterSocketListeners(socket);
logger.info("client disconnected (id=" + socket.id + ")."); logger.info("client disconnected (id=" + socket.id + ").");
}); });
} }
}) })
return mySocketsEvents; return io;
}; };