diff --git a/charger/warp-ws.go b/charger/warp-ws.go index 8ac51b530..ef8d25807 100644 --- a/charger/warp-ws.go +++ b/charger/warp-ws.go @@ -259,7 +259,9 @@ func (w *WarpWS) handleConnection(ctx context.Context, role wsRole, conn *websoc return err } - if role == wsRoleMain && isPmTopic(event.Topic) { + // only drop PM topics on the main WS when a dedicated PM connection exists; + // on single-WS setups (WARP3) PM events arrive here and must be processed + if role == wsRoleMain && w.pm != w.Connection && isPmTopic(event.Topic) { continue }