import org.lastaflute.web.validation.VaErrorHook;

public class LoginAction extends FessLoginAction {

    private static final Logger logger = LogManager.getLogger(LoginAction.class);

    private static final String INVALID_OLD_PASSWORD = "LoginAction.invalidOldPassword";

    // ===================================================================================
    // Attribute
    //
    @Resource
    private UserService userService;

import org.opensearch.index.query.QueryBuilders;

public class DataIndexHelper {

    private static final Logger logger = LogManager.getLogger(DataIndexHelper.class);

    private static final String DELETE_OLD_DOCS = "delete_old_docs";

    private static final String KEEP_EXPIRES_DOCS = "keep_expires_docs";

    protected long crawlingExecutionInterval = Constants.DEFAULT_CRAWLING_EXECUTION_INTERVAL;

                    dc_list_expiration = now + CACHE_POLICY * 1000L;
                    if (list != null && list.length > 0) {
                        dc_list = list;
                    } else { /* keep using the old list */
                        dc_list_expiration = now + 1000 * 60 * 15; /* 15 min */
                        if (SmbTransport.log.level >= 2) {

                    return oldItem;
                }
                if (!item.equals(oldItem)) {
                    throw new DictionaryException("StemmerOverride file was updated: old=" + oldItem + " : new=" + item);
                }
                try {
                    if (!item.isDeleted()) {
                        // update
                        writer.write(item.toLineString());

            assertEquals("1.2.3.4", fl.getServerWithDfs());
            assertEquals("other", fl.getShare());
            assertEquals("\\foo\\bar\\", fl.getUNCPath());
            // this intentionally sticks to the old name
            assertEquals("/share/foo/bar/", fl.getURLPath());
        }
    }


    @Test
    public void testDfsReferralShareNested () throws MalformedURLException, CIFSException {

                if ( list != null && list.length > 0 ) {
                    this.dcList = list;
                }
                else { /* keep using the old list */
                    this.dcListExpiration = now + 1000 * 60 * 15; /* 15 min */
                    log.warn("Failed to retrieve DC list from WINS");
                }
            }

                    return oldItem;
                }
                if (!item.equals(oldItem)) {
                    throw new DictionaryException("Protwords file was updated: old=" + oldItem + " : new=" + item);
                }
                try {
                    if (!item.isDeleted()) {
                        // update
                        writer.write(item.toLineString());

    @Override
    public void hook(final FwAssistantDirector assistantDirector) {
        shutdownCommonsHttpClient();
    }

    private void shutdownCommonsHttpClient() { // from Tomcat7ConfigServlet (old class)
        try {
            final Class<?> clazz = Class.forName("org.apache.commons.httpclient.MultiThreadedHttpConnectionManager");
            final Method method = clazz.getMethod("shutdownAll", (Class<?>[]) null);

        }
        return null;
    }


    /**
     * @param t
     */
    private synchronized void switchTree ( SmbTreeImpl t ) {
        try ( SmbTreeImpl old = getTree() ) {
            if ( old == t ) {
                return;
            }
            boolean wasAcquired = this.treeAcquired;
            log.debug("Switching tree");
            if ( t != null ) {

            synchronized (searchEngineClient) {
                final long deletedDocCount = deleteOldDocuments(searchEngineClient, docList);
                if (logger.isDebugEnabled()) {
                    logger.debug("Deleted {} old docs", deletedDocCount);
                }
                searchEngineClient.addAll(fessConfig.getIndexDocumentUpdateIndex(), docList, (doc, builder) -> {