(raw json.RawMessage)
| 379 | if r.URL.Query().Get("token") != s.token { |
| 380 | http.Error(w, "unauthorized", http.StatusUnauthorized) |
| 381 | return |
| 382 | } |
| 383 | teamSessionID := r.URL.Query().Get("team_session_id") |
| 384 | agentID := r.URL.Query().Get("agent_id") |
| 385 | if strings.TrimSpace(teamSessionID) == "" || strings.TrimSpace(agentID) == "" { |
| 386 | http.Error(w, "team_session_id and agent_id are required", http.StatusBadRequest) |
| 387 | return |
| 388 | } |
| 389 | conn, err := s.upgrader.Upgrade(w, r, nil) |
| 390 | if err != nil { |
| 391 | return |
| 392 | } |
| 393 | unregister := s.registerConnection() |
| 394 | defer unregister() |
| 395 | defer conn.Close() |
| 396 | for { |
| 397 | var req RPCRequest |
no test coverage detected