Add IngressID and ResourceID attributes for the ingress participants (#344)

Author: biglittlebigben

go.mod

@@ -16,7 +16,7 @@ require (
 	github.com/livekit/go-rtmp v0.0.0-20230829211117-1c4f5a5c81ed
 	github.com/livekit/mageutil v0.0.0-20230125210925-54e8a70427c1
 	github.com/livekit/mediatransportutil v0.0.0-20241220010243-a2bdee945564
-	github.com/livekit/protocol v1.35.0
+	github.com/livekit/protocol v1.36.2-0.20250411001049-b735b3b9aec7
 	github.com/livekit/psrpc v0.6.1-0.20250205181828-a0beed2e4126
 	github.com/livekit/server-sdk-go/v2 v2.4.2
 	github.com/pion/dtls/v3 v3.0.4

go.sum

@@ -120,8 +120,8 @@ github.com/livekit/mageutil v0.0.0-20230125210925-54e8a70427c1 h1:jm09419p0lqTkD
 github.com/livekit/mageutil v0.0.0-20230125210925-54e8a70427c1/go.mod h1:Rs3MhFwutWhGwmY1VQsygw28z5bWcnEYmS1OG9OxjOQ=
 github.com/livekit/mediatransportutil v0.0.0-20241220010243-a2bdee945564 h1:GX7KF/V9ExmcfT/2Bdia8aROjkxrgx7WpyH7w9MB4J4=
 github.com/livekit/mediatransportutil v0.0.0-20241220010243-a2bdee945564/go.mod h1:36s+wwmU3O40IAhE+MjBWP3W71QRiEE9SfooSBvtBqY=
-github.com/livekit/protocol v1.35.0 h1:qUWXJZQoOpEerQCoq7C6x+aS4UO2uwY3It5sKjorStY=
-github.com/livekit/protocol v1.35.0/go.mod h1:WrT/CYRxtMNOVUjnIPm5OjWtEkmreffTeE1PRZwlRg4=
+github.com/livekit/protocol v1.36.2-0.20250411001049-b735b3b9aec7 h1:ir8E7VVk6oV6yKaeoJJL4zE+jSGWM8tA9/o3v9XvHBQ=
+github.com/livekit/protocol v1.36.2-0.20250411001049-b735b3b9aec7/go.mod h1:WrT/CYRxtMNOVUjnIPm5OjWtEkmreffTeE1PRZwlRg4=
 github.com/livekit/psrpc v0.6.1-0.20250205181828-a0beed2e4126 h1:fzuYpAQbCid7ySPpQWWePfQOWUrs8x6dJ0T3Wl07n+Y=
 github.com/livekit/psrpc v0.6.1-0.20250205181828-a0beed2e4126/go.mod h1:X5WtEZ7OnEs72Fi5/J+i0on3964F1aynQpCalcgMqRo=
 github.com/livekit/server-sdk-go/v2 v2.4.2 h1:q6ioBWpwLaLNj41f96eLQHi11kRyiY9MfEb5D3zi5AI=

pkg/lksdk_output/lksdk_output.go

@@ -217,6 +217,11 @@ func NewLKSDKOutput(ctx context.Context, onDisconnected func(), p *params.Params
 		return nil, err
 	}
 
+	// The resourceID may not be available when the token is created
+	room.LocalParticipant.SetAttributes(map[string]string{
+		livekit.AttrIngressResourceID: p.State.ResourceId,
+	})
+
 	s.room = room
 	s.logger = p.GetLogger().WithValues("roomID", room.SID())
 

pkg/params/params.go

@@ -140,7 +140,7 @@ func GetParams(ctx context.Context, psrpcClient rpc.IOInfoClient, conf *config.C
 	UpdateTranscodingEnabled(infoCopy)
 
 	if token == "" {
-		token, err = ingress.BuildIngressToken(conf.ApiKey, conf.ApiSecret, info.RoomName, info.ParticipantIdentity, info.ParticipantName, info.ParticipantMetadata)
+		token, err = ingress.BuildIngressToken(conf.ApiKey, conf.ApiSecret, info.RoomName, info.ParticipantIdentity, info.ParticipantName, info.ParticipantMetadata, info.IngressId)
 		if err != nil {
 			return nil, err
 		}