mirror of
https://github.com/aljazceru/lnd-manageJ.git
synced 2026-01-21 15:04:22 +01:00
remove HTLC logger
This commit is contained in:
@@ -1,29 +0,0 @@
|
||||
package de.cotto.lndmanagej;
|
||||
|
||||
import de.cotto.lndmanagej.grpc.GrpcHtlcEvents;
|
||||
import org.slf4j.Logger;
|
||||
import org.slf4j.LoggerFactory;
|
||||
import org.springframework.scheduling.annotation.Scheduled;
|
||||
import org.springframework.stereotype.Component;
|
||||
|
||||
@Component
|
||||
public class HtlcLogger {
|
||||
private final Logger logger = LoggerFactory.getLogger(getClass());
|
||||
private final GrpcHtlcEvents grpcHtlcEvents;
|
||||
|
||||
public HtlcLogger(GrpcHtlcEvents grpcHtlcEvents) {
|
||||
this.grpcHtlcEvents = grpcHtlcEvents;
|
||||
}
|
||||
|
||||
@Scheduled(fixedDelay = 1_000)
|
||||
public void logForwardFailures() {
|
||||
grpcHtlcEvents.getForwardFailures()
|
||||
.forEach(forwardFailure -> logger.info("Forward Failure: {}", forwardFailure));
|
||||
}
|
||||
|
||||
@Scheduled(fixedDelay = 1_000)
|
||||
public void logSettledForwards() {
|
||||
grpcHtlcEvents.getSettledForwards()
|
||||
.forEach(settledForward -> logger.info("Settled Forward: {}", settledForward));
|
||||
}
|
||||
}
|
||||
@@ -1,44 +0,0 @@
|
||||
package de.cotto.lndmanagej;
|
||||
|
||||
import de.cotto.lndmanagej.grpc.GrpcHtlcEvents;
|
||||
import org.junit.jupiter.api.Test;
|
||||
import org.junit.jupiter.api.extension.ExtendWith;
|
||||
import org.mockito.InjectMocks;
|
||||
import org.mockito.Mock;
|
||||
import org.mockito.junit.jupiter.MockitoExtension;
|
||||
import uk.org.lidalia.slf4jtest.TestLogger;
|
||||
import uk.org.lidalia.slf4jtest.TestLoggerFactory;
|
||||
|
||||
import java.util.stream.Stream;
|
||||
|
||||
import static de.cotto.lndmanagej.model.ForwardFailureFixtures.FORWARD_FAILURE;
|
||||
import static de.cotto.lndmanagej.model.SettledForwardFixtures.SETTLED_FORWARD;
|
||||
import static org.assertj.core.api.Assertions.assertThat;
|
||||
import static org.mockito.Mockito.when;
|
||||
import static uk.org.lidalia.slf4jtest.LoggingEvent.info;
|
||||
|
||||
@ExtendWith(MockitoExtension.class)
|
||||
class HtlcLoggerTest {
|
||||
private final TestLogger logger = TestLoggerFactory.getTestLogger(HtlcLogger.class);
|
||||
|
||||
@InjectMocks
|
||||
private HtlcLogger htlcLogger;
|
||||
|
||||
@Mock
|
||||
@SuppressWarnings("unused")
|
||||
private GrpcHtlcEvents grpcHtlcEvents;
|
||||
|
||||
@Test
|
||||
void logSettledForwards() {
|
||||
when(grpcHtlcEvents.getSettledForwards()).thenReturn(Stream.of(SETTLED_FORWARD));
|
||||
htlcLogger.logSettledForwards();
|
||||
assertThat(logger.getLoggingEvents()).contains(info("Settled Forward: {}", SETTLED_FORWARD));
|
||||
}
|
||||
|
||||
@Test
|
||||
void logForwardFailures() {
|
||||
when(grpcHtlcEvents.getForwardFailures()).thenReturn(Stream.of(FORWARD_FAILURE));
|
||||
htlcLogger.logForwardFailures();
|
||||
assertThat(logger.getLoggingEvents()).contains(info("Forward Failure: {}", FORWARD_FAILURE));
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user