*
     * @param userMessage the user's original message
     * @param failedQuery the query that failed
     * @param failureReason the reason for failure ("no_results" or "no_relevant_results")
     * @param history the conversation history
     * @return a new query string, or the userMessage if regeneration fails
     */

		t.Fatalf("Scopes expected 1, got %d", len(results))
	}

	notResult, err := gorm.G[User](DB).Where("name like ?", "GenericsScopes%").Not("name = ?", "GenericsScopes1").Order("name").Find(ctx)
	if len(notResult) != 2 {
		t.Fatalf("expected 2 results, got %d", len(notResult))
	} else if notResult[0].Name != "GenericsScopes2" || notResult[1].Name != "GenericsScopes3" {

					result.Error = err.Error()
				} else {
					result = siteNetperf(ctx, duration)
					result.Endpoint = cli.GetEndpointURL().String()
				}
				resultsMu.Lock()
				results.NodeResults = append(results.NodeResults, result)
				resultsMu.Unlock()
			}()
			continue
		}
		wg.Add(1)
		go func() {
			defer wg.Done()
			ctx, cancel := context.WithTimeout(ctx, duration+10*time.Second)

        request.addSystemMessage(resolvedPrompt);

        addHistoryWithBudget(request, history, getHistoryMaxChars());
        request.addUserMessage(wrapUserInput(userMessage));
        applyPromptTypeParams(request, "noresults");
        request.setStream(true);

        streamChatWithConcurrencyControl(request, callback);
    }

    @Override

	}

	duration = duration.Round(time.Second)

	results := globalNotificationSys.Netperf(ctx, duration)
	enc := json.NewEncoder(w)
	if err := enc.Encode(madmin.NetperfResult{NodeResults: results}); err != nil {
		return
	}
}

func isAllowedRWAccess(r *http.Request, cred auth.Credentials, bucketName string) (rd, wr bool) {
	owner := cred.AccessKey == globalActiveCred.AccessKey