import com.firebase.client.FirebaseException; //导入依赖的package包/类
private <T> void onFirebaseException(Exception error, Task<T>.TaskCompletionSource taskSource,
                                     TaskProvider<T> taskProvider) {
    FirebaseException firebaseException = (FirebaseException) error;
    boolean permissionDenied = firebaseException.getMessage().contains("Permission denied");

    if (permissionDenied) {
        codementorTasks.extractAppData()
                .onSuccessTask(task -> authenticate(task.getResult(), true))
                .continueWith(task -> {
                    if (task.isCancelled() || task.isFaulted()) {
                        taskSource.setError(error);
                    } else {
                        taskProvider.get().continueWith(this.<T>onWrappedTaskReCompleted(taskSource));
                    }

                    return null;
                });
    } else {
        taskSource.setError(error);
    }
}
 

import com.firebase.client.FirebaseException; //导入依赖的package包/类
public static Observable<DataSnapshot> observe(final Query ref) {

        return Observable.create(new Observable.OnSubscribe<DataSnapshot>() {

            @Override
            public void call(final Subscriber<? super DataSnapshot> subscriber) {
                final ValueEventListener listener = ref.addValueEventListener(new ValueEventListener() {
                    @Override
                    public void onDataChange(DataSnapshot dataSnapshot) {
                        subscriber.onNext(dataSnapshot);
                    }

                    @Override
                    public void onCancelled(FirebaseError error) {
                        // Turn the FirebaseError into a throwable to conform to the API
                        subscriber.onError(new FirebaseException(error.getMessage()));
                    }
                });

                // When the subscription is cancelled, remove the listener
                subscriber.add(Subscriptions.create(() -> ref.removeEventListener(listener)));
            }
        });
    }
 

import com.firebase.client.FirebaseException; //导入依赖的package包/类
public static Observable<DataSnapshot> observeOnce(final Query ref) {

        return Observable.create(new Observable.OnSubscribe<DataSnapshot>() {

            @Override
            public void call(final Subscriber<? super DataSnapshot> subscriber) {
                ref.addListenerForSingleValueEvent(new ValueEventListener() {
                    @Override
                    public void onDataChange(DataSnapshot dataSnapshot) {
                        subscriber.onNext(dataSnapshot);
                        subscriber.onCompleted();
                    }

                    @Override
                    public void onCancelled(FirebaseError error) {
                        // Turn the FirebaseError into a throwable to conform to the API
                        subscriber.onError(new FirebaseException(error.getMessage()));
                        subscriber.onCompleted();
                    }
                });
            }
        });
    }
 

import com.firebase.client.FirebaseException; //导入依赖的package包/类
@Override
public AuthData authenticate(Firebase firebase) throws FirebaseException, InterruptedException {
  final CountDownLatch done = new CountDownLatch(1);
  firebase.authWithPassword(this.email, this.password, new AuthResultHandler() {
    @Override
    public void onAuthenticationError(FirebaseError err) {
      done.countDown();
      throw err.toException();
    }
    @Override
    public void onAuthenticated(AuthData arg0) {
      result = arg0;
      done.countDown();
    }
  });
  done.await();
  return result;
}
 

import com.firebase.client.FirebaseException; //导入依赖的package包/类
private <T> Continuation<T, T> onWrappedTaskCompleted(Task<T>.TaskCompletionSource taskSource,
                                                      TaskProvider<T> taskProvider) {
    return task -> {
        Exception error = task.getError();

        if (task.isCancelled()) {
            if (error != null) {
                throw new CancellationException(error.getMessage());
            } else {
                throw new CancellationException();
            }
        }

        if (task.isFaulted()) {
            if (error instanceof FirebaseException) {
                this.<T>onFirebaseException(error, taskSource, taskProvider);
            } else {
                taskSource.setError(error);
            }

            return null;
        }

        taskSource.setResult(task.getResult());
        return null;
    };
}
 

