From a0c5562a4fca8118286dd3b2e9da1a712725de5c Mon Sep 17 00:00:00 2001
From: onthegit <43019496+onthegit@users.noreply.github.com>
Date: Thu, 3 Aug 2023 11:29:51 +0200
Subject: [PATCH] Workaround for corrupted frames

---
 pkg/pipeline/input/video.go | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/pkg/pipeline/input/video.go b/pkg/pipeline/input/video.go
index 5b6cd63d..9f6b56f6 100644
--- a/pkg/pipeline/input/video.go
+++ b/pkg/pipeline/input/video.go
@@ -122,6 +122,16 @@ func (v *VideoInput) buildSDKDecoder(p *config.PipelineConfig) error {
 		}
 		v.elements = append(v.elements, rtpH264Depay)
 
+		caps, err := gst.NewElement("capsfilter")
+		if err != nil {
+			return errors.ErrGstPipelineError(err)
+		}
+		if err = caps.SetProperty("caps", gst.NewCapsFromString(
+			`video/x-h264,stream-format="byte-stream"`)); err != nil {
+			return errors.ErrGstPipelineError(err)
+		}
+		v.elements = append(v.elements, caps)
+
 		if p.VideoTranscoding {
 			avDecH264, err := gst.NewElement("avdec_h264")
 			if err != nil {