【第8回】マイクロサービスを呼び出すWebAPの単体テストコード・E2Eテストの実装(前編)¶

package org.debugroom.mynavi.sample.continuous.integration.bff.domain.repository;

// omit

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.boot.test.autoconfigure.web.client.RestClientTest;
import org.springframework.context.MessageSource;
import org.springframework.test.context.ContextConfiguration;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.test.web.client.MockRestServiceServer;
import org.springframework.test.web.client.match.MockRestRequestMatchers;
import org.springframework.test.web.client.response.MockRestResponseCreators;
import org.springframework.web.client.RestTemplate;

@RunWith(Enclosed.class)
public class UserResourceRepositoryImplTest {


    @RunWith(SpringRunner.class)                                  // …(A)
    @RestClientTest                                               // …(B)
    @ContextConfiguration(classes = {UnitTest.Config.class,
             TestConfig.UnitTestConfig.class})                    // …(C)
    public static class UnitTest{

        //omit

        @Autowired
        RestTemplate restTemplate;

        @Autowired
        MessageSource messageSource;

        @Autowired
        ObjectMapper objectMapper;

        @Autowired
        UserResourceRepository userResourceRepository;

        @Rule
        public ExpectedException expectedException = ExpectedException.none();

        @Test
        public void findOneAbnormalTest1() throws Exception{

            MockRestServiceServer mockRestServiceServer = MockRestServiceServer
                  .bindTo(restTemplate).build();              // …(D)

            Long userId = 0L;

            String errorCode = "E0001";
            BusinessException businessException = new BusinessException(errorCode,
                  messageSource.getMessage(errorCode, new Long[]{userId},
                      Locale.getDefault()), Long.toString(userId));
            String jsonResponseBody1 = objectMapper.writeValueAsString(
                  BusinessExceptionResponse.builder()
                          .businessException(businessException)
                          .build());                         // …(E)

            mockRestServiceServer
              .expect(MockRestRequestMatchers.requestTo("/backend/api/v1/users/0"))
              .andExpect(MockRestRequestMatchers.method(HttpMethod.GET))
              .andRespond(MockRestResponseCreators.withBadRequest().body(
                          jsonResponseBody1));               // …(F)

            expectedException.expect(BusinessException.class);
            expectedException.expect(BusinessExceptionMatcher.builder()
                  .businessException(businessException).build());

           userResourceRepository.findOne(userId);

      }
      // omit
}

package org.debugroom.mynavi.sample.continuous.integration.bff.domain.service;

// omit

@Service
public class OrchestrateServiceImpl implements OrchestrateService {

    @Autowired
    UserResourceRepository userResourceRepository;

    @Override
    public List<UserResource> addUsers(List<UserResource> addUserResources)
          throws BusinessException{
        List<UserResource> userResources = new ArrayList<>();
        for (UserResource addUserResource : addUserResources){
            try{
                userResources.add(userResourceRepository.save(addUserResource));
            }catch (BusinessException e){
            // Rollback for SAGA Pattern.
                for(UserResource userResource : userResources){
                    userResourceRepository.delete(userResource.getUserId());
                }
                throw e;
            }
       }
       return userResources;
    }
}

package org.debugroom.mynavi.sample.continuous.integration.bff.domain.service;

// omit

import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.mock.mockito.MockBean;
import org.springframework.test.context.junit4.SpringRunner;

@RunWith(Enclosed.class)
public class OrchestrateServiceImplTest {

    // omit

    @RunWith(SpringRunner.class)
    @SpringBootTest(classes = {
        OrchestrateServiceImplTest.UnitTest.Config.class
     }, webEnvironment = SpringBootTest.WebEnvironment.NONE)
    public static class UnitTest{

        // omit

        @MockBean
        UserResourceRepository userResourceRepositoryMock;

        @Autowired
        OrchestrateService orchestrateService;

        @Rule
        public ExpectedException expectedException = ExpectedException.none();

        // omit
        @Before
        public void setUp() throws Exception{
            // omit
            when(userResourceRepositoryMock.save(mockUser1)).thenReturn(mockUser1);
            when(userResourceRepositoryMock.save(mockUser2)).thenThrow(BusinessException.class);
            // omit
        }

        @Test
        public void addUsersAbnormalTest1() throws Exception{
            //omit
            UserResource user1 = UserResource.builder()
                     .userId(userId1).firstName("taro").familyName("mynavi")
                     .loginId("taro.mynavi").address(address1)
                     .emailList(Arrays.asList(new EmailResource[]{email1, email2})).build();
            UserResource user2 = UserResource.builder()
                     .userId(userId2).familyName("mynavi").firstName("hanako")
                     .loginId("hanako.mynavi").address(address2)
                     .emailList(Arrays.asList(new EmailResource[]{email3})).build();
            //omit
            expectedException.expect(BusinessException.class);

            orchestrateService.addUsers(Arrays.asList(
                new UserResource[]{user1, user2}));
       }
       // omit