add endpoints: get all / all open channels

This commit is contained in:
Carsten Otto
2021-11-27 17:26:30 +01:00
parent df2bd929ee
commit 280804587e
4 changed files with 74 additions and 0 deletions

View File

@@ -1,7 +1,9 @@
package de.cotto.lndmanagej.controller;
import de.cotto.lndmanagej.controller.dto.ChannelsDto;
import de.cotto.lndmanagej.controller.dto.PubkeysDto;
import de.cotto.lndmanagej.metrics.Metrics;
import de.cotto.lndmanagej.model.ChannelId;
import de.cotto.lndmanagej.model.Pubkey;
import de.cotto.lndmanagej.service.ChannelService;
import de.cotto.lndmanagej.service.OwnNodeService;
@@ -54,6 +56,15 @@ class StatusControllerTest {
assertThat(statusController.isSyncedToChain()).isFalse();
}
@Test
void getOpenChannels() {
when(channelService.getOpenChannels()).thenReturn(Set.of(LOCAL_OPEN_CHANNEL_TO_NODE_3, LOCAL_OPEN_CHANNEL));
List<ChannelId> expectedChannelIds =
List.of(LOCAL_OPEN_CHANNEL.getId(), LOCAL_OPEN_CHANNEL_TO_NODE_3.getId());
assertThat(statusController.getOpenChannels()).isEqualTo(new ChannelsDto(expectedChannelIds));
verify(metrics).mark(argThat(name -> name.endsWith(".getOpenChannels")));
}
@Test
void getPubkeysForOpenChannels() {
when(channelService.getOpenChannels()).thenReturn(Set.of(LOCAL_OPEN_CHANNEL_TO_NODE_3, LOCAL_OPEN_CHANNEL));
@@ -69,6 +80,15 @@ class StatusControllerTest {
assertThat(statusController.getPubkeysForOpenChannels().pubkeys()).containsExactly(PUBKEY_2.toString());
}
@Test
void getAllChannels() {
when(channelService.getAllLocalChannels()).thenReturn(Stream.of(LOCAL_OPEN_CHANNEL_TO_NODE_3, CLOSED_CHANNEL));
List<ChannelId> expectedChannelIds =
List.of(CLOSED_CHANNEL.getId(), LOCAL_OPEN_CHANNEL_TO_NODE_3.getId());
assertThat(statusController.getAllChannels()).isEqualTo(new ChannelsDto(expectedChannelIds));
verify(metrics).mark(argThat(name -> name.endsWith(".getAllChannels")));
}
@Test
void getPubkeysForAllChannels() {
when(channelService.getAllLocalChannels()).thenReturn(Stream.of(LOCAL_OPEN_CHANNEL_TO_NODE_3, CLOSED_CHANNEL));