private static final String PROTWORDS = "protwords";

    List<ProtwordsItem> protwordsItemList;

    /**
     * Constructor for ProtwordsFile.
     * @param id the file identifier
     * @param path the file path
     * @param timestamp the file timestamp
     */
    public ProtwordsFile(final String id, final String path, final Date timestamp) {
        super(id, path, timestamp);
    }

     * @return an OptionalThing containing the pipeline string if found, or empty if not found or blank
     */
    public OptionalThing<String> getPipeline(final String configId) {
        final CrawlingConfig config = getCrawlingConfig(configId);
        if (config == null) {
            return OptionalThing.empty();
        }
        final String pipeline = config.getConfigParameterMap(ConfigName.CONFIG).get(Config.PIPELINE);

            assertEquals("Expected structureSize = 4", exception.getMessage());
        }

        @Test
        @DisplayName("Should correctly calculate bytes read from different starting positions")
        void testReadBytesWireFormatDifferentStartPositions() throws SMBProtocolDecodingException {
            // Given
            byte[] buffer = new byte[20];

            // Test at different positions

            return parent;
        }

        @Override
        public String getQuery() {
            return parent.getQuery();
        }

        @Override
        public Map<String, String[]> getFields() {
            return parent.getFields();
        }

        @Override
        public Map<String, String[]> getConditions() {
            return parent.getConditions();
        }

    protected static final String ID_TOKEN = "id_token";

    /** OAuth2 authorization code parameter name. */
    protected static final String CODE = "code";

    /** Timeout for token acquisition in milliseconds. */
    protected long acquisitionTimeout = 30 * 1000L;

    /** Cache for storing group information to reduce API calls. */
    protected Cache<String, Pair<String[], String[]>> groupCache;

    }
    return new String(is.readAllBytes(), StandardCharsets.UTF_8);
}
```

---

## Quick Reference

### Essential Files

| File | Purpose |
|------|---------|
| `Suggester.java` | Main entry point, index management |
| `SuggestIndexer.java` | Indexing operations |
| `SuggestRequest.java` | Query building, scoring |
| `SuggestSettings.java` | Configuration |

        this.maxFragmentedSize = RdmaCapabilities.DEFAULT_MAX_FRAGMENTED_SIZE;
    }

    /**
     * Decode from byte array
     *
     * @param data source data
     * @param offset starting offset
     * @return decoded response
     */
    public static SmbDirectNegotiateResponse decode(byte[] data, int offset) {
        if (data.length - offset < 32) {

        }
        return OptionalEntity.of(list.get(0));
    }

    /**
     * Stores (inserts or updates) a data configuration.
     *
     * <p>This method encrypts sensitive handler parameters before storing
     * and immediately refreshes the index to ensure the change is visible.
     * If the configuration already exists (based on ID), it will be updated;
     * otherwise, a new configuration will be created.</p>
     *

        // Test with various path formats
        String[] testPaths = { "simple.txt", "path/to/file.doc", "//server/share/file.txt", "folder\\windows\\style.txt", "" // empty path
        };

        for (String path : testPaths) {
            trans2QueryPathInfo = new Trans2QueryPathInformation(config, path, TEST_INFO_LEVEL);
            String result = trans2QueryPathInfo.toString();

            assertNotNull(result);

    /** The original query string provided by the user. */
    protected String queryString;

    /** Set of query terms that should be highlighted in search results. */
    protected Set<String> highlightedQuerySet = null;

    /** Map storing field names and their associated query terms for logging. */
    protected Map<String, List<String>> fieldLogMap = null;