From 9eee8299c40bea01f570d1477837b98a758f7c92 Mon Sep 17 00:00:00 2001
From: Mathew Kamkar <578302+matkam@users.noreply.github.com>
Date: Thu, 28 Oct 2021 20:00:02 -0700
Subject: [PATCH] node selector

---
 pkg/service/roommanager.go | 6 ++++++
 1 file changed, 6 insertions(+)

diff --git a/pkg/service/roommanager.go b/pkg/service/roommanager.go
index 2b35be7d1..f6a180036 100644
--- a/pkg/service/roommanager.go
+++ b/pkg/service/roommanager.go
@@ -47,6 +47,11 @@ func NewLocalRoomManager(conf *config.Config, rs RoomStore, router routing.Route
 		return nil, err
 	}
 
+	ns, err := selector.CreateNodeSelector(conf)
+	if err != nil {
+		return nil, err
+	}
+
 	r := &LocalRoomManager{
 		RoomStore:   rs,
 		lock:        sync.RWMutex{},
@@ -57,6 +62,7 @@ func NewLocalRoomManager(conf *config.Config, rs RoomStore, router routing.Route
 		currentNode: currentNode,
 		webhookPool: workerpool.New(1),
 		rooms:       make(map[string]*rtc.Room),
+		selector:    ns,
 	}
 
 	// hook up to router