rename everything

This commit is contained in:
Zomatree
2025-10-23 15:00:35 +01:00
parent 484f784a43
commit 87c83b7193
283 changed files with 1118 additions and 1117 deletions
+8 -6
View File
@@ -33,7 +33,7 @@ jobs:
with:
# list of Docker images to use as base name for tags
images: |
livekit/livekit-server
ghcr.io/stoatchat/livekit-server
# generate Docker tags based on the following events/attributes
tags: |
type=ref,event=branch
@@ -57,12 +57,14 @@ jobs:
- name: Set up Docker Buildx
uses: docker/setup-buildx-action@v3
- name: Login to DockerHub
# Authenticate with Docker Hub and GHCR
- name: Login to Github Container Registry
if: github.event_name != 'pull_request'
uses: docker/login-action@v3
uses: docker/login-action@v2
with:
username: ${{ secrets.DOCKERHUB_USERNAME }}
password: ${{ secrets.DOCKERHUB_TOKEN }}
registry: ghcr.io
username: ${{ github.actor }}
password: ${{ secrets.GITHUB_TOKEN }}
- name: Build and push
id: docker_build
@@ -72,4 +74,4 @@ jobs:
push: ${{ github.event_name != 'pull_request' }}
platforms: linux/amd64,linux/arm64
tags: ${{ steps.meta.outputs.tags }}
labels: ${{ steps.meta.outputs.labels }}
labels: ${{ steps.meta.outputs.labels }}
-25
View File
@@ -1,25 +0,0 @@
name: PR Slack Notifier
on:
pull_request:
types: [review_requested, reopened, closed]
pull_request_review:
types: [submitted]
permissions:
contents: read
pull-requests: write
issues: write
concurrency:
group: pr-slack-${{ github.event.pull_request.number }}-${{ github.workflow }}
cancel-in-progress: false
jobs:
notify-devs:
runs-on: ubuntu-latest
steps:
- uses: livekit/slack-notifier-action@main
with:
config_json: ${{ secrets.SLACK_NOTIFY_CONFIG_JSON }}
slack_token: ${{ secrets.SLACK_PR_NOTIFIER_TOKEN }}
+7 -7
View File
@@ -27,14 +27,14 @@ import (
"github.com/urfave/cli/v3"
"gopkg.in/yaml.v3"
"github.com/livekit/protocol/auth"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/utils"
"github.com/livekit/protocol/utils/guid"
"github.com/stoatchat/livekit-protocol/auth"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/service"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/service"
)
func generateKeys(_ context.Context, _ *cli.Command) error {
+7 -7
View File
@@ -28,14 +28,14 @@ import (
"github.com/urfave/cli/v3"
"github.com/livekit/livekit-server/pkg/rtc"
"github.com/livekit/livekit-server/pkg/telemetry/prometheus"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/rtc"
"github.com/stoatchat/livekit-server/pkg/telemetry/prometheus"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/service"
"github.com/livekit/livekit-server/version"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/service"
"github.com/stoatchat/livekit-server/version"
)
var baseFlags = []cli.Flag{
+3 -1
View File
@@ -1,4 +1,4 @@
module github.com/livekit/livekit-server
module github.com/stoatchat/livekit-server
go 1.24.0
@@ -150,3 +150,5 @@ require (
google.golang.org/grpc v1.76.0 // indirect
gopkg.in/yaml.v2 v2.4.0 // indirect
)
replace github.com/livekit/protocol => github.com/stoatchat/livekit-protocol
-2
View File
@@ -171,8 +171,6 @@ 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-20250922175932-f537f0880397 h1:Z7j2mY+bvG05UC80MpnJkitlJju8sSDWsr0Bb4dPceo=
github.com/livekit/mediatransportutil v0.0.0-20250922175932-f537f0880397/go.mod h1:mSNtYzSf6iY9xM3UX42VEI+STHvMgHmrYzEHPcdhB8A=
github.com/livekit/protocol v1.42.2-0.20251015173118-0236ffc17f5e h1:2pgUHq8atL01StoCTrK760eYTKDoDz1nC4a90knEw5g=
github.com/livekit/protocol v1.42.2-0.20251015173118-0236ffc17f5e/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/mackerelio/go-osstat v0.2.6 h1:gs4U8BZeS1tjrL08tt5VUliVvSWP26Ai2Ob8Lr7f2i0=
+1 -1
View File
@@ -27,7 +27,7 @@ import (
"github.com/magefile/mage/mg"
"github.com/livekit/livekit-server/version"
"github.com/stoatchat/livekit-server/version"
"github.com/livekit/mageutil"
_ "github.com/livekit/psrpc"
)
+7 -7
View File
@@ -10,13 +10,13 @@ import (
"github.com/stretchr/testify/require"
"go.uber.org/atomic"
"github.com/livekit/livekit-server/pkg/agent"
"github.com/livekit/livekit-server/pkg/agent/testutils"
"github.com/livekit/protocol/auth"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/rpc"
"github.com/livekit/protocol/utils/guid"
"github.com/livekit/protocol/utils/must"
"github.com/stoatchat/livekit-server/pkg/agent"
"github.com/stoatchat/livekit-server/pkg/agent/testutils"
"github.com/stoatchat/livekit-protocol/auth"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/rpc"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/stoatchat/livekit-protocol/utils/must"
"github.com/livekit/psrpc"
)
+5 -5
View File
@@ -23,11 +23,11 @@ import (
"github.com/gammazero/workerpool"
"google.golang.org/protobuf/types/known/emptypb"
serverutils "github.com/livekit/livekit-server/pkg/utils"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/rpc"
"github.com/livekit/protocol/utils"
serverutils "github.com/stoatchat/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/rpc"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/livekit/psrpc"
)
+10 -10
View File
@@ -13,16 +13,16 @@ import (
"github.com/gammazero/deque"
"golang.org/x/exp/maps"
"github.com/livekit/livekit-server/pkg/agent"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/service"
"github.com/livekit/protocol/auth"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/utils/events"
"github.com/livekit/protocol/utils/guid"
"github.com/livekit/protocol/utils/must"
"github.com/livekit/protocol/utils/options"
"github.com/stoatchat/livekit-server/pkg/agent"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/service"
"github.com/stoatchat/livekit-protocol/auth"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/utils/events"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/stoatchat/livekit-protocol/utils/must"
"github.com/stoatchat/livekit-protocol/utils/options"
"github.com/livekit/psrpc"
)
+6 -6
View File
@@ -23,12 +23,12 @@ import (
"google.golang.org/protobuf/proto"
pagent "github.com/livekit/protocol/agent"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/rpc"
"github.com/livekit/protocol/utils"
"github.com/livekit/protocol/utils/guid"
pagent "github.com/stoatchat/livekit-protocol/agent"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/rpc"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/livekit/psrpc"
)
+3 -3
View File
@@ -15,9 +15,9 @@
package clientconfiguration
import (
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/utils/must"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/utils/must"
)
// StaticConfigurations list specific device-side limitations that should be disabled at a global level
+2 -2
View File
@@ -19,8 +19,8 @@ import (
"github.com/stretchr/testify/require"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/utils/must"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/utils/must"
)
func TestScriptMatchConfiguration(t *testing.T) {
+1 -1
View File
@@ -23,7 +23,7 @@ import (
"github.com/d5/tengo/v2/token"
"golang.org/x/mod/semver"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
type Match interface {
@@ -17,10 +17,10 @@ package clientconfiguration
import (
"google.golang.org/protobuf/proto"
"github.com/livekit/livekit-server/pkg/utils"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
protoutils "github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
protoutils "github.com/stoatchat/livekit-protocol/utils"
)
type ConfigurationItem struct {
+1 -1
View File
@@ -15,7 +15,7 @@
package clientconfiguration
import (
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
type ClientConfigurationManager interface {
+13 -13
View File
@@ -26,20 +26,20 @@ import (
"github.com/urfave/cli/v3"
"gopkg.in/yaml.v3"
"github.com/livekit/livekit-server/pkg/agent"
"github.com/livekit/livekit-server/pkg/metric"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/bwe/remotebwe"
"github.com/livekit/livekit-server/pkg/sfu/bwe/sendsidebwe"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/livekit-server/pkg/sfu/pacer"
"github.com/livekit/livekit-server/pkg/sfu/streamallocator"
"github.com/stoatchat/livekit-server/pkg/agent"
"github.com/stoatchat/livekit-server/pkg/metric"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/bwe/remotebwe"
"github.com/stoatchat/livekit-server/pkg/sfu/bwe/sendsidebwe"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/sfu/pacer"
"github.com/stoatchat/livekit-server/pkg/sfu/streamallocator"
"github.com/livekit/mediatransportutil/pkg/rtcconfig"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
redisLiveKit "github.com/livekit/protocol/redis"
"github.com/livekit/protocol/rpc"
"github.com/livekit/protocol/webhook"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
redisLiveKit "github.com/stoatchat/livekit-protocol/redis"
"github.com/stoatchat/livekit-protocol/rpc"
"github.com/stoatchat/livekit-protocol/webhook"
)
const (
+1 -1
View File
@@ -20,7 +20,7 @@ import (
"github.com/stretchr/testify/require"
"github.com/urfave/cli/v3"
"github.com/livekit/livekit-server/pkg/config/configtest"
"github.com/stoatchat/livekit-server/pkg/config/configtest"
)
func TestConfig_UnmarshalKeys(t *testing.T) {
+4 -4
View File
@@ -18,10 +18,10 @@ import (
"sync"
"time"
"github.com/livekit/livekit-server/pkg/sfu/utils"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/utils/mono"
"github.com/stoatchat/livekit-server/pkg/sfu/utils"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/utils/mono"
"google.golang.org/protobuf/types/known/timestamppb"
)
+4 -4
View File
@@ -19,11 +19,11 @@ import (
"time"
"github.com/frostbyte73/core"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/utils/mono"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/utils/mono"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-protocol/utils"
)
type MetricsCollectorProvider interface {
+4 -4
View File
@@ -19,11 +19,11 @@ import (
"time"
"github.com/frostbyte73/core"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/utils/mono"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/utils/mono"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-protocol/utils"
)
type MetricsReporterConsumer interface {
+6 -6
View File
@@ -23,12 +23,12 @@ import (
"go.uber.org/zap/zapcore"
"google.golang.org/protobuf/proto"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/utils"
"github.com/livekit/protocol/auth"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/rpc"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-protocol/auth"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/rpc"
)
//go:generate go run github.com/maxbrunsfeld/counterfeiter/v6 -generate
+3 -3
View File
@@ -20,9 +20,9 @@ import (
"go.uber.org/atomic"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
)
var _ Router = (*LocalRouter)(nil)
+1 -1
View File
@@ -17,7 +17,7 @@ package routing
import (
"sync"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"google.golang.org/protobuf/proto"
)
+2 -2
View File
@@ -18,9 +18,9 @@ import (
"sync"
"testing"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/routing"
)
func TestMessageChannel_WriteMessageClosed(t *testing.T) {
+4 -4
View File
@@ -19,11 +19,11 @@ import (
"sync"
"time"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/utils"
"github.com/livekit/protocol/utils/guid"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/livekit/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/config"
)
type LocalNode interface {
+4 -4
View File
@@ -18,11 +18,11 @@ import (
"sync"
"time"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/telemetry/prometheus"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/telemetry/prometheus"
)
type NodeStats struct {
+4 -4
View File
@@ -25,11 +25,11 @@ import (
"go.uber.org/atomic"
"google.golang.org/protobuf/proto"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/rpc"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/rpc"
"github.com/livekit/livekit-server/pkg/routing/selector"
"github.com/stoatchat/livekit-server/pkg/routing/selector"
)
const (
+3 -3
View File
@@ -17,9 +17,9 @@ package routing
import (
"context"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/rpc"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/rpc"
"github.com/livekit/psrpc"
"github.com/livekit/psrpc/pkg/middleware"
)
@@ -4,8 +4,8 @@ package routingfakes
import (
"sync"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-protocol/livekit"
"google.golang.org/protobuf/proto"
)
@@ -4,8 +4,8 @@ package routingfakes
import (
"sync"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-protocol/livekit"
"google.golang.org/protobuf/proto"
)
@@ -5,8 +5,8 @@ import (
"context"
"sync"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/livekit/psrpc"
)
+2 -2
View File
@@ -5,8 +5,8 @@ import (
"context"
"sync"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-protocol/livekit"
)
type FakeRouter struct {
@@ -5,8 +5,8 @@ import (
"context"
"sync"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-protocol/livekit"
)
type FakeSignalClient struct {
+1 -1
View File
@@ -15,7 +15,7 @@
package selector
import (
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
// AnySelector selects any available node with no limitations
+1 -1
View File
@@ -20,7 +20,7 @@ import (
"github.com/stretchr/testify/require"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
func createTestNode(id string, cpuLoad float32, numRooms int32, numClients int32, state livekit.NodeState) *livekit.Node {
+1 -1
View File
@@ -15,7 +15,7 @@
package selector
import (
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
// CPULoadSelector eliminates nodes that have CPU usage higher than CPULoadLimit
+2 -2
View File
@@ -19,9 +19,9 @@ import (
"github.com/stretchr/testify/require"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/livekit/livekit-server/pkg/routing/selector"
"github.com/stoatchat/livekit-server/pkg/routing/selector"
)
func TestCPULoadSelector_SelectNode(t *testing.T) {
+3 -3
View File
@@ -17,10 +17,10 @@ package selector
import (
"errors"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/livekit/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/config"
)
var ErrUnsupportedSelector = errors.New("unsupported node selector")
+2 -2
View File
@@ -17,9 +17,9 @@ package selector
import (
"math"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/livekit/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/config"
)
// RegionAwareSelector prefers available nodes that are closest to the region of the current instance
+5 -5
View File
@@ -20,12 +20,12 @@ import (
"github.com/stretchr/testify/require"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/utils"
"github.com/livekit/protocol/utils/guid"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/routing/selector"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/routing/selector"
)
const (
+2 -2
View File
@@ -17,9 +17,9 @@ package selector_test
import (
"testing"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/livekit/livekit-server/pkg/routing/selector"
"github.com/stoatchat/livekit-server/pkg/routing/selector"
)
func SortByTest(t *testing.T, sortBy string) {
+1 -1
View File
@@ -15,7 +15,7 @@
package selector
import (
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
// SystemLoadSelector eliminates nodes that surpass has a per-cpu node higher than SysloadLimit
+2 -2
View File
@@ -20,9 +20,9 @@ import (
"github.com/stretchr/testify/require"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/livekit/livekit-server/pkg/routing/selector"
"github.com/stoatchat/livekit-server/pkg/routing/selector"
)
var (
+2 -2
View File
@@ -21,9 +21,9 @@ import (
"github.com/thoas/go-funk"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/livekit/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/config"
)
const AvailableSeconds = 5
+2 -2
View File
@@ -20,9 +20,9 @@ import (
"github.com/stretchr/testify/require"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/livekit/livekit-server/pkg/routing/selector"
"github.com/stoatchat/livekit-server/pkg/routing/selector"
)
func TestIsAvailable(t *testing.T) {
+7 -7
View File
@@ -23,13 +23,13 @@ import (
"go.uber.org/atomic"
"google.golang.org/protobuf/proto"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/telemetry/prometheus"
"github.com/livekit/livekit-server/pkg/utils"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/rpc"
"github.com/livekit/protocol/utils/guid"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/telemetry/prometheus"
"github.com/stoatchat/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/rpc"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/livekit/psrpc"
"github.com/livekit/psrpc/pkg/middleware"
)
+1 -1
View File
@@ -18,7 +18,7 @@ import (
"strconv"
"strings"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
type ClientInfo struct {
+1 -1
View File
@@ -21,7 +21,7 @@ import (
"github.com/stretchr/testify/require"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
func TestClientInfo_CompareVersion(t *testing.T) {
+3 -3
View File
@@ -18,9 +18,9 @@ import (
"github.com/pion/sdp/v3"
"github.com/pion/webrtc/v4"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/sfu/buffer"
dd "github.com/livekit/livekit-server/pkg/sfu/rtpextension/dependencydescriptor"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/sfu/buffer"
dd "github.com/stoatchat/livekit-server/pkg/sfu/rtpextension/dependencydescriptor"
"github.com/livekit/mediatransportutil/pkg/rtcconfig"
)
+3 -3
View File
@@ -22,9 +22,9 @@ import (
"github.com/stretchr/testify/require"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
)
type testDynacastManagerListener struct {
+3 -3
View File
@@ -15,10 +15,10 @@
package dynacast
import (
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
)
var _ DynacastManager = (*dynacastManagerAudio)(nil)
+3 -3
View File
@@ -19,10 +19,10 @@ import (
"golang.org/x/exp/maps"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/utils"
)
type dynacastManagerBaseParams struct {
+4 -4
View File
@@ -19,11 +19,11 @@ import (
"github.com/bep/debounce"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
)
var _ DynacastManager = (*dynacastManagerVideo)(nil)
+3 -3
View File
@@ -17,9 +17,9 @@ package dynacast
import (
"sync"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
)
var _ dynacastQuality = (*dynacastQualityAudio)(nil)
+3 -3
View File
@@ -18,9 +18,9 @@ import (
"sync"
"time"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
)
var _ dynacastQuality = (*dynacastQualityVideo)(nil)
+3 -3
View File
@@ -15,10 +15,10 @@
package dynacast
import (
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
)
type DynacastManagerListener interface {
+5 -5
View File
@@ -20,11 +20,11 @@ import (
"fmt"
"strings"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/telemetry"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/rpc"
"github.com/livekit/protocol/webhook"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/telemetry"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/rpc"
"github.com/stoatchat/livekit-protocol/webhook"
)
type EgressLauncher interface {
+2 -2
View File
@@ -20,8 +20,8 @@ import (
"github.com/pion/webrtc/v4"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
)
var (
+2 -2
View File
@@ -20,8 +20,8 @@ import (
"github.com/pion/webrtc/v4"
"github.com/stretchr/testify/require"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
)
func TestIsCodecEnabled(t *testing.T) {
+3 -3
View File
@@ -20,10 +20,10 @@ import (
"github.com/pion/rtcp"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu"
)
const (
+11 -11
View File
@@ -24,18 +24,18 @@ import (
"github.com/pion/webrtc/v4"
"go.uber.org/atomic"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/observability/roomobs"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/observability/roomobs"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/rtc/dynacast"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/buffer"
"github.com/livekit/livekit-server/pkg/sfu/connectionquality"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/livekit-server/pkg/telemetry"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/rtc/dynacast"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/buffer"
"github.com/stoatchat/livekit-server/pkg/sfu/connectionquality"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/telemetry"
util "github.com/livekit/mediatransportutil"
)
+3 -3
View File
@@ -19,9 +19,9 @@ import (
"github.com/stretchr/testify/require"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
)
func TestTrackInfo(t *testing.T) {
+10 -10
View File
@@ -28,17 +28,17 @@ import (
"golang.org/x/exp/slices"
"google.golang.org/protobuf/proto"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/buffer"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/livekit-server/pkg/sfu/rtpstats"
"github.com/livekit/livekit-server/pkg/telemetry"
sutils "github.com/livekit/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/buffer"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/sfu/rtpstats"
"github.com/stoatchat/livekit-server/pkg/telemetry"
sutils "github.com/stoatchat/livekit-server/pkg/utils"
)
const (
+6 -6
View File
@@ -19,15 +19,15 @@ import (
"slices"
"sync"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/pion/webrtc/v4"
"go.uber.org/atomic"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/telemetry"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/telemetry"
)
var (
+1 -1
View File
@@ -3,7 +3,7 @@ package rtc
import (
"time"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
type MigrationDataCacheState int
+1 -1
View File
@@ -6,7 +6,7 @@ import (
"github.com/stretchr/testify/require"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
func TestMigrationDataCache_Add(t *testing.T) {
+28 -28
View File
@@ -37,34 +37,34 @@ import (
"google.golang.org/protobuf/proto"
"github.com/livekit/mediatransportutil/pkg/twcc"
"github.com/livekit/protocol/auth"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/observability"
"github.com/livekit/protocol/observability/roomobs"
protosdp "github.com/livekit/protocol/sdp"
protosignalling "github.com/livekit/protocol/signalling"
"github.com/livekit/protocol/utils"
"github.com/livekit/protocol/utils/guid"
"github.com/livekit/protocol/utils/pointer"
"github.com/stoatchat/livekit-protocol/auth"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/observability"
"github.com/stoatchat/livekit-protocol/observability/roomobs"
protosdp "github.com/stoatchat/livekit-protocol/sdp"
protosignalling "github.com/stoatchat/livekit-protocol/signalling"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/stoatchat/livekit-protocol/utils/pointer"
"github.com/livekit/psrpc"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/metric"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/rtc/signalling"
"github.com/livekit/livekit-server/pkg/rtc/supervisor"
"github.com/livekit/livekit-server/pkg/rtc/transport"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/buffer"
"github.com/livekit/livekit-server/pkg/sfu/connectionquality"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/livekit-server/pkg/sfu/pacer"
"github.com/livekit/livekit-server/pkg/sfu/streamallocator"
"github.com/livekit/livekit-server/pkg/telemetry"
"github.com/livekit/livekit-server/pkg/telemetry/prometheus"
sutils "github.com/livekit/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/metric"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/rtc/signalling"
"github.com/stoatchat/livekit-server/pkg/rtc/supervisor"
"github.com/stoatchat/livekit-server/pkg/rtc/transport"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/buffer"
"github.com/stoatchat/livekit-server/pkg/sfu/connectionquality"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/sfu/pacer"
"github.com/stoatchat/livekit-server/pkg/sfu/streamallocator"
"github.com/stoatchat/livekit-server/pkg/telemetry"
"github.com/stoatchat/livekit-server/pkg/telemetry/prometheus"
sutils "github.com/stoatchat/livekit-server/pkg/utils"
)
var _ types.LocalParticipant = (*ParticipantImpl)(nil)
@@ -3171,9 +3171,9 @@ func (p *ParticipantImpl) setTrackMuted(mute *livekit.MuteTrackRequest, fromAdmi
if trackInfo != nil && changed {
if mute.Muted {
p.params.Telemetry.TrackMuted(context.Background(), p.ID(), trackInfo)
p.params.Telemetry.TrackMuted(context.Background(), p.ID(), p.Identity(), trackInfo)
} else {
p.params.Telemetry.TrackUnmuted(context.Background(), p.ID(), trackInfo)
p.params.Telemetry.TrackUnmuted(context.Background(), p.ID(), p.Identity(), trackInfo)
}
}
+17 -17
View File
@@ -25,24 +25,24 @@ import (
"go.uber.org/atomic"
"google.golang.org/protobuf/proto"
"github.com/livekit/livekit-server/pkg/sfu/buffer"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/livekit-server/pkg/telemetry/telemetryfakes"
"github.com/livekit/protocol/auth"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/observability/roomobs"
lksdp "github.com/livekit/protocol/sdp"
"github.com/livekit/protocol/signalling"
"github.com/livekit/protocol/utils"
"github.com/livekit/protocol/utils/guid"
"github.com/stoatchat/livekit-server/pkg/sfu/buffer"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/telemetry/telemetryfakes"
"github.com/stoatchat/livekit-protocol/auth"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/observability/roomobs"
lksdp "github.com/stoatchat/livekit-protocol/sdp"
"github.com/stoatchat/livekit-protocol/signalling"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/routing/routingfakes"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/rtc/types/typesfakes"
"github.com/livekit/livekit-server/pkg/testutils"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/routing/routingfakes"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/rtc/types/typesfakes"
"github.com/stoatchat/livekit-server/pkg/testutils"
)
func TestIsReady(t *testing.T) {
+6 -6
View File
@@ -23,12 +23,12 @@ import (
"github.com/pion/sdp/v3"
"github.com/pion/webrtc/v4"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
lksdp "github.com/livekit/protocol/sdp"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
lksdp "github.com/stoatchat/livekit-protocol/sdp"
"github.com/stoatchat/livekit-protocol/utils"
)
func (p *ParticipantImpl) populateSdpCid(parsedOffer *sdp.SessionDescription) ([]*sdp.MediaDescription, []*sdp.MediaDescription) {
+5 -5
View File
@@ -19,12 +19,12 @@ import (
"github.com/pion/webrtc/v4"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
protosignalling "github.com/livekit/protocol/signalling"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
protosignalling "github.com/stoatchat/livekit-protocol/signalling"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
)
func (p *ParticipantImpl) SetResponseSink(sink routing.MessageSink) {
+16 -16
View File
@@ -28,24 +28,24 @@ import (
"golang.org/x/exp/maps"
"google.golang.org/protobuf/proto"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/observability/roomobs"
"github.com/livekit/protocol/rpc"
"github.com/livekit/protocol/utils"
"github.com/livekit/protocol/utils/guid"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/observability/roomobs"
"github.com/stoatchat/livekit-protocol/rpc"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/livekit/psrpc"
"github.com/livekit/livekit-server/pkg/agent"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/buffer"
"github.com/livekit/livekit-server/pkg/sfu/connectionquality"
"github.com/livekit/livekit-server/pkg/telemetry"
"github.com/livekit/livekit-server/pkg/telemetry/prometheus"
sutils "github.com/livekit/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-server/pkg/agent"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/buffer"
"github.com/stoatchat/livekit-server/pkg/sfu/connectionquality"
"github.com/stoatchat/livekit-server/pkg/telemetry"
"github.com/stoatchat/livekit-server/pkg/telemetry/prometheus"
sutils "github.com/stoatchat/livekit-server/pkg/utils"
)
const (
+14 -14
View File
@@ -22,22 +22,22 @@ import (
"github.com/stretchr/testify/require"
"google.golang.org/protobuf/proto"
"github.com/livekit/protocol/auth/authfakes"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/utils"
"github.com/livekit/protocol/webhook"
"github.com/stoatchat/livekit-protocol/auth/authfakes"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/stoatchat/livekit-protocol/webhook"
"github.com/livekit/livekit-server/version"
"github.com/stoatchat/livekit-server/version"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/rtc/types/typesfakes"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/audio"
"github.com/livekit/livekit-server/pkg/telemetry"
"github.com/livekit/livekit-server/pkg/telemetry/prometheus"
"github.com/livekit/livekit-server/pkg/telemetry/telemetryfakes"
"github.com/livekit/livekit-server/pkg/testutils"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/rtc/types/typesfakes"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/audio"
"github.com/stoatchat/livekit-server/pkg/telemetry"
"github.com/stoatchat/livekit-server/pkg/telemetry/prometheus"
"github.com/stoatchat/livekit-server/pkg/telemetry/telemetryfakes"
"github.com/stoatchat/livekit-server/pkg/testutils"
)
func init() {
+3 -3
View File
@@ -19,9 +19,9 @@ package rtc
import (
"sync"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/utils"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-protocol/livekit"
"golang.org/x/exp/slices"
)
+3 -3
View File
@@ -15,10 +15,10 @@
package signalling
import (
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"google.golang.org/protobuf/proto"
)
+3 -3
View File
@@ -17,11 +17,11 @@ package signalling
import (
"fmt"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"google.golang.org/protobuf/proto"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
)
var _ ParticipantSignalHandler = (*signalhandler)(nil)
+5 -5
View File
@@ -17,13 +17,13 @@ package signalling
import (
"fmt"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/livekit/psrpc"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"google.golang.org/protobuf/proto"
)
+3 -3
View File
@@ -17,10 +17,10 @@ package signalling
import (
"sync"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
)
type signallerAsyncBaseParams struct {
+2 -2
View File
@@ -15,8 +15,8 @@
package signalling
import (
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"google.golang.org/protobuf/proto"
)
+2 -2
View File
@@ -15,8 +15,8 @@
package signalling
import (
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"google.golang.org/protobuf/proto"
)
@@ -15,7 +15,7 @@
package signalling
import (
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
"google.golang.org/protobuf/proto"
)
+10 -10
View File
@@ -23,17 +23,17 @@ import (
"go.uber.org/atomic"
"google.golang.org/protobuf/proto"
"github.com/livekit/livekit-server/pkg/telemetry"
sutils "github.com/livekit/livekit-server/pkg/utils"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/observability/roomobs"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-server/pkg/telemetry"
sutils "github.com/stoatchat/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/observability/roomobs"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/buffer"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/buffer"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
)
const (
+7 -7
View File
@@ -26,13 +26,13 @@ import (
"go.uber.org/atomic"
"golang.org/x/exp/maps"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/telemetry"
"github.com/livekit/livekit-server/pkg/telemetry/prometheus"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/telemetry"
"github.com/stoatchat/livekit-server/pkg/telemetry/prometheus"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/utils"
)
// using var instead of const to override in tests
+6 -6
View File
@@ -24,12 +24,12 @@ import (
"github.com/stretchr/testify/require"
"go.uber.org/atomic"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/rtc/types/typesfakes"
"github.com/livekit/livekit-server/pkg/telemetry/telemetryfakes"
"github.com/livekit/livekit-server/pkg/utils"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/rtc/types/typesfakes"
"github.com/stoatchat/livekit-server/pkg/telemetry/telemetryfakes"
"github.com/stoatchat/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
)
func init() {
+3 -3
View File
@@ -20,9 +20,9 @@ import (
"go.uber.org/atomic"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
)
const (
+3 -3
View File
@@ -21,9 +21,9 @@ import (
"github.com/gammazero/deque"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
)
const (
+7 -7
View File
@@ -15,14 +15,14 @@
package rtc
import (
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/observability/roomobs"
"github.com/livekit/protocol/utils"
"github.com/livekit/protocol/utils/guid"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/observability/roomobs"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/stoatchat/livekit-protocol/utils/guid"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/rtc/types/typesfakes"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/rtc/types/typesfakes"
)
func NewMockParticipant(identity livekit.ParticipantIdentity, protocol types.ProtocolVersion, hidden bool, publisher bool) *typesfakes.FakeLocalParticipant {
+20 -20
View File
@@ -38,28 +38,28 @@ import (
"go.uber.org/zap/zapcore"
"google.golang.org/protobuf/proto"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/rtc/transport"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu/buffer"
"github.com/livekit/livekit-server/pkg/sfu/bwe"
"github.com/livekit/livekit-server/pkg/sfu/bwe/remotebwe"
"github.com/livekit/livekit-server/pkg/sfu/bwe/sendsidebwe"
"github.com/livekit/livekit-server/pkg/sfu/datachannel"
sfuinterceptor "github.com/livekit/livekit-server/pkg/sfu/interceptor"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/livekit-server/pkg/sfu/pacer"
pd "github.com/livekit/livekit-server/pkg/sfu/rtpextension/playoutdelay"
"github.com/livekit/livekit-server/pkg/sfu/streamallocator"
sfuutils "github.com/livekit/livekit-server/pkg/sfu/utils"
"github.com/livekit/livekit-server/pkg/telemetry/prometheus"
"github.com/livekit/livekit-server/pkg/utils"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/rtc/transport"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu/buffer"
"github.com/stoatchat/livekit-server/pkg/sfu/bwe"
"github.com/stoatchat/livekit-server/pkg/sfu/bwe/remotebwe"
"github.com/stoatchat/livekit-server/pkg/sfu/bwe/sendsidebwe"
"github.com/stoatchat/livekit-server/pkg/sfu/datachannel"
sfuinterceptor "github.com/stoatchat/livekit-server/pkg/sfu/interceptor"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/sfu/pacer"
pd "github.com/stoatchat/livekit-server/pkg/sfu/rtpextension/playoutdelay"
"github.com/stoatchat/livekit-server/pkg/sfu/streamallocator"
sfuutils "github.com/stoatchat/livekit-server/pkg/sfu/utils"
"github.com/stoatchat/livekit-server/pkg/telemetry/prometheus"
"github.com/stoatchat/livekit-server/pkg/utils"
lkinterceptor "github.com/livekit/mediatransportutil/pkg/interceptor"
lktwcc "github.com/livekit/mediatransportutil/pkg/twcc"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/logger/pionlogger"
lksdp "github.com/livekit/protocol/sdp"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/logger/pionlogger"
lksdp "github.com/stoatchat/livekit-protocol/sdp"
)
const (
+3 -3
View File
@@ -19,9 +19,9 @@ import (
"github.com/pion/webrtc/v4"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu/streamallocator"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu/streamallocator"
"github.com/stoatchat/livekit-protocol/livekit"
)
//go:generate go run github.com/maxbrunsfeld/counterfeiter/v6 -generate
@@ -4,10 +4,10 @@ package transportfakes
import (
"sync"
"github.com/livekit/livekit-server/pkg/rtc/transport"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu/streamallocator"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/rtc/transport"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu/streamallocator"
"github.com/stoatchat/livekit-protocol/livekit"
webrtc "github.com/pion/webrtc/v4"
)
+5 -5
View File
@@ -26,11 +26,11 @@ import (
"github.com/stretchr/testify/require"
"go.uber.org/atomic"
"github.com/livekit/livekit-server/pkg/rtc/transport"
"github.com/livekit/livekit-server/pkg/rtc/transport/transportfakes"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/livekit-server/pkg/testutils"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/rtc/transport"
"github.com/stoatchat/livekit-server/pkg/rtc/transport/transportfakes"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/testutils"
"github.com/stoatchat/livekit-protocol/livekit"
)
func TestMissingAnswerDuringICERestart(t *testing.T) {
+10 -10
View File
@@ -30,17 +30,17 @@ import (
"google.golang.org/protobuf/proto"
"github.com/livekit/mediatransportutil/pkg/twcc"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/livekit/livekit-server/pkg/config"
"github.com/livekit/livekit-server/pkg/rtc/transport"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/datachannel"
"github.com/livekit/livekit-server/pkg/sfu/pacer"
"github.com/livekit/livekit-server/pkg/telemetry"
"github.com/stoatchat/livekit-server/pkg/config"
"github.com/stoatchat/livekit-server/pkg/rtc/transport"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/datachannel"
"github.com/stoatchat/livekit-server/pkg/sfu/pacer"
"github.com/stoatchat/livekit-server/pkg/telemetry"
)
const (
+3 -3
View File
@@ -25,9 +25,9 @@ import (
"github.com/pion/webrtc/v4"
"golang.org/x/exp/slices"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/observability/roomobs"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/observability/roomobs"
)
type ICEConnectionType int
+11 -11
View File
@@ -21,18 +21,18 @@ import (
"github.com/pion/rtcp"
"github.com/pion/webrtc/v4"
"github.com/livekit/protocol/auth"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/observability/roomobs"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-protocol/auth"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/observability/roomobs"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/buffer"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/livekit-server/pkg/sfu/pacer"
"github.com/livekit/livekit-server/pkg/telemetry"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/buffer"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-server/pkg/sfu/pacer"
"github.com/stoatchat/livekit-server/pkg/telemetry"
"google.golang.org/protobuf/proto"
)
+1 -1
View File
@@ -17,7 +17,7 @@ package types
import (
"time"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-protocol/livekit"
)
type TrafficStats struct {
@@ -4,11 +4,11 @@ package typesfakes
import (
"sync"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
)
type FakeLocalMediaTrack struct {
@@ -5,17 +5,17 @@ import (
"sync"
"time"
"github.com/livekit/livekit-server/pkg/routing"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/buffer"
"github.com/livekit/livekit-server/pkg/sfu/pacer"
"github.com/livekit/livekit-server/pkg/telemetry"
"github.com/livekit/protocol/auth"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/livekit/protocol/observability/roomobs"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-server/pkg/routing"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/buffer"
"github.com/stoatchat/livekit-server/pkg/sfu/pacer"
"github.com/stoatchat/livekit-server/pkg/telemetry"
"github.com/stoatchat/livekit-protocol/auth"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
"github.com/stoatchat/livekit-protocol/observability/roomobs"
"github.com/stoatchat/livekit-protocol/utils"
"github.com/pion/rtcp"
webrtc "github.com/pion/webrtc/v4"
"google.golang.org/protobuf/proto"
@@ -4,8 +4,8 @@ package typesfakes
import (
"sync"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/protocol/livekit"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-protocol/livekit"
)
type FakeLocalParticipantHelper struct {
+5 -5
View File
@@ -4,11 +4,11 @@ package typesfakes
import (
"sync"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/livekit-server/pkg/sfu"
"github.com/livekit/livekit-server/pkg/sfu/mime"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/logger"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-server/pkg/sfu"
"github.com/stoatchat/livekit-server/pkg/sfu/mime"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/logger"
)
type FakeMediaTrack struct {
+3 -3
View File
@@ -5,9 +5,9 @@ import (
"sync"
"time"
"github.com/livekit/livekit-server/pkg/rtc/types"
"github.com/livekit/protocol/livekit"
"github.com/livekit/protocol/utils"
"github.com/stoatchat/livekit-server/pkg/rtc/types"
"github.com/stoatchat/livekit-protocol/livekit"
"github.com/stoatchat/livekit-protocol/utils"
)
type FakeParticipant struct {

Some files were not shown because too many files have changed in this diff Show More