mirror of
https://github.com/k0shk0sh/FastHub.git
synced 2026-02-01 15:56:14 +00:00
96 lines
3.8 KiB
Java
96 lines
3.8 KiB
Java
package com.fastaccess.provider.tasks;
|
|
|
|
import android.app.Notification;
|
|
import android.app.NotificationManager;
|
|
import android.app.PendingIntent;
|
|
import android.content.Context;
|
|
import android.content.Intent;
|
|
import android.support.annotation.NonNull;
|
|
import android.support.annotation.Nullable;
|
|
import android.support.v7.app.NotificationCompat;
|
|
|
|
import com.annimon.stream.Stream;
|
|
import com.fastaccess.R;
|
|
import com.fastaccess.data.dao.LoginModel;
|
|
import com.fastaccess.data.dao.NotificationThreadModel;
|
|
import com.fastaccess.helper.BundleConstant;
|
|
import com.fastaccess.helper.Logger;
|
|
import com.fastaccess.provider.rest.RestProvider;
|
|
import com.firebase.jobdispatcher.Constraint;
|
|
import com.firebase.jobdispatcher.FirebaseJobDispatcher;
|
|
import com.firebase.jobdispatcher.GooglePlayDriver;
|
|
import com.firebase.jobdispatcher.Job;
|
|
import com.firebase.jobdispatcher.JobParameters;
|
|
import com.firebase.jobdispatcher.JobService;
|
|
import com.firebase.jobdispatcher.Lifetime;
|
|
import com.firebase.jobdispatcher.RetryStrategy;
|
|
import com.firebase.jobdispatcher.Trigger;
|
|
|
|
import java.util.List;
|
|
|
|
import rx.schedulers.Schedulers;
|
|
|
|
/**
|
|
* Created by Kosh on 19 Feb 2017, 6:32 PM
|
|
*/
|
|
|
|
public class NotificationJobTask extends JobService {
|
|
private final static String EVERY_30_MINS = "every_30_mins";
|
|
|
|
@Override public boolean onStartJob(JobParameters job) {
|
|
if (LoginModel.getUser() != null) {
|
|
RestProvider.getNotificationService()
|
|
.getNotifications()
|
|
.subscribeOn(Schedulers.io())
|
|
.subscribe(item -> {
|
|
if (item != null) onSave(item.getItems());
|
|
}, throwable -> Logger.e(throwable.getMessage()));
|
|
}
|
|
return false;
|
|
}
|
|
|
|
@Override public boolean onStopJob(JobParameters job) {
|
|
return false;
|
|
}
|
|
|
|
public static void scheduleJob(@NonNull Context context) {
|
|
FirebaseJobDispatcher dispatcher = new FirebaseJobDispatcher(new GooglePlayDriver(context));
|
|
Job.Builder builder = dispatcher
|
|
.newJobBuilder()
|
|
.setTag(EVERY_30_MINS)
|
|
.setRetryStrategy(RetryStrategy.DEFAULT_LINEAR)
|
|
.setLifetime(Lifetime.FOREVER)
|
|
.setRecurring(true)
|
|
.setConstraints(Constraint.ON_ANY_NETWORK)
|
|
.setTrigger(Trigger.executionWindow(10, 30 * 60 /*every 30 seconds*/))
|
|
.setService(NotificationJobTask.class);
|
|
dispatcher.mustSchedule(builder.build());
|
|
}
|
|
|
|
private void onSave(@Nullable List<NotificationThreadModel> notificationThreadModels) {
|
|
if (notificationThreadModels != null) {
|
|
NotificationThreadModel.save(notificationThreadModels)
|
|
.subscribe(() -> onNotifyUser(notificationThreadModels));
|
|
}
|
|
}
|
|
|
|
private void onNotifyUser(@NonNull List<NotificationThreadModel> notificationThreadModels) {
|
|
long count = Stream.of(notificationThreadModels)
|
|
.filter(NotificationThreadModel::isUnread)
|
|
.count();
|
|
Logger.e(count, notificationThreadModels);
|
|
if (count > 0) {
|
|
Context context = getApplicationContext();
|
|
Notification notification = new NotificationCompat.Builder(context)
|
|
.setSmallIcon(R.drawable.ic_announcement)
|
|
.setContentTitle(context.getString(R.string.notifictions))
|
|
.setContentText(context.getString(R.string.unread_notification))
|
|
.setNumber((int) count)
|
|
.addAction(R.drawable.ic_github, context.getString(R.string.open), PendingIntent.getActivity(context, 0, new Intent(),
|
|
PendingIntent.FLAG_UPDATE_CURRENT))
|
|
.build();
|
|
((NotificationManager) context.getSystemService(NOTIFICATION_SERVICE)).notify(BundleConstant.REQUEST_CODE, notification);
|
|
}
|
|
}
|
|
}
|