update replay (#697)

Author: frostbyte73

cmd/lk/replay.go

@@ -25,6 +25,7 @@ import (
 	authutil "github.com/livekit/livekit-cli/v2/pkg/auth"
 	"github.com/livekit/livekit-cli/v2/pkg/util"
 	"github.com/livekit/protocol/auth"
+	"github.com/livekit/protocol/livekit"
 	"github.com/livekit/protocol/replay"
 	"github.com/livekit/server-sdk-go/v2/signalling"
 )
@@ -48,6 +49,11 @@ var (
 							Usage:    "Playback room name",
 							Required: false,
 						},
+						&cli.StringFlag{
+							Name:     "token",
+							Usage:    "Pagination token",
+							Required: false,
+						},
 					},
 				},
 				{
@@ -66,7 +72,7 @@ var (
 							Required: true,
 						},
 						&cli.IntFlag{
-							Name:     "pts",
+							Name:     "offset",
 							Usage:    "Playback start time",
 							Required: false,
 						},
@@ -83,7 +89,7 @@ var (
 							Required: true,
 						},
 						&cli.IntFlag{
-							Name:     "pts",
+							Name:     "offset",
 							Usage:    "Playback start time",
 							Required: true,
 						},
@@ -145,6 +151,10 @@ func listReplays(ctx context.Context, cmd *cli.Command) error {
 	req := &replay.ListReplaysRequest{
 		RoomName: cmd.String("room"),
 	}
+	if token := cmd.String("token"); token != "" {
+		req.PageToken = &livekit.TokenPagination{Token: token}
+	}
+
 	res, err := replayClient.ListReplays(ctx, req)
 	if err != nil {
 		return err
@@ -170,9 +180,9 @@ func loadReplay(ctx context.Context, cmd *cli.Command) error {
 	}
 
 	req := &replay.PlaybackRequest{
-		ReplayId:  cmd.String("id"),
-		RoomName:  cmd.String("room"),
-		StartTime: int64(cmd.Int("pts")),
+		ReplayId:     cmd.String("id"),
+		PlaybackRoom: cmd.String("room"),
+		SeekOffset:   int64(cmd.Int("pts")),
 	}
 	res, err := replayClient.Playback(ctx, req)
 	if err != nil {
@@ -191,7 +201,7 @@ func seek(ctx context.Context, cmd *cli.Command) error {
 
 	req := &replay.SeekRequest{
 		PlaybackId: cmd.String("id"),
-		StartTime:  int64(cmd.Int("pts")),
+		SeekOffset: int64(cmd.Int("pts")),
 	}
 	_, err = replayClient.Seek(ctx, req)
 	return err

go.mod

@@ -14,7 +14,7 @@ require (
 	github.com/go-logr/logr v1.4.3
 	github.com/go-task/task/v3 v3.44.1
 	github.com/joho/godotenv v1.5.1
-	github.com/livekit/protocol v1.42.0
+	github.com/livekit/protocol v1.42.1-0.20250929175250-2ddfb3ee7f7e
 	github.com/livekit/server-sdk-go/v2 v2.11.3
 	github.com/moby/buildkit v0.23.2
 	github.com/moby/patternmatcher v0.6.0

go.sum

@@ -274,8 +274,8 @@ github.com/livekit/mageutil v0.0.0-20250511045019-0f1ff63f7731 h1:9x+U2HGLrSw5AT
 github.com/livekit/mageutil v0.0.0-20250511045019-0f1ff63f7731/go.mod h1:Rs3MhFwutWhGwmY1VQsygw28z5bWcnEYmS1OG9OxjOQ=
 github.com/livekit/mediatransportutil v0.0.0-20250825135402-7bc31f107ade h1:lpxPcglwzUWNB4J0S2qZuyMehzmR7vW9whzSwV4IGoI=
 github.com/livekit/mediatransportutil v0.0.0-20250825135402-7bc31f107ade/go.mod h1:mSNtYzSf6iY9xM3UX42VEI+STHvMgHmrYzEHPcdhB8A=
-github.com/livekit/protocol v1.42.0 h1:cd6kkh0eW4/HvNs5hbsWoUlC3CAVyd+ohBAXpdPRgxA=
-github.com/livekit/protocol v1.42.0/go.mod h1:vhMS30QoEyH2p34vi6X1eWkC4EMV72ZGZwQb74ajY7A=
+github.com/livekit/protocol v1.42.1-0.20250929175250-2ddfb3ee7f7e h1:yytr+uwFXtJ8UxBV2q3j55jVKg7zslECuGeE4F56NoU=
+github.com/livekit/protocol v1.42.1-0.20250929175250-2ddfb3ee7f7e/go.mod h1:vhMS30QoEyH2p34vi6X1eWkC4EMV72ZGZwQb74ajY7A=
 github.com/livekit/psrpc v0.7.0 h1:rtfqfjYN06WJYloE/S0nmkJ/Y04x4pxLQLe8kQ4FVHU=
 github.com/livekit/psrpc v0.7.0/go.mod h1:AuDC5uOoEjQJEc69v4Li3t77Ocz0e0NdjQEuFfO+vfk=
 github.com/livekit/server-sdk-go/v2 v2.11.3 h1:k+YDxo8wPCixRrS9fJHcbtlurlXhVLfyPva5Ne4tVH0=