?room s

src/public/index.html

@@ -57,7 +57,7 @@
                     }
                 }
 
-                ws = new WebSocket("ws://"+window.location.host+"/ws");
+                ws = new WebSocket("ws://"+window.location.host+"/ws"+window.location.search);
                 ws.onopen = function(evt) {
                     print("READY");
                 }

src/server/message.go

@@ -5,4 +5,5 @@ type message struct {
 	Pitch    int
 	Rate     float64
 	VoiceIdx int
+	room     string
 }

src/server/server.go

@@ -31,9 +31,12 @@ func (s *Server) WS(w http.ResponseWriter, r *http.Request) error {
 	}
 	defer sess.Close()
 
+	log.Println("someone has joined", sess.room)
+	defer log.Println("someone has left", sess.room)
+
 	sess.cb = func(m message) error {
 		for i := range s.sessions {
-			if s.sessions[i].id != sess.id {
+			if s.sessions[i].id != sess.id && s.sessions[i].room == sess.room {
 				select {
 				case s.sessions[i].scatterc <- m:
 				case <-s.sessions[i].ctx.Done():

src/server/session.go

@@ -20,6 +20,7 @@ type session struct {
 	cb       func(message) error
 	id       string
 	scatterc chan (message)
+	room     string
 }
 
 var upgrader = websocket.Upgrader{}
@@ -34,6 +35,7 @@ func newSession(w http.ResponseWriter, r *http.Request, cb func(message) error)
 		cb:       cb,
 		id:       uuid.New().String(),
 		scatterc: make(chan message, 20),
+		room:     r.URL.Query().Get("room"),
 	}, err
 }
 
@@ -70,6 +72,7 @@ func (s *session) gather() {
 		if err := json.Unmarshal(msg, &m); err != nil {
 			return err
 		}
+		m.room = s.room
 
 		return s.cb(m)
 	})