(raw json.RawMessage)
| 368 | for { |
| 369 | var req RPCRequest |
| 370 | if err := conn.ReadJSON(&req); err != nil { |
| 371 | return |
| 372 | } |
| 373 | resp := s.dispatch(r.Context(), client, req) |
| 374 | client.write(resp) |
| 375 | } |
| 376 | } |
| 377 | |
| 378 | func (s *DaemonServer) handleA2AWS(w http.ResponseWriter, r *http.Request) { |
| 379 | if r.URL.Query().Get("token") != s.token { |
| 380 | http.Error(w, "unauthorized", http.StatusUnauthorized) |
| 381 | return |
| 382 | } |
no test coverage detected