Skip to content
Snippets Groups Projects
Commit 7056c0f1 authored by OZGCloud's avatar OZGCloud
Browse files

OZG-5666 move findAnswers to enrich method

parent 26e9be7d
No related branches found
No related tags found
No related merge requests found
...@@ -98,14 +98,15 @@ public class AntragraumService { ...@@ -98,14 +98,15 @@ public class AntragraumService {
var rueckfragen = postfachNachrichtService.findRueckfragen(BAYERN_ID_SERVICE_KONTO_TYPE, getPostfachId(samlToken)) var rueckfragen = postfachNachrichtService.findRueckfragen(BAYERN_ID_SERVICE_KONTO_TYPE, getPostfachId(samlToken))
.map(rueckfrageMapper::fromPostfachNachricht) .map(rueckfrageMapper::fromPostfachNachricht)
.map(rueckfrage -> enrichByAnswers(rueckfrage, findAnswers(samlToken, rueckfrage.getId()))).toList(); .map(rueckfrage -> enrichByAnswers(rueckfrage, samlToken)).toList();
return enrichRueckfragen(rueckfragen); return enrichRueckfragen(rueckfragen);
} }
Rueckfrage enrichByAnswers(Rueckfrage rueckfrage, Stream<PostfachNachricht> answers) { Rueckfrage enrichByAnswers(Rueckfrage rueckfrage, String samlToken) {
var rueckfrageBuilder = rueckfrage.toBuilder(); var rueckfrageBuilder = rueckfrage.toBuilder();
getFirstSentAt(answers).ifPresent(firstSentAt -> rueckfrageBuilder.answeredAt(firstSentAt).status(RueckfrageStatus.ANSWERED)); getFirstSentAt(findAnswers(samlToken, rueckfrage.getId()))
.ifPresent(firstSentAt -> rueckfrageBuilder.answeredAt(firstSentAt).status(RueckfrageStatus.ANSWERED));
return rueckfrageBuilder.build(); return rueckfrageBuilder.build();
} }
......
...@@ -76,7 +76,6 @@ class AntragraumServiceTest { ...@@ -76,7 +76,6 @@ class AntragraumServiceTest {
private final Rueckfrage rueckfrage = RueckfrageTestFactory.create(); private final Rueckfrage rueckfrage = RueckfrageTestFactory.create();
private final PostfachNachricht postfachNachricht = PostfachNachrichtTestFactory.create(); private final PostfachNachricht postfachNachricht = PostfachNachrichtTestFactory.create();
private final Stream<PostfachNachricht> answers = Stream.of(postfachNachricht);
@BeforeEach @BeforeEach
void mock() { void mock() {
...@@ -85,7 +84,6 @@ class AntragraumServiceTest { ...@@ -85,7 +84,6 @@ class AntragraumServiceTest {
when(rueckfrageMapper.fromPostfachNachricht(any())).thenReturn(rueckfrage); when(rueckfrageMapper.fromPostfachNachricht(any())).thenReturn(rueckfrage);
doReturn(rueckfrage).when(service).enrichByAnswers(any(), any()); doReturn(rueckfrage).when(service).enrichByAnswers(any(), any());
doReturn(Stream.of(rueckfrage)).when(service).enrichRueckfragen(any()); doReturn(Stream.of(rueckfrage)).when(service).enrichRueckfragen(any());
doReturn(answers).when(service).findAnswers(any(), any());
doReturn(POSTFACH_ID).when(service).getPostfachId(any()); doReturn(POSTFACH_ID).when(service).getPostfachId(any());
} }
...@@ -124,18 +122,11 @@ class AntragraumServiceTest { ...@@ -124,18 +122,11 @@ class AntragraumServiceTest {
verify(rueckfrageMapper).fromPostfachNachricht(postfachNachricht); verify(rueckfrageMapper).fromPostfachNachricht(postfachNachricht);
} }
@Test
void shouldCallFindAnswers() {
service.findRueckfragen(SAML_TOKEN).toList();
verify(service).findAnswers(SAML_TOKEN, RueckfrageTestFactory.ID);
}
@Test @Test
void shouldCallEnrichByAnswers() { void shouldCallEnrichByAnswers() {
service.findRueckfragen(SAML_TOKEN).toList(); service.findRueckfragen(SAML_TOKEN).toList();
verify(service).enrichByAnswers(rueckfrage, answers); verify(service).enrichByAnswers(rueckfrage, SAML_TOKEN);
} }
@Test @Test
...@@ -157,11 +148,22 @@ class AntragraumServiceTest { ...@@ -157,11 +148,22 @@ class AntragraumServiceTest {
@Nested @Nested
class TestEnrichByAnswers { class TestEnrichByAnswers {
private static final String SAML_TOKEN = "TOKEN";
private final Rueckfrage rueckfrage = RueckfrageTestFactory.create(); private final Rueckfrage rueckfrage = RueckfrageTestFactory.create();
private final PostfachNachricht postfachNachricht = PostfachNachrichtTestFactory.create();
private final Stream<PostfachNachricht> answers = Stream.of(postfachNachricht);
@BeforeEach @BeforeEach
void mock() { void mock() {
doReturn(Optional.of(PostfachNachrichtTestFactory.SENT_AT)).when(service).getFirstSentAt(any()); doReturn(Optional.of(PostfachNachrichtTestFactory.SENT_AT)).when(service).getFirstSentAt(any());
doReturn(answers).when(service).findAnswers(any(), any());
}
@Test
void shouldCallFindAnswers() {
enrichByAnswer();
verify(service).findAnswers(SAML_TOKEN, RueckfrageTestFactory.ID);
} }
@Test @Test
...@@ -187,7 +189,7 @@ class AntragraumServiceTest { ...@@ -187,7 +189,7 @@ class AntragraumServiceTest {
} }
private Rueckfrage enrichByAnswer() { private Rueckfrage enrichByAnswer() {
return service.enrichByAnswers(rueckfrage, Stream.empty()); return service.enrichByAnswers(rueckfrage, SAML_TOKEN);
} }
} }
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment