aljaz/lnd-manageJ
1
0
Fork 0
mirror of https://github.com/aljazceru/lnd-manageJ.git synced 2026-01-23 07:54:24 +01:00
Code Issues Packages Projects Releases Wiki Activity

add self payments endpoints (aggregated per peer)

Browse Source
This commit is contained in:
Carsten Otto
2021-12-09 13:59:20 +01:00
parent fb8fd3134f
commit 9a8549b527
6 changed files with 180 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
web/src/integrationTest/java/de/cotto/lndmanagej/controller/SelfPaymentsControllerIT.java
View File

@@ -15,6 +15,7 @@ import static de.cotto.lndmanagej.SelfPaymentFixtures.SELF_PAYMENT_2;
import static de.cotto.lndmanagej.model.ChannelIdFixtures.CHANNEL_ID;
import static de.cotto.lndmanagej.model.ChannelIdFixtures.CHANNEL_ID_2;
import static de.cotto.lndmanagej.model.ChannelIdFixtures.CHANNEL_ID_4;
import static de.cotto.lndmanagej.model.PubkeyFixtures.PUBKEY;
import static org.hamcrest.Matchers.empty;
import static org.hamcrest.Matchers.not;
import static org.hamcrest.core.Is.is;
@@ -22,9 +23,11 @@ import static org.mockito.Mockito.when;
import static org.springframework.test.web.servlet.request.MockMvcRequestBuilders.get;
import static org.springframework.test.web.servlet.result.MockMvcResultMatchers.jsonPath;
@SuppressWarnings("PMD.AvoidDuplicateLiterals")
@WebMvcTest(controllers = SelfPaymentsController.class)
class SelfPaymentsControllerIT {
private static final String CHANNEL_PREFIX = "/api/channel/" + CHANNEL_ID.getShortChannelId() + "/";
private static final String NODE_PREFIX = "/api/node/" + PUBKEY + "/";
@Autowired
private MockMvc mockMvc;
@@ -45,6 +48,15 @@ class SelfPaymentsControllerIT {
.andExpect(jsonPath("$[1].memo", is(SELF_PAYMENT.memo())));
}
@Test
void getSelfPaymentsFromPeer() throws Exception {
when(selfPaymentsService.getSelfPaymentsFromPeer(PUBKEY))
.thenReturn(List.of(SELF_PAYMENT_2, SELF_PAYMENT));
mockMvc.perform(get(NODE_PREFIX + "/self-payments-from-peer/"))
.andExpect(jsonPath("$[0].memo", is(SELF_PAYMENT_2.memo())))
.andExpect(jsonPath("$[1].memo", is(SELF_PAYMENT.memo())));
}
@Test
void getSelfPaymentsToChannel() throws Exception {
when(selfPaymentsService.getSelfPaymentsToChannel(CHANNEL_ID))
@@ -64,4 +76,12 @@ class SelfPaymentsControllerIT {
.andExpect(jsonPath("$[1].lastChannel", is(CHANNEL_ID.toString())));
}
@Test
void getSelfPaymentsToPeer() throws Exception {
when(selfPaymentsService.getSelfPaymentsToPeer(PUBKEY))
.thenReturn(List.of(SELF_PAYMENT_2, SELF_PAYMENT));
mockMvc.perform(get(NODE_PREFIX + "/self-payments-to-peer/"))
.andExpect(jsonPath("$[0].memo", is(SELF_PAYMENT_2.memo())))
.andExpect(jsonPath("$[1].memo", is(SELF_PAYMENT.memo())));
}
}