assertEquals(testContent, result);
        }
    }

    @Test
    public void testMemoryBasedCacheMultipleReads() throws IOException {
        String testContent = "Hello, World!";
        byte[] data = testContent.getBytes("UTF-8");
        ContentCache cache = new ContentCache(data);

        // First read
        try (InputStream stream1 = cache.getInputStream()) {

        response.setEncoding("UTF-8");
        String testContent = "Hello, World!";
        byte[] data = testContent.getBytes("UTF-8");
        ContentCache cache = new ContentCache(data);
        response.setContentCache(cache);

        String content = response.getContentAsString();

        assertEquals(testContent, content);
    }

    @Test

	ExecExtendedObjectLayerTest(t, testPutObject)
}

// Tests validate PutObject without prefix.
func testPutObject(obj ObjectLayer, instanceType string, t TestErrHandler) {
	content := []byte("testcontent")
	length := int64(len(content))
	readerEOF := newTestReaderEOF(content)
	readerNoEOF := newTestReaderNoEOF(content)
	err := obj.MakeBucket(context.Background(), "bucket", MakeBucketOptions{})
	if err != nil {

    /**
     * Gets the message content.
     *
     * @return the message content
     */
    public String getContent() {
        return content;
    }

    /**
     * Sets the message content.
     *
     * @param content the message content
     */
    public void setContent(final String content) {
        this.content = content;
    }

    /**
     * Gets the message timestamp.

            assertEquals(0, moduleElements.size());
            assertEquals(2, subprojectElements.size());

            assertEquals("module1", subprojectElements.get(0).textContent());
            assertEquals("module2", subprojectElements.get(1).textContent());
        }
    }

    @Nested
    @DisplayName("Strategy Description")
    class StrategyDescriptionTests {

        @Test

    //                                       ---------------
    protected final Map<String, PropertyGateway> _epgMap = newHashMap();
    {
        setupEpg(_epgMap, et -> ((RelatedContent) et).getContent(), (et, vl) -> ((RelatedContent) et).setContent(DfTypeUtil.toString(vl)),
                "content");
        setupEpg(_epgMap, et -> ((RelatedContent) et).getCreatedBy(),

        assertEquals("User 2", messages.get(0).getContent());
        assertEquals(ChatMessage.ROLE_ASSISTANT, messages.get(1).getRole());
        assertEquals("Assistant 2", messages.get(1).getContent());
        assertEquals(ChatMessage.ROLE_USER, messages.get(2).getRole());
        assertEquals("User 3", messages.get(2).getContent());
        assertEquals(ChatMessage.ROLE_ASSISTANT, messages.get(3).getRole());

        assertEquals("", documentHelper.getContent(null, responseData, "", dataMap));
        assertEquals("", documentHelper.getContent(null, responseData, " ", dataMap));
        assertEquals("", documentHelper.getContent(null, responseData, "  ", dataMap));
        assertEquals("", documentHelper.getContent(null, responseData, "\t", dataMap));

    }

    private static class TestableSearchLogHelper extends SearchLogHelper {
        private SearchLogContext testContext;

        @Override
        protected SearchLogContext createSearchLogContext(final SearchRequestParams params, final FessConfig fessConfig) {
            return testContext != null ? testContext : super.createSearchLogContext(params, fessConfig);
        }
    }

    // Mock classes for addSearchLog tests

            Type2Message message = new Type2Message(mockContext);
            byte[] testContext =
                    new byte[] { (byte) 0x11, (byte) 0x22, (byte) 0x33, (byte) 0x44, (byte) 0x55, (byte) 0x66, (byte) 0x77, (byte) 0x88 };

            // When
            message.setContext(testContext);

            // Then
            assertArrayEquals(testContext, message.getContext());
        }
    }

    @Nested