| author | Stephen Paul Weber
<singpolyma@singpolyma.net> 2026-09-22 18:22:02 UTC |
| committer | Stephen Paul Weber
<singpolyma@singpolyma.net> 2026-09-22 18:22:02 UTC |
| parent | 85532ccbee2756e89e951a24c3c21145fa8eede6 |
| borogove/Chat.hx | +4 | -0 |
| borogove/Client.hx | +1 | -0 |
| borogove/MessageSync.hx | +8 | -1 |
diff --git a/borogove/Chat.hx b/borogove/Chat.hx index 76e3c51..25e70c3 100644 --- a/borogove/Chat.hx +++ b/borogove/Chat.hx @@ -1232,6 +1232,7 @@ class DirectChat extends Chat { message.debug = { source: "live", path: "DirectChat#prepareIncomingMessage", + now: Date.format(std.Date.now()), sortId: { method: "between", lower: lower, upper: null }, }; } @@ -2273,6 +2274,7 @@ class Channel extends Chat { message.debug = { source: "live", path: "Channel#prepareIncomingMessage sortId != null && message.type == MessageChannel", + now: Date.format(std.Date.now()), sortId: { method: "between", lower: lower, upper: null }, }; } else { @@ -2284,6 +2286,7 @@ class Channel extends Chat { message.debug = { source: "live", path: "Channel#prepareIncomingMessage else (probably PM?)", + now: Date.format(std.Date.now()), sortId: { method: "between", lower: lower, upper: null }, }; } @@ -2313,6 +2316,7 @@ class Channel extends Chat { message.debug = { source: "outgoing", path: "Channel#prepareOutgoingMessage", + now: Date.format(std.Date.now()), sortId: { method: "between", lower: lower, upper: null }, }; } diff --git a/borogove/Client.hx b/borogove/Client.hx index 3c18af2..74f300c 100644 --- a/borogove/Client.hx +++ b/borogove/Client.hx @@ -2002,6 +2002,7 @@ class Client extends EventEmitter { builder.debug = { source: "outgoing", path: "Client#storeMessageBuilder", + now: Date.format(std.Date.now()), sortId: { method: "between", lower: lower, upper: null }, }; } diff --git a/borogove/MessageSync.hx b/borogove/MessageSync.hx index 71f9fe7..098ab7e 100644 --- a/borogove/MessageSync.hx +++ b/borogove/MessageSync.hx @@ -32,6 +32,7 @@ class MessageSync { private var contextHandler:(ChatMessageBuilder, Stanza)->ChatMessageBuilder = (b,_)->b; private var errorHandler:(Stanza)->Void; private final startSortA:Null<String>; + private final startFilter:MessageFilter; private var sortA:Null<String>; private final sortB:Null<String>; public var lastPage(default, null):ResultSetPageResult; @@ -42,7 +43,7 @@ class MessageSync { public function new(client:Client, stream:GenericStream, filter:MessageFilter, sortA: Null<String>, sortB: Null<String>, ?serviceJID:String) { this.client = client; this.stream = stream; - this.filter = Reflect.copy(filter); + this.startFilter = this.filter = Reflect.copy(filter); this.sortA = sortA; this.startSortA = sortA; this.sortB = sortB; @@ -127,6 +128,8 @@ class MessageSync { serverReceivedAt: serverReceivedAt, serviceJID: serviceJID, filter: filter, + startFiler: startFilter, + now: Date.format(std.Date.now()), path: "decrypted", sortId: { method: "between", startSortA: startSortA, lower: sortLower, upper: sortB }, }; @@ -145,6 +148,8 @@ class MessageSync { serverReceivedAt: serverReceivedAt, serviceJID: serviceJID, filter: filter, + startFiler: startFilter, + now: Date.format(std.Date.now()), path: "decryption failed", sortId: { method: "between", startSortA: startSortA, lower: sortLower, upper: sortB }, }; @@ -169,6 +174,8 @@ class MessageSync { serverReceivedAt: serverReceivedAt, serviceJID: serviceJID, filter: filter, + startFiler: startFilter, + now: Date.format(std.Date.now()), path: "unencrypted", sortId: { method: "between", startSortA: startSortA, lower: sortLower, upper: sortB }, };