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

return summed fees and amounts for self payments

Browse Source
This commit is contained in:
Carsten Otto
2021-12-14 23:31:16 +01:00
parent 59713d1033
commit 39a6aba404
4 changed files with 69 additions and 19 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
web/src/main/java/de/cotto/lndmanagej/controller/SelfPaymentsController.java
View File

@@ -2,7 +2,6 @@ package de.cotto.lndmanagej.controller;
import com.codahale.metrics.annotation.Timed;
import de.cotto.lndmanagej.controller.dto.ObjectMapperConfiguration;
import de.cotto.lndmanagej.controller.dto.SelfPaymentDto;
import de.cotto.lndmanagej.dto.SelfPaymentsDto;
import de.cotto.lndmanagej.model.ChannelId;
import de.cotto.lndmanagej.model.Pubkey;
@@ -26,32 +25,24 @@ public class SelfPaymentsController {
@Timed
@GetMapping("/channel/{channelId}/self-payments-from-channel")
public SelfPaymentsDto getSelfPaymentsFromChannel(@PathVariable ChannelId channelId) {
return new SelfPaymentsDto(selfPaymentsService.getSelfPaymentsFromChannel(channelId).stream()
.map(SelfPaymentDto::createFromModel)
.toList());
return new SelfPaymentsDto(selfPaymentsService.getSelfPaymentsFromChannel(channelId));
}
@Timed
@GetMapping("/node/{pubkey}/self-payments-from-peer")
public SelfPaymentsDto getSelfPaymentsFromPeer(@PathVariable Pubkey pubkey) {
return new SelfPaymentsDto(selfPaymentsService.getSelfPaymentsFromPeer(pubkey).stream()
.map(SelfPaymentDto::createFromModel)
.toList());
return new SelfPaymentsDto(selfPaymentsService.getSelfPaymentsFromPeer(pubkey));
}
@Timed
@GetMapping("/channel/{channelId}/self-payments-to-channel")
public SelfPaymentsDto getSelfPaymentsToChannel(@PathVariable ChannelId channelId) {
return new SelfPaymentsDto(selfPaymentsService.getSelfPaymentsToChannel(channelId).stream()
.map(SelfPaymentDto::createFromModel)
.toList());
return new SelfPaymentsDto(selfPaymentsService.getSelfPaymentsToChannel(channelId));
}
@Timed
@GetMapping("/node/{pubkey}/self-payments-to-peer")
public SelfPaymentsDto getSelfPaymentsToPeer(@PathVariable Pubkey pubkey) {
return new SelfPaymentsDto(selfPaymentsService.getSelfPaymentsToPeer(pubkey).stream()
.map(SelfPaymentDto::createFromModel)
.toList());
return new SelfPaymentsDto(selfPaymentsService.getSelfPaymentsToPeer(pubkey));
}
}

22
web/src/main/java/de/cotto/lndmanagej/dto/SelfPaymentsDto.java
View File

@@ -1,8 +1,28 @@
package de.cotto.lndmanagej.dto;
import de.cotto.lndmanagej.controller.dto.SelfPaymentDto;
import de.cotto.lndmanagej.model.Coins;
import de.cotto.lndmanagej.model.SelfPayment;
import java.util.List;
import java.util.function.Function;
public record SelfPaymentsDto(List<SelfPaymentDto> selfPayments) {
public record SelfPaymentsDto(List<SelfPaymentDto> selfPayments, String amountPaid, String fees) {
public SelfPaymentsDto(List<SelfPayment> selfPayments) {
this(
selfPayments.stream().map(SelfPaymentDto::createFromModel).toList(),
sumToString(selfPayments, SelfPayment::amountPaid),
sumToString(selfPayments, SelfPayment::fees)
);
}
private static String sumToString(List<SelfPayment> selfPayments, Function<SelfPayment, Coins> coinFunction) {
return String.valueOf(sum(selfPayments, coinFunction).milliSatoshis());
}
private static Coins sum(List<SelfPayment> selfPayments, Function<SelfPayment, Coins> coinFunction) {
return selfPayments.stream()
.map(coinFunction)
.reduce(Coins.NONE, Coins::add);
}
}