Fix session request handling bug

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

@@ -505,7 +505,7 @@ public class PushDecryptJob extends BaseJob implements InjectableType {
     }
 
     if (threadId != null) {
-      SessionManagementProtocol.handleEndSessionMessage(context, content);
+      SessionManagementProtocol.handleEndSessionMessageIfNeeded(context, content);
       MessageNotifier.updateNotification(context, threadId);
     }
   }

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

@@ -75,13 +75,15 @@ object SessionManagementProtocol {
 
     @JvmStatic
     fun handleSessionRequestIfNeeded(context: Context, content: SignalServiceContent) {
+        if (!content.dataMessage.isPresent || !content.dataMessage.get().isSessionRequest) { return }
         // Auto-accept all session requests
         val ephemeralMessage = EphemeralMessage.create(content.sender)
         ApplicationContext.getInstance(context).jobManager.add(PushEphemeralMessageSendJob(ephemeralMessage))
     }
 
     @JvmStatic
-    fun handleEndSessionMessage(context: Context, content: SignalServiceContent) {
+    fun handleEndSessionMessageIfNeeded(context: Context, content: SignalServiceContent) {
+        if (!content.dataMessage.isPresent || !content.dataMessage.get().isEndSession) { return }
         // TODO: Notify the user
         val sessionStore = TextSecureSessionStore(context)
         val lokiThreadDB = DatabaseFactory.getLokiThreadDatabase(context)