git » sdk » commit 6265c97

Don't throw out OMEMO messages from MAM

author Stephen Paul Weber
2026-02-11 14:28:26 UTC
committer Stephen Paul Weber
2026-02-11 14:28:26 UTC
parent 3f2723f064d69b22f549b80dbd39bd19d5163f15

Don't throw out OMEMO messages from MAM

borogove/MessageSync.hx +12 -13

diff --git a/borogove/MessageSync.hx b/borogove/MessageSync.hx
index d55128b..63e4d53 100644
--- a/borogove/MessageSync.hx
+++ b/borogove/MessageSync.hx
@@ -112,8 +112,8 @@ class MessageSync {
 				jmi.set(jmiChildren[0].attr.get("id"), originalMessage);
 			}
 
-			if (originalMessage.hasChild("encrypted", NS.OMEMO)) {
 #if !NO_OMEMO
+			if (originalMessage.hasChild("encrypted", NS.OMEMO)) {
 				trace("MAM: Processing OMEMO message from " + originalMessage.attr.get("from"));
 				promisedMessages.push(client.omemo.decryptMessage(originalMessage, null).then((decryptionResult) -> {
 					final decryptedStanza = decryptionResult.stanza;
@@ -137,21 +137,20 @@ class MessageSync {
 						new EncryptionInfo(DecryptionFailure, NS.OMEMO, "OMEMO", "internal-error", Std.string(err))
 					);
 				}));
-#end
 				return EventHandled;
-			} else {
-				trace("MAM: Processing non-OMEMO message from " + originalMessage.attr.get("from"));
+			}
+#end
 
-				final msg = Message.fromStanza(originalMessage, client.jid, (builder, stanza) -> {
-					builder.serverId = result.attr.get("id");
-					builder.serverIdBy = serviceJID;
-					if (timestamp != null && builder.timestamp == null) builder.timestamp = timestamp;
-					return contextHandler(builder, stanza);
-				});
+			trace("MAM: Processing non-OMEMO message from " + originalMessage.attr.get("from"));
 
-				promisedMessages.push(Promise.resolve(msg));
-				//messages.push(msg);
-			}
+			final msg = Message.fromStanza(originalMessage, client.jid, (builder, stanza) -> {
+				builder.serverId = result.attr.get("id");
+				builder.serverIdBy = serviceJID;
+				if (timestamp != null && builder.timestamp == null) builder.timestamp = timestamp;
+				return contextHandler(builder, stanza);
+			});
+
+			promisedMessages.push(Promise.resolve(msg));
 
 			return EventHandled;
 		});