livekit-protocol 0.7.5

Livekit protocol and utilities for the Rust SDK
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91

package mono

import (
	"testing"
	"time"

	"github.com/stretchr/testify/require"
)

func TestMonoZero(t *testing.T) {
	ts := time.Time{}
	ts2 := FromTime(ts)
	require.True(t, ts.IsZero())
	require.True(t, ts2.IsZero())
	require.True(t, ts.Equal(ts2))
	require.Equal(t, ts.String(), ts2.String())
}

func TestMono(t *testing.T) {
	t.Cleanup(resetClock)

	ts1 := time.Now()
	ts2 := ts1.Add(time.Second)

	ts1m := FromTime(ts1)
	// emulate a clock reset, +1h jump
	// TODO: use synctest when we switch to Go 1.25
	jumpClock(time.Hour)
	ts2m := FromTime(ts2)

	require.Equal(t, ts2.Sub(ts1), ts2m.Sub(ts1m))
}

func TestNoGoMonotonicPayload(t *testing.T) {
	t.Cleanup(resetClock)

	now := Now()
	fromTime := FromTime(time.Now())
	fromUnix := Unix(123, 456)
	fromParse, err := Parse(time.RFC3339Nano, "2026-03-05T12:34:56.789123456Z")
	require.NoError(t, err)

	require.Equal(t, now, now.Round(0))
	require.Equal(t, fromTime, fromTime.Round(0))
	require.Equal(t, fromUnix, fromUnix.Round(0))
	require.Equal(t, fromParse, fromParse.Round(0))
}

func TestSerializationRoundTripComparableAcrossClockJump(t *testing.T) {
	t.Cleanup(resetClock)

	t1 := Now()
	t2 := t1.Add(10 * time.Second)

	t1Encoded := t1.UnixNano()
	t2Encoded := t2.UnixNano()

	// emulate a clock reset, +1h jump
	jumpClock(time.Hour)

	t1Decoded := Unix(0, t1Encoded)
	t2Decoded := Unix(0, t2Encoded)

	require.Equal(t, t2.Sub(t1), t2Decoded.Sub(t1Decoded))
}

func TestNowProgressesAcrossClockJump(t *testing.T) {
	t.Cleanup(resetClock)

	t1 := Now()
	time.Sleep(time.Millisecond)

	// emulate a clock reset, +1h jump
	jumpClock(time.Hour)
	t2 := Now()

	require.Greater(t, t2.Sub(t1), time.Duration(0))
}

func BenchmarkTime(b *testing.B) {
	b.Run("Now()", func(b *testing.B) {
		for b.Loop() {
			_ = Now()
		}
	})
	b.Run("time.Now()", func(b *testing.B) {
		for b.Loop() {
			_ = time.Now()
		}
	})
}