UserCoursesLoader.java

package com.uwflow.flow_android.loaders;

import android.content.Context;
import android.support.v4.app.Fragment;
import android.support.v4.content.LocalBroadcastManager;
import android.util.Log;
import com.crashlytics.android.Crashlytics;
import com.j256.ormlite.dao.Dao;
import com.uwflow.flow_android.constant.Constants;
import com.uwflow.flow_android.dao.FlowDatabaseHelper;
import com.uwflow.flow_android.db_object.Course;
import com.uwflow.flow_android.db_object.UserCourse;
import com.uwflow.flow_android.db_object.UserCourseDetail;
import com.uwflow.flow_android.fragment.ProfileFragment;
import com.uwflow.flow_android.network.FlowApiRequestCallbackAdapter;
import com.uwflow.flow_android.network.FlowApiRequests;

import java.sql.SQLException;
import java.util.ArrayList;
import java.util.List;

public class UserCoursesLoader extends FlowAbstractDataLoader<UserCourseDetail> {
    private static final String TAG = UserCoursesLoader.class.getSimpleName();

    private LoaderUpdateReceiver courseLoadedReceiver;
    public UserCoursesLoader(Context context, FlowDatabaseHelper flowDatabaseHelper, Fragment baseFragment) {
        super(context, flowDatabaseHelper, baseFragment);
    }

    protected void registerReceiver(){
        super.registerReceiver();
        // Start watching for changes in the app data.
        if (courseLoadedReceiver == null) {
            courseLoadedReceiver = new LoaderUpdateReceiver(this, Constants.BroadcastActionId.PROFILE_DATABASE_USER_COURSE_LOADED);
        }
    }

    protected void unregisterReceiver(){
        super.unregisterReceiver();
        if (courseLoadedReceiver != null) {
            LocalBroadcastManager.getInstance(this.getContext().getApplicationContext()).unregisterReceiver(courseLoadedReceiver);
            courseLoadedReceiver = null;
        }
    }

    @Override
    protected UserCourseDetail loadDelegate() {
        //Check if we are loading the logged in user's courseDetail or user friend's course detail
        // For all user friend data we fetch from the network
        if (mBaseFragment != null && mBaseFragment instanceof ProfileFragment) {
            final ProfileFragment profileFragment = (ProfileFragment) mBaseFragment;
            if (profileFragment != null && profileFragment.getProfileID() != null) {
                // It seems like async client must be run from the Main ui thread
                mBaseFragment.getActivity().runOnUiThread(new Runnable() {
                    @Override
                    public void run() {
                        FlowApiRequests.getUserCourses(
                                profileFragment.getProfileID(),
                                new FlowApiRequestCallbackAdapter() {
                                    @Override
                                    public void getUserCoursesCallback(UserCourseDetail userCourseDetail) {
                                        if (userCourseDetail == null) return;
                                        profileFragment.setUserCourses(userCourseDetail);
                                    }

                                    @Override
                                    public void onFailure(String error) {
                                        Crashlytics.log(Log.ERROR, TAG,
                                                "Get user courses API request failed: " + error);
                                    }
                                });
                    }
                });
                return null;
            }
        }

        UserCourseDetail userCourseDetail = new UserCourseDetail();
        try {
            List<Course> courses = new ArrayList<Course>();
            Dao<Course, String> userCourseDao = flowDatabaseHelper.getUserCourseDao();
            courses = userCourseDao.queryForAll();
            userCourseDetail.setCourses(courses);
            List<UserCourse> userCourses = new ArrayList<UserCourse>();
            Dao<UserCourse, String> userCourseStringDao = flowDatabaseHelper.getUserCourseExtraDao();
            userCourses = userCourseStringDao.queryForAll();
            userCourseDetail.setUserCourses(userCourses);
        } catch (SQLException e) {
            e.printStackTrace();
            Crashlytics.logException(e);
        }
        return userCourseDetail;
    }
}