dialWS connects to the versioned WS endpoint.
(t *testing.T, srv *httptest.Server, email, token string)
| 92 | |
| 93 | // dialWS connects to the versioned WS endpoint. |
| 94 | func dialWS(t *testing.T, srv *httptest.Server, email, token string) (*websocket.Conn, *http.Response) { |
| 95 | t.Helper() |
| 96 | return dialWSPath(t, srv, fmt.Sprintf("/api/v1/agents/%s/ws", email), token) |
| 97 | } |
| 98 | |
| 99 | // waitConnected polls the hub until the agent is registered or timeout. |
| 100 | func waitConnected(t *testing.T, hub *Hub, agentID string) { |
no test coverage detected