DV7TiZEx

1public class UserRegistrationTest extends BaseIntegrationTest {
2
3    private static final String TAG = UserRegistrationTest.class.getSimpleName();
4
5    private List<Country> countries;
6    private ApiConfiguration configuration;
7    private int currentCountryNumber = 0;
8
9    @Test
10    @Ignore
11    public void testCustomerRegistration() throws Exception {
12        createGlobalApiClient(GLOBAL_API_URL).getAllCountries().flatMap(new Func1<BaseResponse<List<Country>>, Observable<BaseResponse<ApiConfiguration>>>() {
13            @Override
14            public Observable<BaseResponse<ApiConfiguration>> call(BaseResponse<List<Country>> response) {
15                countries = response.getData();
16
17                setupBaseUrl(countries.get(currentCountryNumber).getUrl());
18
19                return createConfigurationApiClient(baseUrl).getConfiguration();
20            }
21        }).repeat(COUNTRIES_COUNT)
22            .flatMap(new Func1<BaseResponse<ApiConfiguration>, Observable<OAuthToken>>() {
23                @Override
24                public Observable<OAuthToken> call(BaseResponse<ApiConfiguration> response) {
25                    configuration = response.getData();
26
27                    return createAuthenticationApiClient(baseUrl).getToken();
28                }
29            })
30            .flatMap(new Func1<OAuthToken, Observable<BaseResponse<User>>>() {
31                @Override
32                public Observable<BaseResponse<User>> call(OAuthToken oAuthToken) {
33                    System.out.println();
34                    return createCustomerApi(baseUrl, oAuthToken.getToken()).createCustomer(
35                        FixtureDataProvider.generateCustomer(configuration.getCountryCodeMobile()));
36                }
37            })
38            .subscribe(new Action1<BaseResponse<User>>() {
39                @Override
40                public void call(BaseResponse<User> response) {
41                    print(TAG, "countryNumber=" + String.valueOf(currentCountryNumber + 1) + " url =" + countries.get(currentCountryNumber).getUrl());
42                    print(TAG, response.getData().toString());
43                    currentCountryNumber++;
44
45                    Assert.assertEquals(response.getStatusCode(), TestsConstants.SUCCESSFULLY_CREATED_STATUS);
46                }
47            }, new Action1<Throwable>() {
48                @Override
49                public void call(Throwable throwable) {
50                    fail(throwable);
51                }
52            });
53    }
54}