Skip to content

Commit

Permalink
Merge branch 'feature/remove_fallback_jobs'
Browse files Browse the repository at this point in the history
  • Loading branch information
Zeyad-37 committed Nov 13, 2018
2 parents a7e8b52 + ef13c72 commit a5133af
Show file tree
Hide file tree
Showing 10 changed files with 20 additions and 903 deletions.
52 changes: 0 additions & 52 deletions usecases/src/main/java/com/zeyad/usecases/Extensions.kt
Original file line number Diff line number Diff line change
Expand Up @@ -4,15 +4,7 @@ import android.content.Context
import android.net.ConnectivityManager
import android.net.NetworkInfo
import android.os.Build
import android.os.Bundle
import android.util.Log
import com.firebase.jobdispatcher.Constraint
import com.firebase.jobdispatcher.FirebaseJobDispatcher
import com.firebase.jobdispatcher.Lifetime
import com.firebase.jobdispatcher.RetryStrategy
import com.zeyad.usecases.requests.FileIORequest
import com.zeyad.usecases.requests.PostRequest
import com.zeyad.usecases.services.GenericJobService
import org.json.JSONArray
import org.json.JSONException
import java.util.*
Expand Down Expand Up @@ -83,48 +75,4 @@ fun isNetworkAvailable(context: Context): Boolean {
}
}
return false
}

fun queuePostCore(dispatcher: FirebaseJobDispatcher, postRequest: PostRequest, trailCount: Int) {
val extras = Bundle(3)
extras.putString(GenericJobService.JOB_TYPE, GenericJobService.POST)
extras.putParcelable(GenericJobService.PAYLOAD, postRequest)
extras.putInt(GenericJobService.TRIAL_COUNT, trailCount)
queueCore(dispatcher, extras, postRequest.method, postRequest.onWifi, postRequest.whileCharging)
}

fun queueFileIOCore(dispatcher: FirebaseJobDispatcher, isDownload: Boolean,
fileIORequest: FileIORequest, trailCount: Int) {
val extras = Bundle(3)
extras.putString(GenericJobService.JOB_TYPE, if (isDownload)
GenericJobService.DOWNLOAD_FILE
else
GenericJobService.UPLOAD_FILE)
extras.putParcelable(GenericJobService.PAYLOAD, fileIORequest)
extras.putInt(GenericJobService.TRIAL_COUNT, trailCount)
queueCore(dispatcher, extras, (if (isDownload) "Download" else "Upload") + " file",
fileIORequest.onWifi, fileIORequest.whileCharging)
}

private fun queueCore(dispatcher: FirebaseJobDispatcher, bundle: Bundle, message: String,
isOnWifi: Boolean, whileCharging: Boolean) {
val network = if (isOnWifi) Constraint.ON_UNMETERED_NETWORK else Constraint.ON_ANY_NETWORK
val power = if (whileCharging) Constraint.DEVICE_CHARGING else Constraint.DEVICE_IDLE
try {
dispatcher.mustSchedule(dispatcher.newJobBuilder()
.setService(GenericJobService::class.java)
.setTag(bundle.getString("JOB_TYPE") + System.currentTimeMillis().toString())
.setRecurring(false)
.setLifetime(Lifetime.UNTIL_NEXT_BOOT)
// .setTrigger(Trigger.executionWindow(0, 10))
.setReplaceCurrent(true)
.setRetryStrategy(RetryStrategy.DEFAULT_EXPONENTIAL)
.setExtras(bundle)
.setConstraints(network, power)
.build())
} catch (ignored: Exception) {

}

Log.d("FBJD", "$message request is queued successfully!")
}

This file was deleted.

This file was deleted.

59 changes: 0 additions & 59 deletions usecases/src/main/java/com/zeyad/usecases/services/jobs/FileIO.kt

This file was deleted.

84 changes: 0 additions & 84 deletions usecases/src/main/java/com/zeyad/usecases/services/jobs/Post.kt

This file was deleted.

Loading

0 comments on commit a5133af

Please sign in to comment.