Fix missing json handling for official communities (#1475)

Author: SessionHero01

app/src/main/java/org/session/libsession/messaging/MessagingModuleConfiguration.kt

@@ -2,6 +2,7 @@ package org.session.libsession.messaging
 
 import android.content.Context
 import dagger.hilt.android.qualifiers.ApplicationContext
+import kotlinx.serialization.json.Json
 import org.session.libsession.database.MessageDataProvider
 import org.session.libsession.database.StorageProtocol
 import org.session.libsession.messaging.groups.GroupManagerV2
@@ -34,6 +35,7 @@ class MessagingModuleConfiguration @Inject constructor(
     val avatarUtils: AvatarUtils,
     val proStatusManager: ProStatusManager,
     val messageSendJobFactory: MessageSendJob.Factory,
+    val json: Json,
 ) {
 
     companion object {

app/src/main/java/org/session/libsession/messaging/open_groups/OpenGroupApi.kt

@@ -10,6 +10,7 @@ import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.flow.MutableSharedFlow
 import kotlinx.serialization.SerialName
 import kotlinx.serialization.Serializable
+import kotlinx.serialization.json.decodeFromStream
 import network.loki.messenger.libsession_util.ED25519
 import network.loki.messenger.libsession_util.Hash
 import network.loki.messenger.libsession_util.util.BlindKeyAPI
@@ -25,7 +26,6 @@ import org.session.libsession.snode.OnionResponse
 import org.session.libsession.snode.SnodeAPI
 import org.session.libsession.snode.utilities.asyncPromise
 import org.session.libsession.snode.utilities.await
-import org.session.libsession.utilities.TextSecurePreferences
 import org.session.libsignal.utilities.AccountId
 import org.session.libsignal.utilities.Base64.encodeBytes
 import org.session.libsignal.utilities.ByteArraySlice
@@ -46,15 +46,6 @@ import kotlin.collections.set
 
 object OpenGroupApi {
     val defaultRooms = MutableSharedFlow<List<DefaultGroup>>(replay = 1)
-    private val hasPerformedInitialPoll = mutableMapOf<String, Boolean>()
-    private var hasUpdatedLastOpenDate = false
-    private val timeSinceLastOpen by lazy {
-        val context = MessagingModuleConfiguration.shared.context
-        val lastOpenDate = TextSecurePreferences.getLastOpenTimeDate(context)
-        val now = System.currentTimeMillis()
-        now - lastOpenDate
-    }
-
     const val defaultServerPublicKey = "a03c383cf63c3c4efe67acc52112a6dd734b3a946b9545f488aaa93da7991238"
     const val legacyServerIP = "116.203.70.33"
     const val legacyDefaultServer = "http://116.203.70.33" // TODO: migrate all references to use new value
@@ -736,18 +727,6 @@ object OpenGroupApi {
         }
     }
 
-    fun getRoomInfo(roomToken: String, server: String): Promise<RoomInfoDetails, Exception> {
-        val request = Request(
-            verb = GET,
-            room = null,
-            server = server,
-            endpoint = Endpoint.Room(roomToken)
-        )
-        return getResponseBody(request).map { response ->
-            JsonUtil.fromJson(response, RoomInfoDetails::class.java)
-        }
-    }
-
     private fun getAllRooms(): Promise<List<RoomInfoDetails>, Exception> {
         val request = Request(
             verb = GET,
@@ -756,10 +735,9 @@ object OpenGroupApi {
             endpoint = Endpoint.Rooms
         )
         return getResponseBody(request, signRequest = false).map { response ->
-            val rawRooms = JsonUtil.fromJson(response, List::class.java) ?: throw Error.ParsingFailed
-            rawRooms.mapNotNull {
-                JsonUtil.fromJson(JsonUtil.toJson(it), RoomInfoDetails::class.java)
-            }
+            MessagingModuleConfiguration.shared.json
+                .decodeFromStream<Array<RoomInfoDetails>>(response.inputStream())
+                .toList()
         }
     }
 
@@ -770,35 +748,6 @@ object OpenGroupApi {
         }
     }
 
-    fun getCapabilitiesAndRoomInfo(
-        room: String,
-        server: String
-    ): Promise<Pair<Capabilities, RoomInfoDetails>, Exception> {
-        val requests = mutableListOf<BatchRequestInfo<*>>(
-            BatchRequestInfo(
-                request = BatchRequest(
-                    method = GET,
-                    path = "/capabilities"
-                ),
-                endpoint = Endpoint.Capabilities,
-                responseType = object : TypeReference<Capabilities>(){}
-            ),
-            BatchRequestInfo(
-                request = BatchRequest(
-                    method = GET,
-                    path = "/room/$room"
-                ),
-                endpoint = Endpoint.Room(room),
-                responseType = object : TypeReference<RoomInfoDetails>(){}
-            )
-        )
-        return sequentialBatch(server, requests).map {
-            val capabilities = it.firstOrNull()?.body as? Capabilities ?: throw Error.ParsingFailed
-            val roomInfo = it.lastOrNull()?.body as? RoomInfoDetails ?: throw Error.ParsingFailed
-            capabilities to roomInfo
-        }
-    }
-
     fun sendDirectMessage(message: String, blindedAccountId: String, server: String): Promise<DirectMessage, Exception> {
         val request = Request(
             verb = POST,