| /* |
| * Copyright (c) 2016, 2021 Oracle and/or its affiliates. All rights reserved. |
| * |
| * This program and the accompanying materials are made available under the |
| * terms of the Eclipse Public License v. 2.0, which is available at |
| * http://www.eclipse.org/legal/epl-2.0. |
| * |
| * This Source Code may also be made available under the following Secondary |
| * Licenses when the conditions for such availability set forth in the |
| * Eclipse Public License v. 2.0 are satisfied: GNU General Public License, |
| * version 2 with the GNU Classpath Exception, which is available at |
| * https://www.gnu.org/software/classpath/license.html. |
| * |
| * SPDX-License-Identifier: EPL-2.0 OR GPL-2.0 WITH Classpath-exception-2.0 |
| */ |
| |
| package org.glassfish.jersey.logging; |
| |
| import java.io.IOException; |
| import java.io.OutputStream; |
| import java.util.logging.Level; |
| import java.util.logging.Logger; |
| |
| import javax.ws.rs.ConstrainedTo; |
| import javax.ws.rs.RuntimeType; |
| import javax.ws.rs.client.ClientRequestContext; |
| import javax.ws.rs.client.ClientRequestFilter; |
| import javax.ws.rs.client.ClientResponseContext; |
| import javax.ws.rs.client.ClientResponseFilter; |
| import javax.ws.rs.container.PreMatching; |
| import javax.ws.rs.core.FeatureContext; |
| |
| import javax.annotation.Priority; |
| |
| import org.glassfish.jersey.logging.LoggingFeature.Verbosity; |
| import org.glassfish.jersey.message.MessageUtils; |
| |
| /** |
| * Client filter logs requests and responses to specified logger, at required level, with entity or not. |
| * <p> |
| * The filter is registered in {@link LoggingFeature#configure(FeatureContext)} and can be used on client side only. The priority |
| * is set to the minimum value, which means that filter is called as the last filter when request is sent and similarly as the |
| * first filter when the response is received, so request and response is logged as sent or as received. |
| * |
| * @author Pavel Bucek |
| * @author Martin Matula |
| * @author Ondrej Kosatka |
| */ |
| @ConstrainedTo(RuntimeType.CLIENT) |
| @PreMatching |
| @Priority(Integer.MAX_VALUE) |
| @SuppressWarnings("ClassWithMultipleLoggers") |
| final class ClientLoggingFilter extends LoggingInterceptor implements ClientRequestFilter, ClientResponseFilter { |
| |
| /** |
| * Create a logging filter using builder instance with custom logger and custom settings of entity |
| * logging. |
| * |
| * @param builder loggingFeatureBuilder which contains values for: |
| * logger the logger to log messages to. |
| * level level at which the messages will be logged. |
| * verbosity verbosity of the logged messages. See {@link Verbosity}. |
| * maxEntitySize maximum number of entity bytes to be logged (and buffered) - if the entity is larger, |
| * logging filter will print (and buffer in memory) only the specified number of bytes |
| * and print "...more..." string at the end. Negative values are interpreted as zero. |
| * separator delimiter for particular log lines. Default is Linux new line delimiter |
| */ |
| public ClientLoggingFilter(LoggingFeature.LoggingFeatureBuilder builder) { |
| super(builder); |
| } |
| |
| @Override |
| public void filter(final ClientRequestContext context) throws IOException { |
| if (!logger.isLoggable(level)) { |
| return; |
| } |
| final long id = _id.incrementAndGet(); |
| context.setProperty(LOGGING_ID_PROPERTY, id); |
| |
| final StringBuilder b = new StringBuilder(); |
| |
| printRequestLine(b, "Sending client request", id, context.getMethod(), context.getUri()); |
| printPrefixedHeaders(b, id, REQUEST_PREFIX, context.getStringHeaders()); |
| |
| if (context.hasEntity() && printEntity(verbosity, context.getMediaType())) { |
| final OutputStream stream = new LoggingStream(b, context.getEntityStream()); |
| context.setEntityStream(stream); |
| context.setProperty(ENTITY_LOGGER_PROPERTY, stream); |
| // not calling log(b) here - it will be called by the interceptor |
| } else { |
| log(b); |
| } |
| } |
| |
| @Override |
| public void filter(final ClientRequestContext requestContext, final ClientResponseContext responseContext) |
| throws IOException { |
| if (!logger.isLoggable(level)) { |
| return; |
| } |
| final Object requestId = requestContext.getProperty(LOGGING_ID_PROPERTY); |
| final long id = requestId != null ? (Long) requestId : _id.incrementAndGet(); |
| |
| final StringBuilder b = new StringBuilder(); |
| |
| printResponseLine(b, "Client response received", id, responseContext.getStatus()); |
| printPrefixedHeaders(b, id, RESPONSE_PREFIX, responseContext.getHeaders()); |
| |
| if (responseContext.hasEntity() && printEntity(verbosity, responseContext.getMediaType())) { |
| responseContext.setEntityStream(logInboundEntity(b, responseContext.getEntityStream(), |
| MessageUtils.getCharset(responseContext.getMediaType()))); |
| } |
| |
| log(b); |
| } |
| } |