import java.util.Map;
import java.util.stream.Collectors;

import org.apache.logging.log4j.LogManager;
import org.apache.logging.log4j.Logger;
import org.codelibs.core.lang.StringUtil;
import org.codelibs.fess.crawler.Constants;
import org.codelibs.fess.exception.StorageException;

import software.amazon.awssdk.auth.credentials.AwsBasicCredentials;
import software.amazon.awssdk.auth.credentials.StaticCredentialsProvider;

 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND,
 * either express or implied. See the License for the specific language
 * governing permissions and limitations under the License.
 */
package org.codelibs.fess.crawler.helper;

import java.io.ByteArrayInputStream;
import java.io.IOException;
import java.io.InputStream;
import java.nio.charset.StandardCharsets;

import org.codelibs.fess.mylasta.direction.FessConfig;

        String arg0 = "crawler";
        FessMessages result = messages.addSuccessJobStarted(property, arg0);
        assertNotNull(result);
        assertSame(messages, result);
        assertTrue(messages.hasMessageOf(property));
    }

    @Test
    public void test_addSuccessJobStopped() {
        String property = "testProperty";
        String arg0 = "crawler";

import java.util.List;

import org.codelibs.fess.util.ComponentUtil;

/**
 * A pager class for managing pagination of failure URL records.
 * This class provides functionality to handle pagination of failed crawler URLs
 * with search filters and navigation capabilities.
 */
public class FailureUrlPager implements Serializable {

    /** Serial version UID for serialization compatibility. */

   encodedUsername, fragment, host, password, pathSegments, pathSize, port, query,
   queryParameterNames, querySize, scheme, username
 * **MockResponse**: headers, http2ErrorCode, socketPolicy, status, trailers
 * **MockWebServer**: bodyLimit, port, protocolNegotiationEnabled, protocols, requestCount,
   serverSocketFactory
 * **MultipartBody.Part**: body, headers
 * **MultipartBody.**: boundary, parts, size, type

import org.codelibs.core.misc.DynamicProperties;
import org.codelibs.core.timer.TimeoutManager;
import org.codelibs.core.timer.TimeoutTask;
import org.codelibs.fess.Constants;
import org.codelibs.fess.crawler.client.FesenClient;
import org.codelibs.fess.exception.ContainerNotAvailableException;
import org.codelibs.fess.opensearch.client.SearchEngineClient;
import org.codelibs.fess.timer.LogNotificationTarget;

        try {
            final RESULT result = entityType.newInstance();
            result.setAvailable(DfTypeUtil.toBoolean(source.get("available")));
            result.setCrawler(DfTypeUtil.toBoolean(source.get("crawler")));
            result.setCreatedBy(DfTypeUtil.toString(source.get("createdBy")));
            result.setCreatedTime(DfTypeUtil.toLong(source.get("createdTime")));

///

Nous pouvons également utiliser cette même approche pour accéder au corps de la requête dans un gestionnaire d'exceptions.

Il suffit de traiter la requête dans un bloc `try`/`except` :

{* ../../docs_src/custom_request_and_route/tutorial002_an_py310.py hl[14,16] *}

errors.password_is_blacklisted = To hasło jest niedozwolone. Proszę wybrać inne hasło.
errors.invalid_confirm_password = Potwierdzenie hasła nie pasuje.
errors.cannot_delete_doc_because_of_running = Crawler jest uruchomiony. Nie można usunąć dokumentu.
errors.failed_to_delete_doc_in_admin = Nie można usunąć dokumentu.
errors.failed_to_send_testmail=Nie można wysłać e-maila testowego.

  }

  @Test @Disabled
  fun mockResponse() {
    val mockResponse = MockResponse()
    var status: String = mockResponse.getStatus()
    var headers: Headers = mockResponse.getHeaders()
    var trailers: Headers = mockResponse.getTrailers()
    var socketPolicy: SocketPolicy = mockResponse.getSocketPolicy()
    var http2ErrorCode: Int = mockResponse.getHttp2ErrorCode()
  }

  @Test @Disabled