private ScheduledJob createTestScheduledJob(final String id, final boolean loggingEnabled) {
        final ScheduledJob scheduledJob = new ScheduledJob();
        scheduledJob.setId(id);
        scheduledJob.setName("Test Job");
        scheduledJob.setScriptType("groovy");
        scheduledJob.setScriptData("println 'test'");
        scheduledJob.setJobLogging(loggingEnabled ? Constants.T : Constants.F);

    }

    private static void storeAnalyzerSettings() throws Exception {
        // Store analyzer mappings
        client.prepareIndex()
                .setIndex(SUGGEST_INDEX)
                .setId("analyzer_settings")
                .setSource(XContentFactory.jsonBuilder()
                        .startObject()
                        .startObject("analyzer")

    return {"message": "Hello World"}


app.add_api_route("/non_decorated_route", non_decorated_route)


@app.get("/text")
def get_text():
    return "Hello World"


@app.get("/path/{item_id}")
def get_id(item_id):
    return item_id


@app.get("/path/str/{item_id}")
def get_str_id(item_id: str):
    return item_id


@app.get("/path/int/{item_id}")
def get_int_id(item_id: int):
    return item_id

            }
        }

        final BulkRequestBuilder bulkDelete = client.prepareBulk();
        for (final String docId : docIds) {
            bulkDelete.add(client.prepareDelete().setIndex(indexName).setId(docId));
        }
        bulkDelete.execute().actionGet(fessConfig.getIndexSearchTimeout());

        // Delete any remaining events beyond the search size limit (discard overflow)
        try {

        final List<ChatSource> sources = new ArrayList<>();

        message.setId("msg-123");
        message.setRole("assistant");
        message.setContent("Test content");
        message.setTimestamp(timestamp);
        message.setSources(sources);

        assertEquals("msg-123", message.getId());
        assertEquals("assistant", message.getRole());

        if (configMap == null) {
            return Collections.emptyMap();
        }
        return configMap;
    }

    @Override
    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    public Long getVersionNo() {
        return asDocMeta().version();
    }

        when(tree.isConnected()).thenReturn(true);
        assertTrue(h.isValid());
        h.markClosed();
        assertFalse(h.isValid());
    }

    @Test
    @DisplayName("getFid/getFileId throw SmbException when invalid")
    void getters_throw_whenInvalid() {
        when(cfg.isTraceResourceUsage()).thenReturn(false);
        stubValidTree(1L, true, true);

        if (configMap == null) {
            return Collections.emptyMap();
        }
        return configMap;
    }

    @Override
    public String getId() {
        return asDocMeta().id();
    }

    public void setId(final String id) {
        asDocMeta().id(id);
    }

    public Long getVersionNo() {
        return asDocMeta().version();
    }

        void testGetTid() {
            // Given
            when(mockResponse.getTid()).thenReturn(12345);

            // When
            int tid = mockResponse.getTid();

            // Then
            assertEquals(12345, tid, "Should return the configured tree ID");
            verify(mockResponse).getTid();
        }

        @Test
        @DisplayName("Should return service type")

    /**
     * @return
     * @throws IOException
     */
    private int negotiateWrite(final CommonServerMessageBlockRequest req, final boolean setmid) throws IOException {
        if (setmid) {
            makeKey(req);
        } else {
            req.setMid(0);
            this.mid.set(1);
        }
        final int n = req.encode(this.sbuf, 4);