-
Notifications
You must be signed in to change notification settings - Fork 11
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Added MessagesMovingJobService. Refactored code.| #504
- Loading branch information
Showing
7 changed files
with
241 additions
and
3 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
200 changes: 200 additions & 0 deletions
200
FlowCrypt/src/main/java/com/flowcrypt/email/jobscheduler/MessagesMovingJobService.kt
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,200 @@ | ||
| /* | ||
| * © 2016-2019 FlowCrypt Limited. Limitations apply. Contact [email protected] | ||
| * Contributors: DenBond7 | ||
| */ | ||
|
|
||
| package com.flowcrypt.email.jobscheduler | ||
|
|
||
| import android.app.job.JobInfo | ||
| import android.app.job.JobParameters | ||
| import android.app.job.JobScheduler | ||
| import android.app.job.JobService | ||
| import android.content.ComponentName | ||
| import android.content.Context | ||
| import android.os.AsyncTask | ||
| import android.util.Log | ||
| import com.flowcrypt.email.api.email.FoldersManager | ||
| import com.flowcrypt.email.api.email.protocol.OpenStoreHelper | ||
| import com.flowcrypt.email.database.MessageState | ||
| import com.flowcrypt.email.database.dao.source.AccountDao | ||
| import com.flowcrypt.email.database.dao.source.AccountDaoSource | ||
| import com.flowcrypt.email.database.dao.source.imap.MessageDaoSource | ||
| import com.flowcrypt.email.util.LogsUtil | ||
| import com.flowcrypt.email.util.exception.ExceptionUtil | ||
| import com.flowcrypt.email.util.exception.FolderNotAvailableException | ||
| import com.sun.mail.imap.IMAPFolder | ||
| import java.lang.ref.WeakReference | ||
| import javax.mail.Folder | ||
| import javax.mail.Message | ||
| import javax.mail.Session | ||
| import javax.mail.Store | ||
|
|
||
| /** | ||
| * This [JobService] moves messages from one folder to another one (archiving, deleting, total | ||
| * deleting and etc). | ||
| * | ||
| * @author Denis Bondarenko | ||
| * Date: 10/9/19 | ||
| * Time: 7:05 PM | ||
| * E-mail: [email protected] | ||
| */ | ||
| class MessagesMovingJobService : JobService() { | ||
|
|
||
| override fun onCreate() { | ||
| super.onCreate() | ||
| LogsUtil.d(TAG, "onCreate") | ||
| } | ||
|
|
||
| override fun onDestroy() { | ||
| super.onDestroy() | ||
| LogsUtil.d(TAG, "onDestroy") | ||
| } | ||
|
|
||
| override fun onStartJob(jobParameters: JobParameters): Boolean { | ||
| LogsUtil.d(TAG, "onStartJob") | ||
| MoveMessagesAsyncTask(this).execute(jobParameters) | ||
| return true | ||
| } | ||
|
|
||
| override fun onStopJob(jobParameters: JobParameters): Boolean { | ||
| LogsUtil.d(TAG, "onStopJob") | ||
| jobFinished(jobParameters, true) | ||
| return false | ||
| } | ||
|
|
||
| /** | ||
| * This is an implementation of [AsyncTask] which sends the outgoing messages. | ||
| */ | ||
| private class MoveMessagesAsyncTask internal constructor(jobService: MessagesMovingJobService) | ||
| : AsyncTask<JobParameters, Boolean, JobParameters>() { | ||
| private val weakRef: WeakReference<MessagesMovingJobService> = WeakReference(jobService) | ||
|
|
||
| private var sess: Session? = null | ||
| private var store: Store? = null | ||
| private var isFailed: Boolean = false | ||
|
|
||
| override fun doInBackground(vararg params: JobParameters): JobParameters { | ||
| LogsUtil.d(TAG, "doInBackground") | ||
| try { | ||
| if (weakRef.get() != null) { | ||
| val context = weakRef.get()?.applicationContext | ||
| val account = AccountDaoSource().getActiveAccountInformation(context) | ||
| val msgDaoSource = MessageDaoSource() | ||
|
|
||
| if (context != null && account != null) { | ||
| val candidatesForArchiving = msgDaoSource.getMsgsWithState(context, account.email, | ||
| MessageState.PENDING_ARCHIVING) | ||
|
|
||
| if (candidatesForArchiving.isNotEmpty()) { | ||
| sess = OpenStoreHelper.getAccountSess(context, account) | ||
| store = OpenStoreHelper.openStore(context, account, sess!!) | ||
| } | ||
|
|
||
| if (candidatesForArchiving.isNotEmpty()) { | ||
| archiveMsgs(context, account, msgDaoSource, store!!) | ||
| } | ||
|
|
||
| store?.close() | ||
| } | ||
| } | ||
|
|
||
| publishProgress(false) | ||
| } catch (e: Exception) { | ||
| e.printStackTrace() | ||
| publishProgress(true) | ||
| } | ||
|
|
||
| return params[0] | ||
| } | ||
|
|
||
| override fun onPostExecute(jobParameters: JobParameters) { | ||
| LogsUtil.d(TAG, "onPostExecute") | ||
| try { | ||
| weakRef.get()?.jobFinished(jobParameters, isFailed) | ||
| } catch (e: NullPointerException) { | ||
| e.printStackTrace() | ||
| } | ||
|
|
||
| } | ||
|
|
||
| override fun onProgressUpdate(vararg values: Boolean?) { | ||
| super.onProgressUpdate(*values) | ||
| isFailed = values[0] ?: true | ||
| } | ||
|
|
||
| fun archiveMsgs(context: Context, account: AccountDao, msgDaoSource: MessageDaoSource, store: Store) { | ||
| val foldersManager = FoldersManager.fromDatabase(context, account.email) | ||
| val inboxFolder = foldersManager.findInboxFolder() ?: return | ||
| val allMsgsFolder = foldersManager.folderAll ?: return | ||
|
|
||
| val srcFolder = store.getFolder(inboxFolder.fullName) as IMAPFolder | ||
| val destFolder = store.getFolder(allMsgsFolder.fullName) as IMAPFolder | ||
|
|
||
| if (!srcFolder.exists()) { | ||
| throw FolderNotAvailableException("The invalid source folder: \"${srcFolder}\"") | ||
| } | ||
|
|
||
| srcFolder.open(Folder.READ_WRITE) | ||
|
|
||
| if (!destFolder.exists()) { | ||
| throw FolderNotAvailableException("The invalid destination folder: \"$destFolder\"") | ||
| } | ||
|
|
||
| destFolder.open(Folder.READ_WRITE) | ||
|
|
||
| while (true) { | ||
| val candidatesForArchiving = msgDaoSource.getMsgsWithState(context, account.email, | ||
| MessageState.PENDING_ARCHIVING) | ||
|
|
||
| if (candidatesForArchiving.isEmpty()) { | ||
| break | ||
| } else { | ||
| val uidList = candidatesForArchiving.map { it.uid.toLong() } | ||
| val msgs: List<Message> = srcFolder.getMessagesByUID(uidList.toLongArray()).filterNotNull() | ||
|
|
||
| if (msgs.isNotEmpty()) { | ||
| srcFolder.moveMessages(msgs.toTypedArray(), destFolder) | ||
| msgDaoSource.deleteMsgsByUID(context, account.email, inboxFolder.fullName, uidList) | ||
| } | ||
| } | ||
| } | ||
|
|
||
| destFolder.close(false) | ||
| srcFolder.close(false) | ||
| } | ||
| } | ||
|
|
||
| companion object { | ||
|
|
||
| private val TAG = MessagesMovingJobService::class.java.simpleName | ||
|
|
||
| @JvmStatic | ||
| fun schedule(context: Context?) { | ||
| context ?: return | ||
|
|
||
| val jobInfoBuilder = JobInfo.Builder(JobIdManager.JOB_TYPE_MOVE_MESSAGES, | ||
| ComponentName(context, MessagesMovingJobService::class.java)) | ||
| .setRequiredNetworkType(JobInfo.NETWORK_TYPE_ANY) | ||
| .setPersisted(true) | ||
|
|
||
| val scheduler = context.getSystemService(Context.JOB_SCHEDULER_SERVICE) as JobScheduler | ||
|
|
||
| for (jobInfo in scheduler.allPendingJobs) { | ||
| if (jobInfo.id == JobIdManager.JOB_TYPE_MOVE_MESSAGES) { | ||
| //skip schedule a new job if we already have another one | ||
| LogsUtil.d(TAG, "A job has already scheduled! Skip scheduling a new job.") | ||
| return | ||
| } | ||
| } | ||
|
|
||
| val result = scheduler.schedule(jobInfoBuilder.build()) | ||
| if (result == JobScheduler.RESULT_SUCCESS) { | ||
| LogsUtil.d(TAG, "A job has scheduled successfully") | ||
| } else { | ||
| val errorMsg = "Error. Can't schedule a job" | ||
| Log.e(TAG, errorMsg) | ||
| ExceptionUtil.handleError(IllegalStateException(errorMsg)) | ||
| } | ||
| } | ||
| } | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters