Arthelh/NCNF

package com.ncnf.authentication.firebase;

import com.google.android.gms.tasks.Task;
import com.google.firebase.auth.FirebaseAuth;
import com.ncnf.authentication.Authentication;

import java.util.concurrent.CompletableFuture;

import javax.inject.Inject;


public class FirebaseAuthentication implements Authentication {

    private FirebaseAuth auth;

    @Inject
    public FirebaseAuthentication(){
        this(true);
    }

    protected FirebaseAuthentication(boolean getAuth){
        if(getAuth){
            this.auth = FirebaseAuth.getInstance();
        }
    }

    @Override
    public CompletableFuture<Boolean> register(String email, String password){
        CompletableFuture<Boolean> futureResponse = new CompletableFuture<>();
        auth.createUserWithEmailAndPassword(email, password).addOnCompleteListener(task -> onTaskComplete(task, futureResponse));

        return futureResponse;
    }

    @Override
    public CompletableFuture<Boolean> logIn(String email, String password) {
        CompletableFuture<Boolean> futureResponse = new CompletableFuture<>();

        auth.signInWithEmailAndPassword(email, password).addOnCompleteListener(task -> onTaskComplete(task, futureResponse));

        return futureResponse;
    }

    @Override
    public void logOut() {
        this.auth.signOut();
    }

    /**TODO : should we monitor fail cases or what ? */
    @Override
    public CompletableFuture<Boolean> delete() {
        CompletableFuture<Boolean> futureResponse = new CompletableFuture<>();

        this.auth.getCurrentUser().delete().addOnCompleteListener(task -> onTaskComplete(task, futureResponse));

        return futureResponse;
    }

    @Override
    public CompletableFuture<Boolean> changeEmail(String email){
        CompletableFuture<Boolean> futureResponse = new CompletableFuture<>();

        this.auth.getCurrentUser().updateEmail(email).addOnCompleteListener(task -> onTaskComplete(task , futureResponse));
        return futureResponse;
    }

    private void onTaskComplete(Task<?> task, CompletableFuture<Boolean> futureResponse){
        if(task.isSuccessful()){
            futureResponse.complete(true);
        } else {
            futureResponse.completeExceptionally(task.getException());
        }
    }

    protected void setAuth(FirebaseAuth auth){
        this.auth = auth;
    }

}