From e3ed9ff53fc14e1d1576ac63e876ff1f99b4e4c9 Mon Sep 17 00:00:00 2001 From: Benjamin Pracht Date: Mon, 7 Aug 2023 15:44:44 -0700 Subject: [PATCH] Validate that url pull ingress are ready to use on creation (#1939) --- pkg/service/ingress.go | 9 +++++++++ 1 file changed, 9 insertions(+) diff --git a/pkg/service/ingress.go b/pkg/service/ingress.go index bf4a316c2..73de7663c 100644 --- a/pkg/service/ingress.go +++ b/pkg/service/ingress.go @@ -160,6 +160,15 @@ func (s *IngressService) CreateIngressWithUrl(ctx context.Context, urlStr string case livekit.IngressInput_RTMP_INPUT, livekit.IngressInput_WHIP_INPUT: info.Reusable = true + if err := ingress.ValidateForSerialization(info); err != nil { + return nil, err + } + case livekit.IngressInput_URL_INPUT: + if err := ingress.Validate(info); err != nil { + return nil, err + } + default: + return nil, ingress.ErrInvalidIngressType } if err := ingress.ValidateForSerialization(info); err != nil {