Mastodon
/
fedilab-Android-App
mirror of https://codeberg.org/tom79/Fedilab
1
0
Fork 0
Code Issues Releases Wiki Activity

Prepares jobs for streaming

This commit is contained in:
tom79 2017-08-28 15:33:05 +02:00
parent d222ab3ff2
commit 182a391b72
2 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
app/src/main/java/fr/gouv/etalab/mastodon/activities/MainApplication.java
View File

@ -17,8 +17,7 @@ import android.app.Application;
import android.os.StrictMode;
import com.evernote.android.job.JobManager;
import fr.gouv.etalab.mastodon.jobs.ApplicationJob;
import fr.gouv.etalab.mastodon.jobs.HomeTimelineSyncJob;
import fr.gouv.etalab.mastodon.jobs.NotificationsSyncJob;
import fr.gouv.etalab.mastodon.jobs.StreamingSyncJob;
/**
* Created by Thomas on 29/04/2017.
@ -33,8 +32,7 @@ public class MainApplication extends Application{
super.onCreate();
JobManager.create(this).addJobCreator(new ApplicationJob());
JobManager.instance().getConfig().setVerbose(false);
NotificationsSyncJob.schedule(false);
HomeTimelineSyncJob.schedule(false);
StreamingSyncJob.schedule(false);
StrictMode.VmPolicy.Builder builder = new StrictMode.VmPolicy.Builder();
StrictMode.setVmPolicy(builder.build());
}

6
app/src/main/java/fr/gouv/etalab/mastodon/jobs/SteamingSyncJob.java → app/src/main/java/fr/gouv/etalab/mastodon/jobs/StreamingSyncJob.java
View File

@ -70,7 +70,7 @@ import static fr.gouv.etalab.mastodon.helper.Helper.notify_user;
* Notifications refresh job
*/
public class SteamingSyncJob extends Job implements OnRetrieveStreamingInterface {
public class StreamingSyncJob extends Job implements OnRetrieveStreamingInterface {
static final String STREAMING = "job_streaming";
private String message;
@ -93,7 +93,7 @@ public class SteamingSyncJob extends Job implements OnRetrieveStreamingInterface
return jobRequests.iterator().next().getJobId();
}
return new JobRequest.Builder(SteamingSyncJob.STREAMING)
return new JobRequest.Builder(StreamingSyncJob.STREAMING)
.setPeriodic(TimeUnit.MINUTES.toMillis(Helper.MINUTES_BETWEEN_NOTIFICATIONS_REFRESH), TimeUnit.MINUTES.toMillis(5))
.setPersisted(true)
.setUpdateCurrent(updateCurrent)
@ -133,7 +133,7 @@ public class SteamingSyncJob extends Job implements OnRetrieveStreamingInterface
return;
//Retrieve users in db that owner has.
for (Account account: accounts) {
new StreamingUserAsyncTask(account.getInstance(), account.getToken(), account.getAcct(), account.getId(), SteamingSyncJob.this).executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR);
new StreamingUserAsyncTask(account.getInstance(), account.getToken(), account.getAcct(), account.getId(), StreamingSyncJob.this).executeOnExecutor(AsyncTask.THREAD_POOL_EXECUTOR);
}
}
}