@@ -27,11 +27,11 @@ import (
2727 "github.com/urfave/cli/v3"
2828 "google.golang.org/protobuf/encoding/protojson"
2929
30- "github.com/livekit/livekit-cli/pkg/util"
31- "github.com/livekit/protocol/logger"
32-
3330 "github.com/livekit/protocol/livekit"
31+ "github.com/livekit/protocol/logger"
3432 lksdk "github.com/livekit/server-sdk-go/v2"
33+
34+ "github.com/livekit/livekit-cli/pkg/util"
3535)
3636
3737var (
@@ -754,6 +754,20 @@ func joinRoom(ctx context.Context, cmd *cli.Command) error {
754754
755755 done := make (chan os.Signal , 1 )
756756 roomCB := & lksdk.RoomCallback {
757+ OnParticipantConnected : func (p * lksdk.RemoteParticipant ) {
758+ logger .Infow ("participant connected" ,
759+ "kind" , p .Kind (),
760+ "pID" , p .SID (),
761+ "participant" , p .Identity (),
762+ )
763+ },
764+ OnParticipantDisconnected : func (p * lksdk.RemoteParticipant ) {
765+ logger .Infow ("participant disconnected" ,
766+ "kind" , p .Kind (),
767+ "pID" , p .SID (),
768+ "participant" , p .Identity (),
769+ )
770+ },
757771 ParticipantCallback : lksdk.ParticipantCallback {
758772 OnDataPacket : func (p lksdk.DataPacket , params lksdk.DataReceiveParams ) {
759773 identity := params .SenderIdentity
0 commit comments