juplo.de Git - demos/testing/blob - src/test/java/de/juplo/demo/RemoteContentServiceTest.java

   1 package de.juplo.demo;
   2
   3
   4 import org.junit.jupiter.api.BeforeEach;
   5 import org.junit.jupiter.api.Test;
   6 import org.junit.jupiter.api.extension.ExtendWith;
   7 import static org.mockito.ArgumentMatchers.eq;
   8 import static org.mockito.Mockito.when;
   9 import org.springframework.boot.test.mock.mockito.MockBean;
  10 import org.springframework.test.context.junit.jupiter.SpringExtension;
  11 import org.springframework.web.reactive.function.client.WebClient;
  12 import org.springframework.web.reactive.function.client.WebClient.RequestHeadersUriSpec;
  13 import org.springframework.web.reactive.function.client.WebClient.ResponseSpec;
  14 import reactor.core.publisher.Mono;
  15 import reactor.test.StepVerifier;
  16
  17
  18 /**
  19  * Unit-Test for class {@link RemoteContentService}.
  20  * @author Kai Moritz
  21  */
  22 @ExtendWith(SpringExtension.class)
  23 public class RemoteContentServiceTest
  24 {
  25   RemoteContentService service;
  26
  27   @MockBean
  28   WebClient webClient;
  29   @MockBean
  30   RequestHeadersUriSpec uriSpec;
  31   @MockBean
  32   ResponseSpec responseSpec;
  33
  34
  35   @BeforeEach
  36   void setUp()
  37   {
  38     service = new RemoteContentService(webClient);
  39   }
  40
  41
  42   @Test
  43   void test()
  44   {
  45     when(webClient.get()).thenReturn(uriSpec);
  46     when(uriSpec.uri(eq("/foo"))).thenReturn(uriSpec);
  47     when(uriSpec.retrieve()).thenReturn(responseSpec);
  48     when(responseSpec.bodyToMono(String.class)).thenReturn(Mono.just("bar"));
  49
  50     Mono<String> result = service.getRemoteText("/foo");
  51
  52     StepVerifier
  53         .create(result)
  54         .expectNext("bar")
  55         .verifyComplete();
  56   }
  57 }