deblan-mirror/nextcloud-spreed-signaling
deblan-mirror/nextcloud-spreed-signaling
1
0
Fork 0
mirror of https://github.com/strukturag/nextcloud-spreed-signaling synced 2026-03-14 14:35:44 +01:00
Code Issues Releases Wiki Activity

Move server-related code to "server" package.

Browse source
This commit is contained in:
Joachim Bauch 2026-01-08 14:49:49 +01:00
commit 9d321bb3ab
No known key found for this signature in database
GPG key ID: 77C1D22D53E15F02
38 changed files with 45 additions and 41 deletions
Download patch file Download diff file Expand all files Collapse all files

10
cmd/server/main.go
View file

@ -41,7 +41,6 @@ import (
"github.com/dlintw/goconf"
"github.com/gorilla/mux"
signaling "github.com/strukturag/nextcloud-spreed-signaling"
"github.com/strukturag/nextcloud-spreed-signaling/async/events"
"github.com/strukturag/nextcloud-spreed-signaling/config"
"github.com/strukturag/nextcloud-spreed-signaling/dns"
@ -50,6 +49,7 @@ import (
"github.com/strukturag/nextcloud-spreed-signaling/internal"
signalinglog "github.com/strukturag/nextcloud-spreed-signaling/log"
"github.com/strukturag/nextcloud-spreed-signaling/nats"
"github.com/strukturag/nextcloud-spreed-signaling/server"
"github.com/strukturag/nextcloud-spreed-signaling/sfu"
"github.com/strukturag/nextcloud-spreed-signaling/sfu/janus"
"github.com/strukturag/nextcloud-spreed-signaling/sfu/proxy"
@ -183,7 +183,7 @@ func main() {
logger.Printf("Using a maximum of %d CPUs", runtime.GOMAXPROCS(0))
signaling.RegisterStats()
server.RegisterStats()
natsUrl, _ := config.GetStringOptionWithEnv(cfg, "nats", "url")
if natsUrl == "" {
@ -221,7 +221,7 @@ func main() {
}
}()
rpcServer, err := signaling.NewGrpcServer(stopCtx, cfg, version)
rpcServer, err := server.NewGrpcServer(stopCtx, cfg, version)
if err != nil {
logger.Fatalf("Could not create RPC server: %s", err)
}
@ -239,7 +239,7 @@ func main() {
defer rpcClients.Close()
r := mux.NewRouter()
hub, err := signaling.NewHub(stopCtx, cfg, events, rpcServer, rpcClients, etcdClient, r, version)
hub, err := server.NewHub(stopCtx, cfg, events, rpcServer, rpcClients, etcdClient, r, version)
if err != nil {
logger.Fatal("Could not create hub: ", err)
}
@ -324,7 +324,7 @@ func main() {
go hub.Run()
defer hub.Stop()
server, err := signaling.NewBackendServer(stopCtx, cfg, hub, version)
server, err := server.NewBackendServer(stopCtx, cfg, hub, version)
if err != nil {
logger.Fatal("Could not create backend server: ", err)
}