From b0eead22b5464add9fffe4ed15fa584570631eb9 Mon Sep 17 00:00:00 2001 From: Benjamin Pracht Date: Mon, 12 Sep 2022 14:03:15 -0700 Subject: [PATCH] Allow specifying a different RTMP url domain for each ingress (#994) --- pkg/service/ingress.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/service/ingress.go b/pkg/service/ingress.go index 757c460eb..efed11a38 100644 --- a/pkg/service/ingress.go +++ b/pkg/service/ingress.go @@ -54,6 +54,10 @@ func (s *IngressService) Stop() { } func (s *IngressService) CreateIngress(ctx context.Context, req *livekit.CreateIngressRequest) (*livekit.IngressInfo, error) { + return s.CreateIngressWithUrlPrefix(ctx, s.conf.RTMPBaseURL, req) +} + +func (s *IngressService) CreateIngressWithUrlPrefix(ctx context.Context, urlPrefix string, req *livekit.CreateIngressRequest) (*livekit.IngressInfo, error) { roomName, err := EnsureJoinPermission(ctx) if err != nil { return nil, twirpAuthError(err) @@ -68,7 +72,7 @@ func (s *IngressService) CreateIngress(ctx context.Context, req *livekit.CreateI IngressId: utils.NewGuid(utils.IngressPrefix), Name: req.Name, StreamKey: sk, - Url: newRtmpUrl(s.conf.RTMPBaseURL, sk), + Url: newRtmpUrl(urlPrefix, sk), InputType: req.InputType, Audio: req.Audio, Video: req.Video,