private fun acceptCommand(
    fromAddress: InetAddress,
    fromSource: BufferedSource,
    fromSink: BufferedSink,
  ) {
    // Read the command.
    val version = fromSource.readByte() and 0xff
    if (version != VERSION_5) throw ProtocolException("unexpected version: $version")

    val command = fromSource.readByte() and 0xff

    val reserved = fromSource.readByte() and 0xff

    /**
     * Parses a source map from OpenSearch and creates a SuggestItem.
     *
     * @param source The source map from OpenSearch
     * @return A new SuggestItem instance
     */
    public static SuggestItem fromSource(final Map<String, Object> source) {
        final String text = source.get(FieldNames.TEXT).toString();
        final List<String[]> readings = new ArrayList<>();
        for (int i = 0;; i++) {

        source.put(FieldNames.KINDS, Arrays.asList("document"));
        source.put(FieldNames.TIMESTAMP, System.currentTimeMillis());

        SuggestItem item = SuggestItemSerializer.fromSource(source);

        assertNotNull(item);
        assertEquals("test text", item.getText());
        assertEquals(10L, item.getDocFreq());
        assertEquals(5L, item.getQueryFreq());

     * @param source The source map.
     * @return A SuggestItem instance.
     */
    public static SuggestItem parseSource(final Map<String, Object> source) {
        return SuggestItemSerializer.fromSource(source);
    }

    /**
     * Returns the updated source map by merging with existing source.
     * @param existingSource The existing source map.
     * @return The updated source map.
     */