Fix bugs in waiting room.

rtpconn/unlock_test.go

@@ -296,6 +296,36 @@ func TestScheduledUnlockCompletesWhileIssuerIsOperator(t *testing.T) {
 	}
 }
 
+func TestScheduledUnlockTimerCompletesWhileIssuerIsOperator(t *testing.T) {
+	g, hallName := newWaitingTestHall(t, 0)
+	operator := addTestWebClient(t, hallName, "Operator", "op")
+	g.SetLocked(true, "")
+	waiter := joinWaitingTestClient(t, hallName, "Alice")
+	if err := updateWaitingPreference(waiter, true); err != nil {
+		t.Fatalf("enable automatic waiting-room admission: %v", err)
+	}
+
+	now := time.Now()
+	if err := scheduleHallUnlock(g, operator, now.Add(20*time.Millisecond), now); err != nil {
+		t.Fatalf("scheduleHallUnlock: %v", err)
+	}
+	deadline := time.Now().Add(time.Second)
+	for {
+		locked, _ := g.Locked()
+		if !locked && waitingClientHall(waiter) == nil {
+			break
+		}
+		if time.Now().After(deadline) {
+			t.Fatal("scheduled timer left hall locked while issuing operator was present")
+		}
+		time.Sleep(time.Millisecond)
+	}
+	drainActions(t, waiter)
+	if waiter.hall != g || waiter.waiting != nil {
+		t.Fatalf("waiting user was not admitted after scheduled unlock: hall=%v waiting=%v", waiter.hall, waiter.waiting)
+	}
+}
+
 func TestScheduledUnlockRequiresOperatorPermissionAtDeadline(t *testing.T) {
 	hallName := newChalkboardTestHall(t)
 	operator := addTestWebClient(t, hallName, "Operator", "op")

rtpconn/waiting_test.go

@@ -70,6 +70,9 @@ func TestWaitingClientAuthenticatedWithoutMembership(t *testing.T) {
 	drainActions(t, operator)
 
 	waiter := joinWaitingTestClient(t, name, "Alice")
+	if status := g.Status(true, nil); !status.WaitingRoom {
+		t.Fatalf("locked hall with operator did not report waiting-room availability: %#v", status)
+	}
 	if waiter.hall != nil || waiter.waiting == nil {
 		t.Fatalf("waiting client membership: hall=%v waiting=%v", waiter.hall, waiter.waiting)
 	}
@@ -108,6 +111,25 @@ func TestWaitingClientAuthenticatedWithoutMembership(t *testing.T) {
 	}
 }
 
+func TestWaitingClientLivenessMessagesDoNotReportAdmissionError(t *testing.T) {
+	g, name := newWaitingTestHall(t, 0)
+	operator := addTestWebClient(t, name, "Operator", "op")
+	g.SetLocked(true, "")
+	drainActions(t, operator)
+
+	waiter := joinWaitingTestClient(t, name, "Alice")
+	for _, messageType := range []string{"ping", "pong"} {
+		if err := handleClientMessage(waiter, clientMessage{Type: messageType}); err != nil {
+			t.Fatalf("waiting %s: %v", messageType, err)
+		}
+	}
+	for _, message := range drainMessages(waiter) {
+		if message.Type == "usermessage" && message.Kind == "error" {
+			t.Fatalf("waiting liveness message produced error: %#v", message)
+		}
+	}
+}
+
 func TestWaitingManualAdmissionAndLastOperatorCancellation(t *testing.T) {
 	g, name := newWaitingTestHall(t, 0)
 	operator := addTestWebClient(t, name, "Operator", "op")

rtpconn/webclient.go

@@ -1467,7 +1467,7 @@ func handleClientMessage(c *webClient, m clientMessage) error {
 			}
 		}
 	}
-	if waitingClientHall(c) != nil && m.Type != "waiting" && m.Type != "join" && m.Type != "pong" {
+	if waitingClientHall(c) != nil && m.Type != "waiting" && m.Type != "join" && m.Type != "ping" && m.Type != "pong" {
 		return c.error(hall.UserError("you have not been admitted to the hall"))
 	}