v0.3.2 add RxUser to control User profile setting.

Author: wbinarytree

build.gradle

@@ -23,7 +23,7 @@ buildscript {
         jcenter()
     }
     dependencies {
-        classpath 'com.android.tools.build:gradle:2.3.0'
+        classpath 'com.android.tools.build:gradle:2.3.1'
         classpath 'com.jfrog.bintray.gradle:gradle-bintray-plugin:1.7.3'
         classpath 'com.github.dcendents:android-maven-gradle-plugin:1.5'
         // NOTE: Do not place your application dependencies here; they belong

rxfirebase/build.gradle

@@ -1,7 +1,23 @@
+/*
+ * Copyright 2017 WBinaryTree
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
 apply plugin: 'com.android.library'
 apply plugin: 'com.github.dcendents.android-maven'
 apply plugin: 'com.jfrog.bintray'
-version = '0.3.1'
+version = '0.3.2'
 android {
     compileSdkVersion 25
     buildToolsVersion "25.0.2"
@@ -59,33 +75,15 @@ artifacts {
     archives javadocJar
     archives sourcesJar
 }
-group = "com.github.wbinarytree"            /*
- * Copyright 2017 WBinaryTree
- *
- * Licensed under the Apache License, Version 2.0 (the "License");
- * you may not use this file except in compliance with the License.
- * You may obtain a copy of the License at
- *
- *     http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */            // Maven Group ID for the artifact，
+group = "com.github.wbinarytree"
 install {
     repositories.mavenInstaller {
-        // This generates POM.xml with proper parameters
         pom {
             project {
                 version
                 packaging 'aar'
-                // Add your description here
                 name 'RxJava 2.x wrap for Firebase'
-                //项目的描述 你可以多写一点
                 url siteUrl
-                // Set your license
                 licenses {
                     license {
                         name 'The Apache Software License, Version 2.0'
@@ -94,7 +92,7 @@ install {
                 }
                 developers {
                     developer {
-                        id 'wbinarytree'        //填写的一些基本信息
+                        id 'wbinarytree'
                         name 'Yaoda WANG'
                         email '[email protected]'
                     }
@@ -116,17 +114,13 @@ bintray  {
     configurations = ['archives']
     pkg {
         userOrg = 'phoenixwyd'
-        //发布到Bintray的哪个仓库
         repo = 'maven'
-        //发布到Bintray上的名字
         name = 'RxFirebase'
-        //项目描述
         desc = 'A RxJava 2 wrap for firebase'
         websiteUrl = siteUrl
         vcsUrl = gitUrl
         issueTrackerUrl = issueUrl
         licenses = ["Apache-2.0"]
-        //标签
         labels = ['android']
         publish = true
         publicDownloadNumbers = true

rxfirebase/src/main/java/phoenixlib/io/rxfirebase/auth/AuthStateObservable.java

@@ -20,6 +20,8 @@
 
 import com.google.firebase.auth.FirebaseAuth;
 import com.google.firebase.auth.FirebaseUser;
+import com.google.firebase.auth.UserInfo;
+import com.google.firebase.auth.UserProfileChangeRequest;
 
 import java.util.concurrent.atomic.AtomicBoolean;
 
@@ -32,7 +34,7 @@
  * Created by phoenix on 2017/4/15.
  */
 
-class AuthStateObservable extends Observable<FirebaseUser> {
+public class AuthStateObservable extends Observable<FirebaseUser> {
 
     private final FirebaseAuth auth;
 
@@ -49,6 +51,7 @@ protected void subscribeActual(Observer<? super FirebaseUser> observer) {
         auth.addAuthStateListener(listener);
     }
 
+
     private static class AuthListener implements Disposable, FirebaseAuth.AuthStateListener {
 
         private final Observer<? super FirebaseUser> observer;

rxfirebase/src/main/java/phoenixlib/io/rxfirebase/auth/RxAuth.java

@@ -72,4 +72,13 @@ public static Observable<FirebaseUser> authState(FirebaseAuth auth) {
         return new AuthStateObservable(auth);
     }
 
+    public static Observable<AuthResult> createUser(final FirebaseAuth auth, final String email, final String password) {
+        return new TaskObservable<>(new Callable<Task<AuthResult>>() {
+            @Override
+            public Task<AuthResult> call() throws Exception {
+                return auth.createUserWithEmailAndPassword(email, password);
+            }
+        });
+    }
+
 }

rxfirebase/src/main/java/phoenixlib/io/rxfirebase/auth/RxUser.java

@@ -0,0 +1,62 @@
+/*
+ * Copyright 2017 WBinaryTree
+ *
+ * Licensed under the Apache License, Version 2.0 (the "License");
+ * you may not use this file except in compliance with the License.
+ * You may obtain a copy of the License at
+ *
+ *     http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing, software
+ * distributed under the License is distributed on an "AS IS" BASIS,
+ * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+ * See the License for the specific language governing permissions and
+ * limitations under the License.
+ */
+
+package phoenixlib.io.rxfirebase.auth;
+
+import com.google.android.gms.tasks.Task;
+import com.google.firebase.auth.FirebaseUser;
+import com.google.firebase.auth.GetTokenResult;
+import com.google.firebase.auth.UserProfileChangeRequest;
+
+import java.util.concurrent.Callable;
+
+import io.reactivex.Completable;
+import io.reactivex.Observable;
+
+/**
+ * Created by phoenix on 2017/4/16.
+ */
+
+public class RxUser {
+    public static Completable updateUsername(final FirebaseUser user, final String username) {
+        return new TaskObservable<>(new Callable<Task<Void>>() {
+            @Override
+            public Task<Void> call() throws Exception {
+                return user.updateProfile(new UserProfileChangeRequest.Builder().setDisplayName(username)
+                                                                                .build());
+            }
+        }).ignoreElements();
+    }
+
+    public static Completable updateProfile(final FirebaseUser user, final UserProfileChangeRequest profile) {
+        return new TaskObservable<>(new Callable<Task<Void>>() {
+            @Override
+            public Task<Void> call() throws Exception {
+                return user.updateProfile(profile);
+            }
+        }).ignoreElements();
+    }
+
+    public static Observable<GetTokenResult> getToken(final FirebaseUser user, final boolean refresh) {
+        return new TaskObservable<>(new Callable<Task<GetTokenResult>>() {
+            @Override
+            public Task<GetTokenResult> call() throws Exception {
+                return user.getToken(refresh);
+            }
+        });
+    }
+
+}