diff --git a/backend/src/tasks/lightning/network-sync.service.ts b/backend/src/tasks/lightning/network-sync.service.ts index ad468939d..d704012f7 100644 --- a/backend/src/tasks/lightning/network-sync.service.ts +++ b/backend/src/tasks/lightning/network-sync.service.ts @@ -95,11 +95,19 @@ class NetworkSyncService { */ private async $updateChannelsList(channels: ILightningApi.Channel[]): Promise { try { + const [closedChannelsRaw]: any[] = await DB.query(`SELECT id FROM channels WHERE status = 2`); + const closedChannels = {}; + for (const closedChannel of closedChannelsRaw) { + closedChannels[Common.channelShortIdToIntegerId(closedChannel.id)] = true; + } + let progress = 0; const graphChannelsIds: string[] = []; for (const channel of channels) { - await channelsApi.$saveChannel(channel); + if (!closedChannels[channel.channel_id]) { + await channelsApi.$saveChannel(channel); + } graphChannelsIds.push(channel.channel_id); ++progress;