createCapturingHelper("node1@host1", null, capturedBody, createMockResponse(200, "{\"hits\":{\"hits\":[]}}"));
        setLastEventCheckTime(helper, 1000L);

        helper.fetchNewEvents();

        assertNotNull(capturedBody.get());
        assertTrue(capturedBody.get().contains("\"event\""));
        assertTrue(capturedBody.get().contains("\"minimum_should_match\":1"));

    }

    /**
     * Fetches new events from OpenSearch that were created after the last check time.
     *
     * @return the list of new events.
     */
    protected List<EventInfo> fetchNewEvents() {
        final List<EventInfo> events = new ArrayList<>();
        final String query = toJson(Map.of( //
                "query", Map.of("bool", Map.of( //
                        "must", List.of( //