Remove deprecated message receiving code (#1772)

Author: SessionHero01

app/src/main/java/org/session/libsession/messaging/jobs/BatchMessageReceiveJob.kt

@@ -38,7 +38,6 @@ class JobQueue : JobDelegate {
         for (job in channel) {
             if (!isActive) break
             val communityAddress = when (job) {
-                is BatchMessageReceiveJob -> job.fromCommunity?.address
                 is OpenGroupDeleteJob -> job.address?.address
                 is TrimThreadJob -> job.communityAddress?.address
                 else -> null
@@ -132,10 +131,8 @@ class JobQueue : JobDelegate {
                     is OpenGroupDeleteJob -> {
                         openGroupQueue.send(job)
                     }
-                    is TrimThreadJob,
-                    is BatchMessageReceiveJob -> {
-                        if ((job is BatchMessageReceiveJob && job.fromCommunity != null)
-                            || (job is TrimThreadJob && job.communityAddress != null)) {
+                    is TrimThreadJob -> {
+                        if (job.communityAddress != null) {
                             openGroupQueue.send(job)
                         } else {
                             rxQueue.send(job)
@@ -223,7 +220,6 @@ class JobQueue : JobDelegate {
             AttachmentDownloadJob.KEY,
             MessageSendJob.KEY,
             NotifyPNServerJob.KEY,
-            BatchMessageReceiveJob.KEY,
             OpenGroupDeleteJob.KEY,
             InviteContactsJob.KEY,
         )
@@ -249,16 +245,6 @@ class JobQueue : JobDelegate {
             return
         }
 
-        // Batch message receive job, re-queue non-permanently failed jobs
-        if (job is BatchMessageReceiveJob && job.failureCount <= 0) {
-            val replacementParameters = job.failures.toList()
-            if (replacementParameters.isNotEmpty()) {
-                val newJob = job.recreateWithNewMessages(replacementParameters)
-                newJob.failureCount = job.failureCount + 1
-                add(newJob)
-            }
-        }
-
         // Regular job failure
         job.failureCount += 1
 

app/src/main/java/org/session/libsession/messaging/jobs/JobQueue.kt

@@ -5,7 +5,6 @@ import javax.inject.Inject
 class SessionJobManagerFactories @Inject constructor(
     private val attachmentDownloadJobFactory: AttachmentDownloadJob.Factory,
     private val attachmentUploadJobFactory: AttachmentUploadJob.Factory,
-    private val batchFactory: BatchMessageReceiveJob.Factory,
     private val trimThreadFactory: TrimThreadJob.Factory,
     private val messageSendJobFactory: MessageSendJob.Factory,
     private val deleteJobFactory: OpenGroupDeleteJob.Factory,
@@ -19,7 +18,6 @@ class SessionJobManagerFactories @Inject constructor(
             MessageSendJob.KEY to messageSendJobFactory,
             NotifyPNServerJob.KEY to NotifyPNServerJob.DeserializeFactory(),
             TrimThreadJob.KEY to trimThreadFactory,
-            BatchMessageReceiveJob.KEY to batchFactory,
             OpenGroupDeleteJob.KEY to deleteJobFactory,
             InviteContactsJob.KEY to inviteContactsJobFactory,
         )