From fb8b1467032138c92396c68a1be9768d37f0ce7e Mon Sep 17 00:00:00 2001
From: 0x330a <92654767+0x330a@users.noreply.github.com>
Date: Wed, 25 Oct 2023 12:15:01 +1100
Subject: [PATCH] feat: add scheduling invite jobs and handling update config
 syncs

---
 .../java/org/thoughtcrime/securesms/database/Storage.kt     | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/app/src/main/java/org/thoughtcrime/securesms/database/Storage.kt b/app/src/main/java/org/thoughtcrime/securesms/database/Storage.kt
index b9b50ed79..0c4ba8a68 100644
--- a/app/src/main/java/org/thoughtcrime/securesms/database/Storage.kt
+++ b/app/src/main/java/org/thoughtcrime/securesms/database/Storage.kt
@@ -27,6 +27,7 @@ import org.session.libsession.messaging.jobs.AttachmentUploadJob
 import org.session.libsession.messaging.jobs.BackgroundGroupAddJob
 import org.session.libsession.messaging.jobs.ConfigurationSyncJob
 import org.session.libsession.messaging.jobs.GroupAvatarDownloadJob
+import org.session.libsession.messaging.jobs.InviteContactJob
 import org.session.libsession.messaging.jobs.Job
 import org.session.libsession.messaging.jobs.JobQueue
 import org.session.libsession.messaging.jobs.MessageReceiveJob
@@ -1025,6 +1026,10 @@ open class Storage(
             setRecipientApprovedMe(groupRecipient, true)
             setRecipientApproved(groupRecipient, true)
             pollerFactory.updatePollers()
+            members.forEach { contact ->
+                val job = InviteContactJob(group.groupSessionId.hexString(), contact.sessionID)
+                JobQueue.shared.add(job)
+            }
             return Optional.of(groupRecipient)
         } catch (e: Exception) {
             Log.e("Group Config", e)
@@ -1237,6 +1242,7 @@ open class Storage(
             groupMembers.erase(member)
         }
         configFactory.persistGroupConfigDump(groupMembers, closedGroup, SnodeAPI.nowWithOffset)
+        ConfigurationMessageUtilities.forceSyncConfigurationNowIfNeeded(Destination.ClosedGroup(closedGroup.hexString()))
         groupMembers.close()
     }