Installation instruction

'parameters':
  'elasticsearchTemplate': 'elasticsearch_query.json'
  'elasticsearch':
    'jsoupSelectId': 'content'
    'jsoupSelectTag': 'main'
    'jsoupRemoveElements':
      '0': '[data-noindex]'
    'indexfields':
      'description': 'description'
      'language': 'Content-Language'
      'title': 'title'

'mappings':
  'website':
    'URIPrefix': ''
    'handlePrefix': '/b2c_de'
    'repository': 'website'
  'dam':
    'URIPrefix': ''
    'handlePrefix': '/b2c'
    'repository': 'dam'

@Slf4j
public class CustomSearchService extends SearchServiceImpl {

        private static final String ELASTIC_TEMPLATE = "elasticsearch_query_fallback.json";

    private static final String SITE_PARAM_SEARCH_KEY = "elasticsearchTemplate";
    private final SiteManager siteManager;

    @Inject
    public RodenstockSearchService(Provider<SearchServiceModule> searchServiceModule, EsStringSanitizer esStringSanitizer, ObjectMapper objectMapper, SiteManager siteManager) {
        super(searchServiceModule, esStringSanitizer, objectMapper, siteManager);
        this.siteManager = siteManager;
    }

    @Override
    public void createElasticsearchRequest(SearchPageRequest searchPageRequest, Request request, String queryTerm) {
        String templateName = tryGetTemplateNameFromSiteParameter(searchPageRequest);
        String queryTemplate = StringUtils.isNotBlank(templateName)
                ? readElasticQueryTemplateFromFile(templateName)
                : readElasticQueryTemplateFromFile(ELASTIC_TEMPLATE);

        if (StringUtils.isBlank(queryTemplate) || queryTemplate.equals("{}")) {
            // Fallback to Default Search Config
            super.createElasticsearchRequest(searchPageRequest, request, queryTerm);
        } else {
            request.setJsonEntity(String.format(queryTemplate,
                    searchPageRequest.getPageFrom(),
                    SearchPageRequest.getPageSize(),
                    searchPageRequest.getLocale(),
                    StringEscapeUtils.escapeJson(queryTerm),
                    StringEscapeUtils.escapeJson(queryTerm),
                    StringEscapeUtils.escapeJson(queryTerm)));
        }
    }

    /**
     * This method tries to read the custom query template from the classpath.
     *
     * @param templateName the name of the template to read
     * @return the template as a string
     */
    private String readElasticQueryTemplateFromFile(String templateName) {
        try (var inputStream = getClass().getResourceAsStream("/" + templateName)){
            if (inputStream != null) {
                return new String(inputStream.readAllBytes(), StandardCharsets.UTF_8);
            }
        } catch (IOException e) {
            log.error("Error reading custom query template", e);
        }
        return "{}";
    }

    /**
     * This method tries to get the template name from the site parameter.
     * @param searchPageRequest the search page request
     * @return the template name or null if not found
     */
    @Nullable
    private String tryGetTemplateNameFromSiteParameter(SearchPageRequest searchPageRequest) {
        Site site = this.siteManager.getSite(searchPageRequest.getSite());

        if (site != null && !(site instanceof NullSite) && site.getParameters() != null) {
            return site.getParameters().containsKey(SITE_PARAM_SEARCH_KEY) ? site.getParameters().get(SITE_PARAM_SEARCH_KEY).toString() : null;
        }
        return null;
    }
}

<components>
    <component>
        <type>com.raysono.magnolia.search.service.service.SearchServiceImpl</type>
        <implementation>com.raysono.search.service.CustomSearchService</implementation>
        <scope>singleton</scope>
    </component>
</components>