if (varyFields.isEmpty()) return Headers.EMPTY

      val result = Headers.Builder()
      for (i in 0 until requestHeaders.size) {
        val fieldName = requestHeaders.name(i)
        if (fieldName in varyFields) {
          result.add(fieldName, requestHeaders.value(i))
        }
      }
      return result.build()
    }
  }

    /**
     * Decodes a resource change notification message.
     */
    private void decodeResourceChangeMessage(NdrBuffer buf, WitnessNotificationMessage message) throws NdrException {
        // Timestamp (FILETIME - 64-bit)
        long timestamp = buf.dec_ndr_hyper();
        message.setTimestamp(timestamp);

        // Resource name
        String resourceName = decodeWideStringPointer(buf);

    }

    @Test
    void testGetPipe() throws CIFSException, MalformedURLException {
        // Test getPipe(String url, int pipeType) method
        String url = "smb://server/IPC$/pipeName"; // Corrected URL for named pipe
        int pipeType = 1;
        SmbPipeResource mockSmbPipeResource = mock(SmbNamedPipe.class);

        // Similar to testGetSmbResource, we cannot directly mock `new SmbNamedPipe()`.

    }

    protected static Analyzer getAnalyzer(final boolean ignoreCase) {
        return new Analyzer() {
            @Override
            protected TokenStreamComponents createComponents(final String fieldName) {
                final Tokenizer tokenizer = new KeywordTokenizer();
                final TokenStream stream = ignoreCase ? new LowerCaseFilter(tokenizer) : tokenizer;

        // Query was processed successfully

        // Query was processed successfully
        WildcardQueryBuilder wqb = (WildcardQueryBuilder) queryBuilder;
        assertEquals("title", wqb.fieldName());
    }

    @Test
    public void test_convertWildcardQuery_nonSearchField() throws Exception {
        // Test with DEFAULT_FIELD when field is not a search field

        assertDoesNotThrow(() -> InputValidator.validateSmbPath(path));
    }

    @ParameterizedTest
    @DisplayName("Test invalid path characters")
    @ValueSource(strings = { "file:name.txt", "file<name>.txt", "file|name.txt", "file*name.txt", "file?name.txt", "file\"name.txt" })
    void testInvalidPathCharacters(String path) {

    private java.lang.reflect.Field findField(Class<?> clazz, String fieldName) {
        while (clazz != null) {
            try {
                return clazz.getDeclaredField(fieldName);
            } catch (final NoSuchFieldException e) {
                clazz = clazz.getSuperclass();
            }
        }
        throw new RuntimeException("Field not found: " + fieldName);
    }

import java.nio.file.Files;
import java.nio.file.NoSuchFileException;
import java.nio.file.Path;
import java.nio.file.SimpleFileVisitor;
import java.nio.file.attribute.BasicFileAttributes;
import java.nio.file.attribute.FileTime;
import java.util.EnumSet;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Future;
import junit.framework.TestCase;
import junit.framework.TestSuite;
import org.jspecify.annotations.NullUnmarked;

        byte[] buffer = new byte[8];
        ServerMessageBlock.writeTime(0, buffer, 0);
        // When zero is written, it stays as zero in buffer
        // When read back, it converts to negative Unix time due to Windows FileTime conversion
        long expectedTime = -SmbConstants.MILLISECONDS_BETWEEN_1970_AND_1601;
        assertEquals(expectedTime, ServerMessageBlock.readTime(buffer, 0));
    }

    @Test
    void testUTimeReadWrite() {

        // Verify that the query was processed successfully
        assertTrue(result instanceof FuzzyQueryBuilder);
        FuzzyQueryBuilder fqb = (FuzzyQueryBuilder) result;
        assertEquals("title", fqb.fieldName());
        assertEquals(searchText, fqb.value());
    }

    // Test with special characters in term text
    @Test
    public void test_convertFuzzyQuery_withSpecialCharacters() {