for some reasons this wasn't generated before committed. (#974)

This commit is contained in:
David Zhao
2022-08-31 21:35:51 -07:00
committed by GitHub
parent 1df9470504
commit da2525e973
+1 -6
View File
@@ -66,9 +66,8 @@ func InitializeServer(conf *config.Config, currentNode routing.LocalNode) (*Live
ingressConfig := getIngressConfig(conf)
rpc := ingress.NewRedisRPC(nodeID, client)
ingressRPCClient := getIngressRPCClient(rpc)
rpcServer := getIngressRPCServer(rpc)
ingressStore := getIngressStore(objectStore)
ingressService := NewIngressService(ingressConfig, ingressRPCClient, rpcServer, ingressStore, roomService, telemetryService)
ingressService := NewIngressService(ingressConfig, ingressRPCClient, ingressStore, roomService, telemetryService)
rtcService := NewRTCService(conf, roomAllocator, objectStore, router, currentNode)
clientConfigurationManager := createClientConfiguration()
roomManager, err := NewLocalRoomManager(conf, objectStore, currentNode, router, telemetryService, clientConfigurationManager)
@@ -226,10 +225,6 @@ func getIngressRPCClient(rpc ingress.RPC) ingress.RPCClient {
return rpc
}
func getIngressRPCServer(rpc ingress.RPC) ingress.RPCServer {
return rpc
}
func createClientConfiguration() clientconfiguration.ClientConfigurationManager {
return clientconfiguration.NewStaticClientConfigurationManager(clientconfiguration.StaticConfigurations)
}