import com.firebase.client.FirebaseException; //导入依赖的package包/类
public void push(ThunderBoardSensor sensor) {

        try {
            long time = System.currentTimeMillis();
            Timber.d("%d: %s", time, sensor.getSensorData().toString());
            data.put(time, sensor.getSensorData().clone());
        } catch (FirebaseException e) {
            e.printStackTrace();
            Timber.d(e.getMessage());
        }
    }
 

import com.firebase.client.FirebaseException; //导入依赖的package包/类
/**
 * Creates all firebase references for the current session.
 *
 * @param model
 * @param deviceName
 * @param uniqueID
 * @param demo
 * @param sensor
 * @return
 */
public String createFirebaseReference(String model, String deviceName, String uniqueID, String demo, ThunderBoardSensor sensor) {

    try {

        long currentTime = System.currentTimeMillis();

        String rootDataThundeBoardSessionsUrl = String.format("%s%s/sessions", baseDataThunderBoardUrl, model);
        Timber.d("rootDataThundeBoardSessionsUrl: %s", rootDataThundeBoardSessionsUrl);
        rootDataThundeBoardSessionsReference = new Firebase(rootDataThundeBoardSessionsUrl);
        rootDataThundeBoardSessionsReference.authWithCustomToken(keyFirebase, this);

        String rootDataSessionsUrl = String.format("%s%s", baseDataSessionsUrl, uniqueID);
        Timber.d("rootDataSessionsUrl: %s", rootDataSessionsUrl);
        rootDataSessionsReference = new Firebase(rootDataSessionsUrl);
        rootDataSessionsReference.authWithCustomToken(keyFirebase, this);
        rootDataSessionsDemoReference = rootDataSessionsReference.child(demo);

        // push the start time
        rootDataSessionsReference.child(START_TIME).setValue(currentTime);
        rootDataSessionsReference.child(TEMPERATURE_TYPE).setValue(prefsManager.getPreferences().temperatureType);
        rootDataSessionsReference.child(MEASUREMENTS_TYPE).setValue(prefsManager.getPreferences().measureUnitType);
        Timber.d("root sessions ref: %s", rootDataSessionsReference.getPath().toString());

        // push contactInfo
        ContactInfo ci = new ContactInfo();
        ThunderBoardPreferences prefs = prefsManager.getPreferences();
        ci.emailAddress = prefs.userEmail;
        ci.fullName = prefs.userName;
        ci.title = prefs.userTitle;
        ci.phoneNumber = prefs.userPhone;
        ci.deviceName = deviceName;
        rootDataSessionsReference.child("contactInfo").setValue(ci);

        String demoUrl = String.format("%s%s/%s/%s", baseDemoSessionsUrl, model, uniqueID, demo);
        Timber.d("short demo url: %s", demoUrl);
        rootDataSessionsReference.child(SHORT_URL).setValue(demoUrl);
        // will be overriden later, we do not want to keep it null....
        // if the requirement is to use a short url, then a refactor is needed to wait until it's available
        shortUrl = demoUrl;

        data = new HashMap<>();

        push(sensor);

        pushTimer.start();

        // request in the background
        shortenUrlReference = rootDataSessionsReference;
        shortenUrl(demoUrl);

        rootDataThundeBoardSessionsReference.child(String.valueOf(currentTime)).setValue(uniqueID);

        return demoUrl;

    } catch (FirebaseException e) {
        e.printStackTrace();
        Timber.d(e.getMessage());
        return null;
    }
}
 

import com.firebase.client.FirebaseException; //导入依赖的package包/类
public abstract AuthData authenticate(Firebase firebase)
throws FirebaseException, InterruptedException;
 

import com.firebase.client.FirebaseException; //导入依赖的package包/类
@Override
public AuthData authenticate(Firebase firebase) throws FirebaseException {
  return new AuthData(null, 0, null, null, null, null);
}