2323import com .stackup .stackup .session .domain .TtsStatus ;
2424import com .stackup .stackup .user .domain .User ;
2525import java .util .Optional ;
26+ import java .util .function .Predicate ;
2627import org .junit .jupiter .api .Test ;
2728import org .junit .jupiter .api .extension .ExtendWith ;
2829import org .mockito .InjectMocks ;
@@ -58,9 +59,9 @@ void apply_successStoresTtsFieldsWithoutChangingMessageStatus() {
5859 assertThat (question .getTtsAudioPath ()).isEqualTo ("interview/tts/50/100.mp3" );
5960 assertThat (question .getTtsDurationSec ()).isEqualTo (2.4 );
6061 assertThat (MessageResult .of (question ).ttsAudioPath ()).isEqualTo ("interview/tts/50/100.mp3" );
61- verify (events ).publishEvent (argThat (event ->
62+ verify (events ).publishEvent (argThatObject (event ->
6263 isNotice (event , RealtimeNotifyEvent .Channel .SESSION , 50L )));
63- verify (events ).publishEvent (argThat (event ->
64+ verify (events ).publishEvent (argThatObject (event ->
6465 isNotice (event , RealtimeNotifyEvent .Channel .USER , 1L )));
6566 verify (processedMessageRepository ).save (any (ProcessedMessage .class ));
6667 }
@@ -81,7 +82,7 @@ void apply_failedMarksOnlyTtsFailedAndLeavesQuestionUsable() {
8182 assertThat (question .getTtsStatus ()).isEqualTo (TtsStatus .FAILED );
8283 assertThat (question .getContent ()).isEqualTo ("Q?" );
8384 assertThat (question .getTtsAudioPath ()).isNull ();
84- verify (events ).publishEvent (argThat (event ->
85+ verify (events ).publishEvent (argThatObject (event ->
8586 isNotice (event , RealtimeNotifyEvent .Channel .SESSION , 50L )));
8687 verify (processedMessageRepository ).save (any (ProcessedMessage .class ));
8788 }
@@ -145,6 +146,10 @@ private boolean isNotice(Object event, RealtimeNotifyEvent.Channel channel, Long
145146 && realtimeNotifyEvent .type () == SseEventType .SESSION_MESSAGE ;
146147 }
147148
149+ private Object argThatObject (Predicate <Object > predicate ) {
150+ return argThat (predicate ::test );
151+ }
152+
148153 private InterviewSession sessionFixture (Long id ) {
149154 User user = User .createGithubUser (1L , "u" , null , null , "t" );
150155 ReflectionTestUtils .setField (user , "id" , 1L );
0 commit comments