fetch latest backups before subscribtion
This commit is contained in:
parent
6cdbd1e498
commit
857e61fc23
1 changed files with 11 additions and 2 deletions
|
|
@ -422,11 +422,20 @@ module.exports = async (
|
||||||
// Send an event to update lightning's status
|
// Send an event to update lightning's status
|
||||||
mySocketsEvents.emit("updateLightning");
|
mySocketsEvents.emit("updateLightning");
|
||||||
|
|
||||||
//register to listen for channel backups
|
//get the latest channel backups before subscribing
|
||||||
const user = require('../services/gunDB/Mediator').getUser()
|
const user = require('../services/gunDB/Mediator').getUser()
|
||||||
const SEA = require('../services/gunDB/Mediator').mySEA
|
const SEA = require('../services/gunDB/Mediator').mySEA
|
||||||
|
const { lightning } = LightningServices.services;
|
||||||
|
lightning.exportAllChannelBackups({}, (err, channelBackups) => {
|
||||||
|
if (err) {
|
||||||
|
return handleError(res, err);
|
||||||
|
}
|
||||||
|
GunActions.saveChannelsBackup(JSON.stringify(channelBackups),user,SEA)
|
||||||
|
|
||||||
|
});
|
||||||
|
|
||||||
|
//register to listen for channel backups
|
||||||
const onNewChannelBackup = () => {
|
const onNewChannelBackup = () => {
|
||||||
const { lightning } = LightningServices.services;
|
|
||||||
logger.warn("Subscribing to channel backup ...")
|
logger.warn("Subscribing to channel backup ...")
|
||||||
const stream = lightning.SubscribeChannelBackups({})
|
const stream = lightning.SubscribeChannelBackups({})
|
||||||
stream.on("data", data => {
|
stream.on("data", data => {
|
||||||
|
|
|
||||||
Loading…
Add table
Add a link
Reference in a new issue