Method handleNodeSpeedTest

internal/serverapi/api.go:659–683

(w http.ResponseWriter, r *http.Request, nodeID string)

}

func (a *API) handleNodeSpeedTest(w http.ResponseWriter, r *http.Request, nodeID string) {
	if r.Method != http.MethodPost {
		writeMethodNotAllowed(w, http.MethodPost)
		return
	}
	client, err := a.clientFor(nodeID)
	if err != nil {
		writeNodeError(w, err)
		return
	}
	ctx, cancel := context.WithTimeout(r.Context(), 70*time.Second)
	defer cancel()
	resp, err := client.SpeedTest(ctx)
	if err != nil {
		writeJSON(w, http.StatusUnprocessableEntity, map[string]any{"error": err.Error()})
		return
	}
	result := nodes.SpeedTestResult{
		DownBps:  resp.DownBps,
		UpBps:    resp.UpBps,
		TestedAt: time.Now().UTC(),
	}
	_ = a.store.UpsertNodeSpeedTest(nodeID, result)
	writeJSON(w, http.StatusOK, result)
}

func (a *API) handleNodeCheck(w http.ResponseWriter, r *http.Request, nodeID string) {
	if r.Method != http.MethodPost {