Ensure we create en Egress ID with PsRPC (#1273)

This commit is contained in:
Benjamin Pracht
2022-12-30 13:46:45 +13:00
committed by GitHub
parent 7778cdf2cd
commit 86bf5cb62e

View File

@@ -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 {