Repository Example

UsersRepository.java

@Singleton
public final class UsersRepository {

    private final Api api;
    private final Prefs prefs;
    private final Db db;

    @Inject
    public UsersRepository(Api api, Prefs prefs, Db db) {
        this.api = api;
        this.prefs = prefs;
        this.db = db;
    }

    public Single<List<User>> getJoinedUsers(long gameId, int page) {
        return api.fetchJoinedUsers(gameId, page).map(Users::get);
    }

    public Single<User> getMe() {
        return api.fetchMe().map(UserResponse::getUser);
    }

    public Single<Users> getUsersForRate(long gameId, int page) {
        return api.fetchUsersForRate(gameId, page);
    }

    public Single<User> updateProfile(Profile profile) {
        return api.updateProfile(new UserBody(profile)).map(UserResponse::getUser);
    }

    public Completable updateLocation(Location location) {
        return api.updateLocation(location.lat(), location.lng()).toCompletable();
    }

    public Single<String> uploadPhoto(File uri) {
        final MultipartBody.Part formData = MultipartBody.Part.createFormData("upload[source]",
                uri.getName(),
                RequestBody.create(MediaType.parse(MimeType.IMAGE_JPG), uri));
        return api.uploadPhoto(formData)
                .map(UploadResponse::getUpload)
                .map(Upload::getUrl)
                .doOnSuccess(url -> Timber.v("Uploaded photo url: %s", url));
    }

    public Single<User> getUser(long userId) {
        return api.fetchUser(userId).map(UserResponse::getUser);
    }

    public Completable rateUser(long userId, long gameId, Map<String, Float> ratings) {
        return api.rateUser(userId, new ReviewRequest(gameId, ratings)).toCompletable();
    }
}