Построение Android приложений шаг за шагом, часть вторая

• Введение
• Шаг 1. Простая архитектура
• Шаг 2. Усложненная архитектура
• Шаг 3. Dependency Injection
• Шаг 4. Модульное тестирование
• Шаг 5. Интеграционное тестирование
• Шаг 6. Функциональное тестирование
• Шаг 7. TDD
• Шаг 8. Что дальше?
• Заключение

apply plugin: 'com.android.application'
apply plugin: 'com.neenbedankt.android-apt'
 
dependencies {
    compile fileTree(dir: 'libs', include: ['*.jar'])
    compile 'com.android.support:appcompat-v7:21.0.3'
 
    compile 'com.google.dagger:dagger:2.0-SNAPSHOT'
    apt 'com.google.dagger:dagger-compiler:2.0-SNAPSHOT'
    provided 'org.glassfish:javax.annotation:10.0-b28'
}

@Singleton
@Component(modules = {ModelModule.class, PresenterModule.class, ViewModule.class})
public interface AppComponent {

   void inject(ModelImpl dataRepository);

   void inject(BasePresenter basePresenter);

   void inject(RepoListPresenter repoListPresenter);

   void inject(RepoInfoPresenter repoInfoPresenter);

   void inject(RepoInfoFragment repoInfoFragment);
}

@Provides
@Singleton
ApiInterface provideApiInterface() {
   return ApiModule.getApiInterface(Const.BASE_URL);
}

@Provides
@Singleton
@Named(Const.UI_THREAD)
Scheduler provideSchedulerUI() {
   return AndroidSchedulers.mainThread();
}

@Provides
@Singleton
@Named(Const.IO_THREAD)
Scheduler provideSchedulerIO() {
   return Schedulers.io();
}

public class PresenterModule {

   @Provides
   @Singleton
   Model provideDataRepository() {
       return new ModelImpl();
   }

   @Provides
   CompositeSubscription provideCompositeSubscription() {
       return new CompositeSubscription();
   }
}

public class RepoBranchesMapper implements Func1<List<BranchDTO>, List<Branch>> {

   @Inject
   public RepoBranchesMapper() {
   }

   @Override
   public List<Branch> call(List<BranchDTO> branchDTOs) {
       List<Branch> branches = Observable.from(branchDTOs)
               .map(branchDTO -> new Branch(branchDTO.getName()))
               .toList()
               .toBlocking()
               .first();
       return branches;
   }
}

@Override
public void onCreate(@Nullable Bundle savedInstanceState) {
   super.onCreate(savedInstanceState);
   DaggerViewComponent.builder()
           .viewDynamicModule(new ViewDynamicModule(this))
           .build()
           .inject(this);
}

@Singleton
@Component(modules = {ViewDynamicModule.class})
public interface ViewComponent {

   void inject(RepoListFragment repoListFragment);
}

@Module
public class ViewDynamicModule {

   RepoListView view;

   public ViewDynamicModule(RepoListView view) {
       this.view = view;
   }

   @Provides
   RepoListPresenter provideRepoListPresenter() {
       return new RepoListPresenter(view);
   }
}

@Inject
RepoInfoPresenter presenter;

@Override
public void onCreate(@Nullable Bundle savedInstanceState) {
   super.onCreate(savedInstanceState);
   App.getComponent().inject(this);
   presenter.onCreate(this, getRepositoryVO());
}

@Module
public class ViewModule {

   @Provides
   RepoInfoPresenter provideRepoInfoPresenter() {
       return new RepoInfoPresenter();
   }
}

apply plugin: 'jacoco'

jacoco {
   toolVersion = "0.7.1.201405082137"
}

def coverageSourceDirs = [
       '../app/src/main/java'
]

task jacocoTestReport(type: JacocoReport, dependsOn: "testDebugUnitTest") {
   group = "Reporting"

   description = "Generate Jacoco coverage reports"

   classDirectories = fileTree(
           dir: '../app/build/intermediates/classes/debug',
           excludes: ['**/R.class',
                      '**/R$*.class',
                      '**/*$ViewInjector*.*',
                      '**/*$ViewBinder*.*',   //DI
                      '**/*_MembersInjector*.*',  //DI
                      '**/*_Factory*.*',  //DI
                      '**/testrx/model/dto/*.*', //dto model
                      '**/testrx/presenter/vo/*.*', //vo model
                      '**/testrx/other/**',
                      '**/BuildConfig.*',
                      '**/Manifest*.*',
                      '**/Lambda$*.class',
                      '**/Lambda.class',
                      '**/*Lambda.class',
                      '**/*Lambda*.class']
   )

   additionalSourceDirs = files(coverageSourceDirs)
   sourceDirectories = files(coverageSourceDirs)
   executionData = files('../app/build/jacoco/testDebugUnitTest.exec')

   reports {
       xml.enabled = true
       html.enabled = true
   }
}

@Module
public class ModelTestModule {

   @Provides
   @Singleton
   ApiInterface provideApiInterface() {
       return mock(ApiInterface.class);
   }

   @Provides
   @Singleton
   @Named(Const.UI_THREAD)
   Scheduler provideSchedulerUI() {
       return Schedulers.immediate();
   }

