From 826ac40a5cd7bd6abd1e019324048e76e5283b2d Mon Sep 17 00:00:00 2001 From: Sarah Jamie Lewis Date: Sun, 11 Feb 2024 14:45:11 -0800 Subject: [PATCH] Stream check in engine --- protocol/connections/engine.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/protocol/connections/engine.go b/protocol/connections/engine.go index c696e50..c486cfe 100644 --- a/protocol/connections/engine.go +++ b/protocol/connections/engine.go @@ -754,7 +754,7 @@ func (e *engine) handlePeerMessage(hostname string, eventID string, context stri // later on...we still want to ack the original send...(as some "malformed" messages // may be future-ok) if cm, err := model.DeserializeMessage(string(message)); err == nil { - if cm.Overlay > 1024 && cm.Overlay&0x7 == 0x7 { + if cm.IsStream() { return } }