Add pre-release config flag and client version detection

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

@@ -202,4 +202,5 @@ interface StorageProtocol {
     fun getExpirationConfiguration(threadId: Long): ExpirationConfiguration?
     fun addExpirationConfiguration(config: ExpirationConfiguration)
     fun getExpiringMessages(messageIds: LongArray): List<Pair<String, Int>>
+    fun updateDisappearingState(address: String, disappearingState: Recipient.DisappearingState)
 }

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

@@ -1,6 +1,7 @@
 package org.session.libsession.messaging.jobs
 
 import org.session.libsession.messaging.MessagingModuleConfiguration
+import org.session.libsession.messaging.messages.ExpirationConfiguration
 import org.session.libsession.messaging.messages.control.SyncedExpiriesMessage
 import org.session.libsession.messaging.messages.control.SyncedExpiry
 import org.session.libsession.messaging.sending_receiving.MessageSender
@@ -16,6 +17,7 @@ class DisappearingMessagesJob(val messageIds: LongArray = longArrayOf(), val sta
     override val maxFailureCount: Int = 1
 
     override fun execute() {
+        if (!ExpirationConfiguration.isNewConfigEnabled) return
         val userPublicKey = MessagingModuleConfiguration.shared.storage.getUserPublicKey() ?: return
         val module = MessagingModuleConfiguration.shared
         try {

libsession/src/main/java/org/session/libsession/messaging/messages/ExpirationConfiguration.kt

@@ -9,4 +9,7 @@ class ExpirationConfiguration(
     val updatedTimestampMs: Long = 0
 ) {
     val isEnabled = durationSeconds > 0
+    companion object {
+        val isNewConfigEnabled = System.currentTimeMillis() > 1_671_062_400_000 // 15/12/2022
+    }
 }

libsession/src/main/java/org/session/libsession/messaging/messages/control/ExpirationTimerUpdate.kt

@@ -1,6 +1,7 @@
 package org.session.libsession.messaging.messages.control
 
 import org.session.libsession.messaging.MessagingModuleConfiguration
+import org.session.libsession.messaging.messages.ExpirationConfiguration
 import org.session.libsession.messaging.messages.visible.VisibleMessage
 import org.session.libsignal.utilities.Log
 import org.session.libsignal.protos.SignalServiceProtos
@@ -17,7 +18,7 @@ class ExpirationTimerUpdate() : ControlMessage() {
 
     override fun isValid(): Boolean {
         if (!super.isValid()) return false
-        return duration != null
+        return duration != null || ExpirationConfiguration.isNewConfigEnabled
     }
 
     companion object {
@@ -28,7 +29,7 @@ class ExpirationTimerUpdate() : ControlMessage() {
             val isExpirationTimerUpdate = dataMessageProto.flags.and(SignalServiceProtos.DataMessage.Flags.EXPIRATION_TIMER_UPDATE_VALUE) != 0
             if (!isExpirationTimerUpdate) return null
             val syncTarget = dataMessageProto.syncTarget
-            val duration = dataMessageProto.expireTimer
+            val duration = if (proto.hasExpirationTimer()) proto.expirationTimer else dataMessageProto.expireTimer
             return ExpirationTimerUpdate(syncTarget, duration)
         }
     }
@@ -44,14 +45,9 @@ class ExpirationTimerUpdate() : ControlMessage() {
     }
 
     override fun toProto(): SignalServiceProtos.Content? {
-        val duration = duration
-        if (duration == null) {
-            Log.w(TAG, "Couldn't construct expiration timer update proto from: $this")
-            return null
-        }
         val dataMessageProto = SignalServiceProtos.DataMessage.newBuilder()
         dataMessageProto.flags = SignalServiceProtos.DataMessage.Flags.EXPIRATION_TIMER_UPDATE_VALUE
-        dataMessageProto.expireTimer = duration
+        duration?.let { dataMessageProto.expireTimer = it }
         // Sync target
         if (syncTarget != null) {
             dataMessageProto.syncTarget = syncTarget

libsession/src/main/java/org/session/libsession/messaging/sending_receiving/ReceivedMessageHandler.kt

@@ -39,6 +39,7 @@ import org.session.libsession.utilities.ProfileKeyUtil
 import org.session.libsession.utilities.SSKEnvironment
 import org.session.libsession.utilities.TextSecurePreferences
 import org.session.libsession.utilities.recipients.Recipient
+import org.session.libsession.utilities.recipients.Recipient.DisappearingState
 import org.session.libsignal.crypto.ecc.DjbECPrivateKey
 import org.session.libsignal.crypto.ecc.DjbECPublicKey
 import org.session.libsignal.crypto.ecc.ECKeyPair
@@ -83,8 +84,10 @@ fun MessageReceiver.handle(message: Message, proto: SignalServiceProtos.Content,
 }
 
 fun updateExpirationConfigurationIfNeeded(message: Message, proto: SignalServiceProtos.Content, openGroupID: String?) {
-    if (!proto.hasLastDisappearingMessageChangeTimestamp()) return
     val storage = MessagingModuleConfiguration.shared.storage
+    val disappearingState = if (proto.hasExpirationTimer()) DisappearingState.UPDATED else DisappearingState.LEGACY
+    storage.updateDisappearingState(message.sender!!, disappearingState)
+    if (!proto.hasLastDisappearingMessageChangeTimestamp() || !ExpirationConfiguration.isNewConfigEnabled) return
     val threadID = storage.getOrCreateThreadIdFor(message.sender!!, message.groupPublicKey, openGroupID)
     if (threadID <= 0) return
     val localConfig = storage.getExpirationConfiguration(threadID)

libsession/src/main/java/org/session/libsession/utilities/recipients/Recipient.java

@@ -86,6 +86,7 @@ public class Recipient implements RecipientModifiedListener {
   private           boolean              blocked               = false;
   private           boolean              approved              = false;
   private           boolean              approvedMe            = false;
+  private           DisappearingState    disappearingState     = DisappearingState.LEGACY;
   private           VibrateState         messageVibrate        = VibrateState.DEFAULT;
   private           VibrateState         callVibrate           = VibrateState.DEFAULT;
   private           int                  expireMessages        = 0;
@@ -653,6 +654,18 @@ public class Recipient implements RecipientModifiedListener {
     notifyListeners();
   }
 
+  public synchronized DisappearingState getDisappearingState() {
+    return disappearingState;
+  }
+
+  public void setDisappearingState(DisappearingState disappearingState) {
+    synchronized (this) {
+      this.disappearingState = disappearingState;
+    }
+
+    notifyListeners();
+  }
+
   public synchronized RegisteredState getRegistered() {
     if      (isPushGroupRecipient()) return RegisteredState.REGISTERED;
 
@@ -787,6 +800,24 @@ public class Recipient implements RecipientModifiedListener {
     }
   }
 
+  public enum DisappearingState {
+    LEGACY(0), UPDATED(1);
+
+    private final int id;
+
+    DisappearingState(int id) {
+      this.id = id;
+    }
+
+    public int getId() {
+      return id;
+    }
+
+    public static DisappearingState fromId(int id) {
+      return values()[id];
+    }
+  }
+
   public enum RegisteredState {
     UNKNOWN(0), REGISTERED(1), NOT_REGISTERED(2);