   @Provides
   @Singleton
   @Named(Const.IO_THREAD)
   Scheduler provideSchedulerIO() {
       return Schedulers.immediate();
   }
}

public class ApiInterfaceTest extends BaseTest {

   private MockWebServer server;
   private ApiInterface apiInterface;

   @Before
   public void setUp() throws Exception {
       super.setUp();
       server = new MockWebServer();
       server.start();
       final Dispatcher dispatcher = new Dispatcher() {

           @Override
           public MockResponse dispatch(RecordedRequest request) throws InterruptedException {

               if (request.getPath().equals("/users/" + TestConst.TEST_OWNER + "/repos")) {
                   return new MockResponse().setResponseCode(200)
                           .setBody(testUtils.readString("json/repos"));
               } else if (request.getPath().equals("/repos/" + TestConst.TEST_OWNER + "/" + TestConst.TEST_REPO + "/branches")) {
                   return new MockResponse().setResponseCode(200)
                           .setBody(testUtils.readString("json/branches"));
               } else if (request.getPath().equals("/repos/" + TestConst.TEST_OWNER + "/" + TestConst.TEST_REPO + "/contributors")) {
                   return new MockResponse().setResponseCode(200)
                           .setBody(testUtils.readString("json/contributors"));
               }
               return new MockResponse().setResponseCode(404);
           }
       };

       server.setDispatcher(dispatcher);
       HttpUrl baseUrl = server.url("/");
       apiInterface = ApiModule.getApiInterface(baseUrl.toString());
   }


   @Test
   public void testGetRepositories() throws Exception {

       TestSubscriber<List<RepositoryDTO>> testSubscriber = new TestSubscriber<>();
       apiInterface.getRepositories(TestConst.TEST_OWNER).subscribe(testSubscriber);

       testSubscriber.assertNoErrors();
       testSubscriber.assertValueCount(1);

       List<RepositoryDTO> actual = testSubscriber.getOnNextEvents().get(0);

       assertEquals(7, actual.size());
       assertEquals("Android-Rate", actual.get(0).getName());
       assertEquals("andrey7mel/Android-Rate", actual.get(0).getFullName());
       assertEquals(26314692, actual.get(0).getId());
   }

  @After
    public void tearDown() throws Exception {
        server.shutdown();
    }
}

@Test
public void testGetRepoBranches() {

   BranchDTO[] branchDTOs = testUtils.getGson().fromJson(testUtils.readString("json/branches"), BranchDTO[].class);

   when(apiInterface.getBranches(TestConst.TEST_OWNER, TestConst.TEST_REPO)).thenReturn(Observable.just(Arrays.asList(branchDTOs)));

   TestSubscriber<List<BranchDTO>> testSubscriber = new TestSubscriber<>();
   model.getRepoBranches(TestConst.TEST_OWNER, TestConst.TEST_REPO).subscribe(testSubscriber);

   testSubscriber.assertNoErrors();
   testSubscriber.assertValueCount(1);

   List<BranchDTO> actual = testSubscriber.getOnNextEvents().get(0);

   assertEquals(3, actual.size());
   assertEquals("QuickStart", actual.get(0).getName());
   assertEquals("94870e23f1cfafe7201bf82985b61188f650b245", actual.get(0).getCommit().getSha());
}

    @Before
    public void setUp() throws Exception {
        super.setUp();
        component.inject(this);

        activityCallback = mock(ActivityCallback.class);

        mockView = mock(RepoListView.class);
        repoListPresenter = new RepoListPresenter(mockView, activityCallback);

        doAnswer(invocation -> Observable.just(repositoryDTOs))
                .when(model)
                .getRepoList(TestConst.TEST_OWNER);

        doAnswer(invocation -> TestConst.TEST_OWNER)
                .when(mockView)
                .getUserName();
    }


    @Test
    public void testLoadData() {
        repoListPresenter.onCreateView(null);
        repoListPresenter.onSearchButtonClick();
        repoListPresenter.onStop();

        verify(mockView).showRepoList(repoList);
    }

    @Test
    public void testSubscribe() {
        repoListPresenter = spy(new RepoListPresenter(mockView, activityCallback)); //for ArgumentCaptor
        repoListPresenter.onCreateView(null);
        repoListPresenter.onSearchButtonClick();
        repoListPresenter.onStop();

        ArgumentCaptor<Subscription> captor = ArgumentCaptor.forClass(Subscription.class);
        verify(repoListPresenter).addSubscription(captor.capture());
        List<Subscription> subscriptions = captor.getAllValues();
        assertEquals(1, subscriptions.size());
        assertTrue(subscriptions.get(0).isUnsubscribed());
    }

@Test
public void testOnCreateViewWithBundle() {
   repoInfoFragment.onCreateView(LayoutInflater.from(activity), (ViewGroup) activity.findViewById(R.id.container), bundle);
   verify(repoInfoPresenter).onCreateView(bundle);
}

@Test
public void testOnStop() {
   repoInfoFragment.onStop();
   verify(repoInfoPresenter).onStop();
}

@Test
public void testOnSaveInstanceState() {
   repoInfoFragment.onSaveInstanceState(null);
   verify(repoInfoPresenter).onSaveInstanceState(null);
}