}
        final String content = msg.getContent();
        if (content == null || content.isEmpty()) {
            return suffix;
        }
        final String truncMarker = "... [truncated]";
        final int bodyBudget = Math.max(0, summaryMaxChars - suffix.length() - truncMarker.length());
        if (content.length() <= bodyBudget) {
            return content + suffix;
        }

    assert response.status_code == 200, response.text
    assert response.headers["content-type"] == "text/html; charset=utf-8"
    assert "window.opener.swaggerUIRedirectOauth2" in response.text


def test_redoc():
    response = client.get("/redoc")
    assert response.status_code == 200, response.text
    assert response.headers["content-type"] == "text/html; charset=utf-8"
    assert "redoc@2" in response.text

	condValues["DurationSeconds"] = []string{strconv.FormatInt(int64(dur.Seconds()), 10)}
	return nil
}

func commonAddServiceAccount(r *http.Request, ldap bool) (context.Context, auth.Credentials, newServiceAccountOpts, madmin.AddServiceAccountReq, string, APIError) {
	ctx := r.Context()

	// Get current object layer instance.
	objectAPI := newObjectLayerFn()
	if objectAPI == nil || globalNotificationSys == nil {

        SmbFile targetFile = new SmbFile(baseUrl + "shared/copy_" + timestamp + ".txt", context);

        // Create source file with content
        String content = "Content for copy test";
        try (OutputStream out = sourceFile.openOutputStream(false)) {
            out.write(content.getBytes("UTF-8"));
        }

# Boost value for fuzzy content queries.
query.boost.fuzzy.content=0.005
# Fuzziness for fuzzy content queries.
query.boost.fuzzy.content.fuzziness=AUTO
# Number of expansions for fuzzy content queries.
query.boost.fuzzy.content.expansions=10
# Prefix length for fuzzy content queries.
query.boost.fuzzy.content.prefix_length=0
# Whether to allow transpositions in fuzzy content queries.

        doc.put("title", "Test Doc");
        doc.put("url", "http://example.com");
        doc.put("content", "Plain text content without any HTML");
        documents.add(doc);

        final String result = client.testBuildContext(documents);
        assertTrue(result.contains("Plain text content without any HTML"));
    }

    @Test
    public void test_buildContext_multipleDocumentsWithHtml() {

func (z *erasureServerPools) StorageInfo(ctx context.Context, metrics bool) StorageInfo {
	return globalNotificationSys.StorageInfo(ctx, z, metrics)
}

func (z *erasureServerPools) NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, healScanMode madmin.HealScanMode) error {
	// Updates must be closed before we return.
	defer xioutil.SafeClose(updates)

	ctx, cancel := context.WithCancel(ctx)
	defer cancel()

// only via IAM notifications.
func (sys *IAMSys) LoadGroup(ctx context.Context, objAPI ObjectLayer, group string) error {
	if !sys.Initialized() {
		return errServerNotInitialized
	}

	return sys.store.GroupNotificationHandler(ctx, group)
}

// LoadPolicy - reloads a specific canned policy from backend disks or etcd.
func (sys *IAMSys) LoadPolicy(ctx context.Context, objAPI ObjectLayer, policyName string) error {

	loadMappedPolicies(ctx context.Context, userType IAMUserType, isGroup bool, m *xsync.MapOf[string, MappedPolicy]) error
	saveIAMConfig(ctx context.Context, item any, path string, opts ...options) error
	loadIAMConfig(ctx context.Context, item any, path string) error
	deleteIAMConfig(ctx context.Context, path string) error
	savePolicyDoc(ctx context.Context, policyName string, p PolicyDoc) error

	}
}

func (c *check) mustGetIAMUserInfo(ctx context.Context, admClnt *madmin.AdminClient, accessKey string) madmin.UserInfo {
	c.Helper()
	ui, err := admClnt.GetUserInfo(ctx, accessKey)
	if err != nil {
		c.Fatalf("should be able to get user info: %v", err)
	}
	return ui
}

func (c *check) mustNotCreateIAMUser(ctx context.Context, admClnt *madmin.AdminClient) {
	c.Helper()