feat: open group attachment and message processing

app/src/main/java/org/thoughtcrime/securesms/database/Storage.kt

@@ -576,6 +576,13 @@ class Storage(context: Context, helper: SQLCipherOpenHelper) : Database(context,
         return if (threadID < 0) null else threadID
     }
 
+    override fun getThreadIdForMms(mmsId: Long): Long {
+        val mmsDb = DatabaseFactory.getMmsDatabase(context)
+        val cursor = mmsDb.getMessage(mmsId)
+        val reader = mmsDb.readerFor(cursor)
+        return reader.current.threadId
+    }
+
     override fun getSessionRequestSentTimestamp(publicKey: String): Long? {
         return DatabaseFactory.getLokiAPIDatabase(context).getSessionRequestSentTimestamp(publicKey)
     }

app/src/main/java/org/thoughtcrime/securesms/loki/api/PublicChatManager.kt

@@ -110,7 +110,7 @@ class PublicChatManager(private val context: Context) {
   fun addChat(server: String, room: String, info: OpenGroupAPIV2.Info, publicKey: String): OpenGroupV2 {
     val chat = OpenGroupV2(server, room, info.name, publicKey)
     var threadID = GroupManager.getOpenGroupThreadID(chat.id, context)
-    var profilePicture: Bitmap? = null
+    val profilePicture: Bitmap?
     if (threadID < 0) {
         val profilePictureAsByteArray = try {
           OpenGroupAPIV2.downloadOpenGroupProfilePicture(info.id,server).get()

libsession/src/main/java/org/session/libsession/messaging/StorageProtocol.kt

@@ -136,6 +136,7 @@ interface StorageProtocol {
     fun getOrCreateThreadIdFor(address: Address): Long
     fun getOrCreateThreadIdFor(publicKey: String, groupPublicKey: String?, openGroupID: String?): Long
     fun getThreadIdFor(address: Address): Long?
+    fun getThreadIdForMms(messageId: Long): Long
 
     // Session Request
     fun getSessionRequestSentTimestamp(publicKey: String): Long?

libsession/src/main/java/org/session/libsession/messaging/jobs/AttachmentDownloadJob.kt

@@ -53,15 +53,23 @@ class AttachmentDownloadJob(val attachmentID: Long, val databaseMessageID: Long)
             messageDataProvider.setAttachmentState(AttachmentState.STARTED, attachmentID, this.databaseMessageID)
             val tempFile = createTempFile()
 
-            FileServerAPI.shared.downloadFile(tempFile, attachment.url, MAX_ATTACHMENT_SIZE, null)
+            val threadId = MessagingConfiguration.shared.storage.getThreadIdForMms(databaseMessageID)
+            val openGroupV2 = MessagingConfiguration.shared.storage.getV2OpenGroup(threadId.toString())
 
-            // DECRYPTION
+            val isOpenGroupV2 = false
+            if (!isOpenGroupV2) {
+                FileServerAPI.shared.downloadFile(tempFile, attachment.url, MAX_ATTACHMENT_SIZE, null)
 
-            // Assume we're retrieving an attachment for an open group server if the digest is not set
+                // DECRYPTION
-            val stream = if (attachment.digest?.size ?: 0 == 0 || attachment.key.isNullOrEmpty()) FileInputStream(tempFile)
-            else AttachmentCipherInputStream.createForAttachment(tempFile, attachment.size, Base64.decode(attachment.key), attachment.digest)
 
-            messageDataProvider.insertAttachment(databaseMessageID, attachment.attachmentId, stream)
+                // Assume we're retrieving an attachment for an open group server if the digest is not set
+                val stream = if (attachment.digest?.size ?: 0 == 0 || attachment.key.isNullOrEmpty()) FileInputStream(tempFile)
+                else AttachmentCipherInputStream.createForAttachment(tempFile, attachment.size, Base64.decode(attachment.key), attachment.digest)
+
+                messageDataProvider.insertAttachment(databaseMessageID, attachment.attachmentId, stream)
+            } else {
+//                val bytes = OpenGroupAPIV2.download()
+            }
 
             tempFile.delete()
             handleSuccess()

libsession/src/main/java/org/session/libsession/messaging/opengroups/OpenGroupAPIV2.kt

@@ -350,6 +350,10 @@ object OpenGroupAPIV2 {
         val storage = MessagingConfiguration.shared.storage
         storage.setOpenGroupPublicKey(DEFAULT_SERVER, DEFAULT_SERVER_PUBLIC_KEY)
         return getAllRooms(DEFAULT_SERVER).map { groups ->
+            val earlyGroups = groups.map { group ->
+                DefaultGroup(group.id, group.name, null)
+            }
+            defaultRooms.tryEmit(earlyGroups) // TODO: take into account cached w/ images groups
             val images = groups.map { group ->
                 group.id to downloadOpenGroupProfilePicture(group.id, DEFAULT_SERVER)
             }.toMap()