Shinsuke Sugaya <******@****.***> 1774681159 +0900

Shinsuke Sugaya <******@****.***> 1774681159 +0900

        verifyToken(this::asIndexHtml);
        final CoordinatorHelper coordinator = ComponentUtil.getCoordinatorHelper();
        if (!coordinator.tryStartOperation("reload_doc_index")) {
            saveError(messages -> messages.addErrorsOperationAlreadyRunning(GLOBAL,
                    coordinator.getOperationInfo("reload_doc_index").map(o -> o.hostname).orElse("unknown")));
            return redirect(getClass());

    //                                                                        ============

    /**
     * Returns the coordinator index name, adjusted for the configured index prefix.
     *
     * @return the coordinator index name.
     */
    protected String getIndexName() {
        final FessConfig fessConfig = ComponentUtil.getFessConfig();

		</postConstruct>
		<postConstruct name="addIndexConfig">
			<arg>"fess_config.web_config/web_config"</arg>
		</postConstruct>
		<postConstruct name="addIndexConfig">
			<arg>"fess_config.coordinator/coordinator"</arg>
		</postConstruct>
		<!-- fess_user index -->
		<postConstruct name="addIndexConfig">
			<arg>"fess_user.user/user"</arg>
		</postConstruct>
		<postConstruct name="addIndexConfig">

     * @return The curl helper.
     */
    public static CurlHelper getCurlHelper() {
        return getComponent(CURL_HELPER);
    }

    /**
     * Gets the coordinator helper component.
     * @return The coordinator helper.
     */
    public static CoordinatorHelper getCoordinatorHelper() {
        return getComponent(COORDINATOR_HELPER);
    }

    /**

            @Override
            public String getIndexConfigIndex() {
                return "fess_config";
            }
        });
        assertEquals("fess_config.coordinator", coordinatorHelper.getIndexName());
    }

    @Test
    public void test_getIndexName_custom() {
        ComponentUtil.setFessConfig(new FessConfig.SimpleImpl() {

#                                                Coordinator
#                                                     ------

# Interval (seconds) for polling heartbeats and events.
coordinator.poll.interval=60
# Time-to-live (ms) for instance heartbeat documents.
coordinator.heartbeat.ttl=180000
# Time-to-live (ms) for operation lock documents.
coordinator.operation.ttl=7200000

    /** The key of the configuration. e.g. 60 */
    String COORDINATOR_POLL_INTERVAL = "coordinator.poll.interval";

    /** The key of the configuration. e.g. 180000 */
    String COORDINATOR_HEARTBEAT_TTL = "coordinator.heartbeat.ttl";

    /** The key of the configuration. e.g. 7200000 */
    String COORDINATOR_OPERATION_TTL = "coordinator.operation.ttl";

    /** The key of the configuration. e.g. 3 */

 * This class serves as the entry point for crawling web content, file systems, and data stores.
 * It manages the crawling lifecycle, including initialization, execution coordination,
 * monitoring, and cleanup operations.
 *
 * <p>The crawler can operate in different modes based on command-line options:
 * <ul>
 * <li>Web crawling - crawls web sites and web content</li>