From b9639b90a161409a690ef079ee779b59bdd6e113 Mon Sep 17 00:00:00 2001
From: Ingo Oppermann <ingo@datarhei.com>
Date: Tue, 9 Dec 2025 17:11:49 +0100
Subject: [PATCH] Fix event rewriting for loaded processes

---
 restream/core.go | 12 +-----------
 1 file changed, 1 insertion(+), 11 deletions(-)

diff --git a/restream/core.go b/restream/core.go
index fa1656ec..3e8649b1 100644
--- a/restream/core.go
+++ b/restream/core.go
@@ -469,17 +469,7 @@ func (r *restream) load() error {
 
 		t.ffmpeg = ffmpeg
 
-		r.events.Consume(t.parser, func(e event.Event) event.Event {
-			pe, ok := e.(*event.ProcessEvent)
-			if !ok {
-				return e
-			}
-
-			pe.ProcessID = t.process.ID
-			pe.Domain = t.process.Domain
-
-			return pe
-		})
+		r.events.Consume(t.parser, t.RewriteEvent)
 
 		return true
 	})