Debug

src/org/thoughtcrime/securesms/jobs/PushDecryptJob.java

@@ -279,6 +279,10 @@ public class PushDecryptJob extends BaseJob implements InjectableType {
           MultiDeviceProtocol.handleUnlinkingRequestIfNeeded(context, content);
         } else {
 
+          if (message.getClosedGroupUpdate().isPresent()) {
+            ClosedGroupsProtocol.handleSharedSenderKeysUpdate(context, message.getClosedGroupUpdate().get(), content.getSender());
+          }
+
           if (message.isEndSession()) {
             handleEndSessionMessage(content, smsMessageId);
           } else if (message.isGroupUpdate()) {

src/org/thoughtcrime/securesms/jobs/PushReceivedJob.java

@@ -36,7 +36,8 @@ public abstract class PushReceivedJob extends BaseJob {
 
         if (envelope.isReceipt()) {
           handleReceipt(envelope);
-        } else if (envelope.isPreKeySignalMessage() || envelope.isSignalMessage() || envelope.isUnidentifiedSender() || envelope.isFallbackMessage()) {
+        } else if (envelope.isPreKeySignalMessage() || envelope.isSignalMessage()
+            || envelope.isUnidentifiedSender() || envelope.isFallbackMessage() || envelope.isClosedGroupCiphertext()) {
           handleMessage(envelope, isPushNotification);
         } else {
           Log.w(TAG, "Received envelope of unknown type: " + envelope.getType());

src/org/thoughtcrime/securesms/loki/api/ClosedGroupPoller.kt

@@ -59,7 +59,7 @@ class ClosedGroupPoller private constructor(private val context: Context, privat
     // region Private API
     private fun poll() {
         if (!isPolling) { return }
-        val publicKeys = database.getAllClosedGroupPublicKeys()
+        val publicKeys = database.getAllClosedGroupPublicKeys().map { "05$it" }
         publicKeys.forEach { publicKey ->
             SwarmAPI.shared.getSwarm(publicKey).bind { swarm ->
                 val snode = swarm.getRandomElementOrNull() ?: throw InsufficientSnodesException() // Should be cryptographically secure

src/org/thoughtcrime/securesms/loki/database/SharedSenderKeysDatabase.kt

@@ -9,6 +9,7 @@ import org.thoughtcrime.securesms.util.Hex
 import org.whispersystems.signalservice.loki.protocol.closedgroups.ClosedGroupRatchet
 import org.whispersystems.signalservice.loki.protocol.closedgroups.ClosedGroupSenderKey
 import org.whispersystems.signalservice.loki.protocol.closedgroups.SharedSenderKeysDatabaseProtocol
+import org.whispersystems.signalservice.loki.utilities.PublicKeyValidation
 
 class SharedSenderKeysDatabase(context: Context, helper: SQLCipherOpenHelper) : Database(context, helper), SharedSenderKeysDatabaseProtocol {
 
@@ -105,6 +106,7 @@ class SharedSenderKeysDatabase(context: Context, helper: SQLCipherOpenHelper) :
     // endregion
 
     override fun isSSKBasedClosedGroup(groupPublicKey: String): Boolean {
+        if (!PublicKeyValidation.isValid(groupPublicKey)) { return false }
         return getAllClosedGroupPublicKeys().contains(groupPublicKey)
     }
     // endregion

src/org/thoughtcrime/securesms/loki/protocol/ClosedGroupsProtocol.kt

@@ -180,6 +180,7 @@ object ClosedGroupsProtocol {
         ApplicationContext.getInstance(context).jobManager.add(job)
     }
 
+    @JvmStatic
     public fun handleSharedSenderKeysUpdate(context: Context, closedGroupUpdate: SignalServiceProtos.ClosedGroupUpdate, senderPublicKey: String) {
         when (closedGroupUpdate.type) {
             SignalServiceProtos.ClosedGroupUpdate.Type.NEW -> handleNewClosedGroup(context, closedGroupUpdate)