}).orElse(() -> {
            throwValidationErrorApi(messages -> {
                messages.addErrorsFailedToStartJob(GLOBAL, id);
            });
        });
        return asJson(new ApiResponse().status(Status.OK).result());
    }

    /**
     * Stops a scheduled job by ID.
     *
     * @param id the ID of the scheduled job to stop
     * @return JSON response indicating success or failure
     */

                new ApiResult.ApiConfigsResponse<EditBody>().settings(list.stream().map(this::createEditBody).collect(Collectors.toList()))
                        .total(pager.getAllRecordCount())
                        .status(ApiResult.Status.OK)
                        .result());
    }

    /**
     * Retrieves a specific user setting by ID.
     *
     * @param id the ID of the user setting to retrieve

    // Status Constants
    // ============================================================

    /** Status constant representing ready state. */
    public static final String READY = "ready";

    /** Status constant representing running state. */
    public static final String RUNNING = "running";

    /** Status constant representing done/completed state. */

    }

    /**
     * Gets the HTTP status code of the response.
     *
     * @return the HTTP status code.
     */
    public int getHttpStatusCode() {
        return httpStatusCode;
    }

    /**
     * Sets the HTTP status code for the response.
     *
     * @param httpStatusCode the HTTP status code to set.
     */

                if (className.startsWith(prefix)) {
                    return ObjectInputFilter.Status.ALLOWED;
                }
            } else if (className.equals(allowedPattern)) {
                return ObjectInputFilter.Status.ALLOWED;
            }
        }

        // Reject everything else
        return ObjectInputFilter.Status.REJECTED;
    };

    /**
     * Tests if the object can be serialized.
     *

    /** Configuration key for crawler clients used in parameter maps */
    protected static final String CRAWLER_CLIENTS = "crawlerClients";

    /** HTTP status code for Not Found */
    private static final int HTTP_STATUS_NOT_FOUND = 404;

    /** HTTP status code for OK */
    private static final int HTTP_STATUS_OK = 200;

    /**
     * Cache for client rules mapping client names to their corresponding URL patterns.

    }

    /**
     * Writes a JSON response.
     * @param status The status code.
     * @param t The throwable.
     */
    protected void writeJsonResponse(final int status, final Throwable t) {
        final Supplier<String> stacktraceString = () -> {
            final StringBuilder buf = new StringBuilder(100);

        }
    }

    /**
     * Stops the crawling process.
     * Sets the crawler status to DONE and interrupts all crawler threads.
     */
    public void stop() {
        if (logger.isInfoEnabled()) {
            logger.info("Stopping crawler: sessionId={}, status={}", crawlerContext.sessionId, crawlerContext.getStatus());
        }
        crawlerContext.setStatus(CrawlerStatus.DONE);

    /**
     * Interval in milliseconds between crawler thread executions.
     * Used to control the rate at which new crawler threads are started
     * and the frequency of status checks.
     */
    protected long crawlingExecutionInterval = Constants.DEFAULT_CRAWLING_EXECUTION_INTERVAL;

    /**
     * Thread priority for crawler threads.
     * Defaults to normal thread priority.
     */

     */
    private static final String[] ACCESS_RESULT_FIELDS = { "parentUrl", "method", "mimeType", "sessionId", "url", "executionTime",
            "createTime", "contentLength", "lastModified", "ruleId", "httpStatusCode", "status" };

    /**
     * Creates a new instance of OpenSearchDataService.
     * @param crawlerConfig The crawler configuration.
     */
    public OpenSearchDataService(final OpenSearchCrawlerConfig crawlerConfig) {