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

package agentsobs

import (
	"testing"

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

func TestJobKindFromProto(t *testing.T) {
	tests := []struct {
		input    livekit.JobType
		expected JobKind
	}{
		{livekit.JobType_JT_ROOM, JobKindRoom},
		{livekit.JobType_JT_PUBLISHER, JobKindPublisher},
		{livekit.JobType_JT_PARTICIPANT, JobKindParticipant},
		{livekit.JobType(999), JobKindUndefined}, // Undefined case
	}

	for _, test := range tests {
		result := JobKindFromProto(test.input)
		require.Equal(t, test.expected, result)
	}
}

func TestJobStatusFromProto(t *testing.T) {
	tests := []struct {
		input    livekit.JobStatus
		expected JobStatus
	}{
		{livekit.JobStatus_JS_PENDING, JobStatusPending},
		{livekit.JobStatus_JS_RUNNING, JobStatusRunning},
		{livekit.JobStatus_JS_SUCCESS, JobStatusSuccess},
		{livekit.JobStatus_JS_FAILED, JobStatusFailed},
		{livekit.JobStatus(999), JobStatusUndefined}, // Undefined case
	}

	for _, test := range tests {
		result := JobStatusFromProto(test.input)
		require.Equal(t, test.expected, result)
	}
}

func TestWorkerStatusFromProto(t *testing.T) {
	tests := []struct {
		input    livekit.WorkerStatus
		expected WorkerStatus
	}{
		{livekit.WorkerStatus_WS_AVAILABLE, WorkerStatusAvailable},
		{livekit.WorkerStatus_WS_FULL, WorkerStatusFull},
		{livekit.WorkerStatus(999), WorkerStatusUndefined}, // Undefined case
	}

	for _, test := range tests {
		result := WorkerStatusFromProto(test.input)
		require.Equal(t, test.expected, result)
	}
}