From 86bf5cb62e1068f7fffba06cff08fb98ca25b07d Mon Sep 17 00:00:00 2001 From: Benjamin Pracht Date: Fri, 30 Dec 2022 13:46:45 +1300 Subject: [PATCH] Ensure we create en Egress ID with PsRPC (#1273) --- pkg/service/egress.go | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/pkg/service/egress.go b/pkg/service/egress.go index f3ff39974..c0f21d469 100644 --- a/pkg/service/egress.go +++ b/pkg/service/egress.go @@ -15,6 +15,7 @@ import ( "github.com/livekit/protocol/egress" "github.com/livekit/protocol/livekit" "github.com/livekit/protocol/logger" + "github.com/livekit/protocol/utils" "github.com/livekit/livekit-server/pkg/telemetry" ) @@ -183,6 +184,11 @@ func (s *egressLauncher) StartEgress(ctx context.Context, req *livekit.StartEgre var info *livekit.EgressInfo var err error + // Ensure we have a Egress ID + if req.EgressId == "" { + req.EgressId = utils.NewGuid(utils.EgressPrefix) + } + if s.psrpcClient != nil { info, err = s.psrpcClient.StartEgress(ctx, req) } else {