add roommanager service (#789)

* add roommanager service

* merge

* merge

* generated protobuf

---------

Co-authored-by: github-actions <41898282+github-actions[bot]@users.noreply.github.com>

magefile.go

@@ -69,6 +69,7 @@ func Proto() error {
 		"rpc/keepalive.proto",
 		"rpc/participant.proto",
 		"rpc/room.proto",
+		"rpc/roommanager.proto",
 		"rpc/signal.proto",
 		"rpc/sip.proto",
 	}

protobufs/livekit_internal.proto

@@ -23,6 +23,7 @@ option ruby_package = "LiveKit::Proto";
 import "livekit_models.proto";
 import "livekit_egress.proto";
 import "livekit_agent_dispatch.proto";
+import "livekit_room.proto";
 
 enum NodeType {
   SERVER = 0;
@@ -136,6 +137,7 @@ message StartSession {
   ReconnectReason reconnect_reason = 17;
   optional bool subscriber_allow_pause = 18;
   bool disable_ice_lite = 19;
+  livekit.CreateRoomRequest create_room = 20;
 }
 
 // room info that should not be returned to clients

protobufs/rpc/roommanager.proto

@@ -0,0 +1,36 @@
+// Copyright 2023 LiveKit, Inc.
+//
+// Licensed under the Apache License, Version 2.0 (the "License");
+// you may not use this file except in compliance with the License.
+// You may obtain a copy of the License at
+//
+//     http://www.apache.org/licenses/LICENSE-2.0
+//
+// Unless required by applicable law or agreed to in writing, software
+// distributed under the License is distributed on an "AS IS" BASIS,
+// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+// See the License for the specific language governing permissions and
+// limitations under the License.
+
+syntax = "proto3";
+
+package rpc;
+
+option go_package = "github.com/livekit/protocol/rpc";
+
+import "options.proto";
+import "livekit_models.proto";
+import "livekit_room.proto";
+
+service RoomManager {
+  rpc CreateRoom(livekit.CreateRoomRequest) returns (livekit.Room) {
+    option (psrpc.options) = {
+      topics: true
+      topic_params: {
+        group: "node"
+        names: ["node_id"]
+        typed: true
+      };
+    };
+  };
+}

protobufs/rpc/signal.proto

@@ -28,6 +28,7 @@ service Signal {
       stream: true
       topics: true
       topic_params: {
+        group: "node"
         names: ["node_id"]
         typed: true
         single_server: true