try {
            writer.write("event: " + event + "\n");
            writer.write("data: " + objectMapper.writeValueAsString(data) + "\n\n");
            writer.flush();
        } catch (final JsonProcessingException e) {
            logger.warn("[RAG] Failed to serialize SSE data. event={}", event, e);
        }
    }

    /**

     * @param map the map to serialize.
     * @return the JSON string, or {@code "{}"} on failure.
     */
    protected String toJson(final Map<String, Object> map) {
        try {
            return objectMapper.writeValueAsString(map);
        } catch (final Exception e) {
            logger.warn("Failed to serialize JSON.", e);
            return "{}";
        }
    }

    /**
     * Parses a JSON string into a map.

     */
    public void writeSearchLogEvent(final SearchLogEvent event) {
        try {
            final Map<String, Object> source = toSource(event);
            searchLogLogger.info(objectMapper.writeValueAsString(source));
        } catch (final JsonProcessingException e) {
            logger.warn("Failed to write {}", event, e);
        }
    }

    /**
    * Converts a search log event to a source map.