I am using MVVM and enqueuing a worker from my Repository. The workers job is just to insert some data into the database but i would like to get access to some Output data when the background task is finished so i can verify if the data went inside the Database without issue or not. I tried using WorkInfo.State or get the data with getOutputData but it doesn't seem to work for some reason. Any ideas on how i can achieve this?
Here is the code for reference:
AddWorkoutWorker.java
public class AddWorkoutWorker extends Worker {
public static final String WORK_WORKOUT_NAME = "workout";
public static final String WORK_WORKOUT_TYPE = "type";
public static final String WORK_FAILURE_TAG = "failed";
public static final String WORK_SUCCESS_TAG = "success";
private static final String WORKER_TAG = "Worker Tag";
private WorkoutDAO workoutDAO;
private AppDatabase database;
Boolean workSuccess;
//Worker constructor
public AddWorkoutWorker(@NonNull Context context, @NonNull WorkerParameters workerParams) {
super(context, workerParams);
database = AppDatabase.getInstance(context);
workoutDAO = database.workoutDAO();
}
@NonNull
@Override
public Result doWork() {
//Gets input data
Data inputData = getInputData();
String workoutName = inputData.getString(WORK_WORKOUT_NAME);
String workoutType = inputData.getString(WORK_WORKOUT_TYPE);
if (workoutName != null && workoutType != null){
//Inserts item in database through DAO
Log.d(WORKER_TAG,"Worker data passed: "+workoutName + workoutType);
Workout workout = new Workout(workoutName, workoutType);
workoutDAO.insertSingleWorkout(workout);
}else{
//Returns false if the worker doesn't add the item to the database
workSuccess = false;
Data output = new Data.Builder()
.putBoolean(WORK_FAILURE_TAG,workSuccess)
.build();
return Result.failure(output);
}
//Returns true if the worker adds the item to the database
workSuccess = true;
Data output = new Data.Builder()
.putBoolean(WORK_SUCCESS_TAG, workSuccess)
.build();
return Result.success(output);
}
}
AddWorkoutRepository.java
public class AddWorkoutRepository{
private static final String REPOSITORY_TAG = "REPOSITORY TAG";
public static final String WORKER_QUEUE_TAG = "Importing Single Workout";
public WorkoutDAO workoutDAO;
private final WorkManager workManager;
private AppDatabase database;
//private LiveData<List<Workout>> workouts;
public AddWorkoutRepository(Application application){
database = AppDatabase.getInstance(application);
workoutDAO = database.workoutDAO();
workManager = WorkManager.getInstance(application.getApplicationContext());
//workouts = workoutDAO.getAllWorkoutsLiveData();
}
/*public LiveData<List<Workout>> getAllWorkouts(){
return workouts;
}*/
public void insertWorkout(Workout workout){
String workoutName = workout.getWorkoutName();
String workoutType = workout.getWorkoutType();
Log.d(REPOSITORY_TAG, "Insert Values passed: "+workoutName + workoutType);
Data data = new Data.Builder()
.putString(WORK_WORKOUT_NAME, workoutName)
.putString(WORK_WORKOUT_TYPE, workoutType)
.build();
OneTimeWorkRequest importDataRequest = new OneTimeWorkRequest.Builder(AddWorkoutWorker.class)
.setInputData(data)
.addTag(WORKER_QUEUE_TAG)
.build();
workManager.enqueue(importDataRequest);
Log.d(REPOSITORY_TAG, "After work manager task OK");
}
}