text: /*
   * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS HEADER.
   *
   * Copyright (c) 2013-2017 Oracle and/or its affiliates. All rights reserved.
   *
   * The contents of this file are subject to the terms of either the GNU
   * General Public License Version 2 only ("GPL") or the Common Development
   * and Distribution License("CDDL") (collectively, the "License").  You
   * may not use this file except in compliance with the License.  You can
   * obtain a copy of the License at
   * https://oss.oracle.com/licenses/CDDL+GPL-1.1
   * or LICENSE.txt.  See the License for the specific
   * language governing permissions and limitations under the License.
   *
   * When distributing the software, include this License Header Notice in each
   * file and include the License file at LICENSE.txt.
   *
   * GPL Classpath Exception:
   * Oracle designates this particular file as subject to the "Classpath"
   * exception as provided by Oracle in the GPL Version 2 section of the License
   * file that accompanied this code.
   *
   * Modifications:
   * If applicable, add the following below the License Header, with the fields
   * enclosed by brackets [] replaced by your own identifying information:
   * "Portions Copyright [year] [name of copyright owner]"
   *
   * Contributor(s):
   * If you wish your version of this file to be governed by only the CDDL or
   * only the GPL Version 2, indicate your decision by adding "[Contributor]
   * elects to include this software in this distribution under the [CDDL or GPL
   * Version 2] license."  If you don't indicate a single choice of license, a
   * recipient has the option to distribute your version of this file under
   * either the CDDL, the GPL Version 2 or to extend the choice of license to
   * its licensees as provided above.  However, if you add GPL Version 2 code
   * and therefore, elected the GPL Version 2 license, then the option applies
   * only if the new code is made subject to such option by the copyright
   * holder.
   */
  
  package org.glassfish.jersey.tests.integration.tracing;
  
  import java.io.BufferedReader;
  import java.io.IOException;
  import java.io.InputStream;
  import java.io.InputStreamReader;
  import java.lang.annotation.Annotation;
  import java.lang.reflect.Type;
  
  import javax.ws.rs.Consumes;
  import javax.ws.rs.WebApplicationException;
  import javax.ws.rs.core.MediaType;
  import javax.ws.rs.core.MultivaluedMap;
  import javax.ws.rs.ext.MessageBodyReader;
  import javax.ws.rs.ext.Provider;
  
  import org.glassfish.jersey.message.MessageUtils;
  
  /**
   * @author Libor Kramolis (libor.kramolis at oracle.com)
   */
  @Provider
  @Consumes(Utils.APPLICATION_X_JERSEY_TEST)
  public class MessageBodyReaderTestFormat implements MessageBodyReader<Message> {
  
      boolean serverSide = true;
  
      public MessageBodyReaderTestFormat() {
      }
  
      public MessageBodyReaderTestFormat(final boolean serverSide) {
          this.serverSide = serverSide;
      }
  
      @Override
      public boolean isReadable(final Class<?> type, final Type genericType, final Annotation[] annotations,
                                final MediaType mediaType) {
          return type.isAssignableFrom(Message.class);
      }
  
      @Override
      public Message readFrom(final Class<Message> type, final Type genericType, final Annotation[] annotations,
                              final MediaType mediaType, final MultivaluedMap<String, String> httpHeaders,
                              final InputStream entityStream) throws IOException, WebApplicationException {
          final BufferedReader reader = new BufferedReader(new InputStreamReader(entityStream, MessageUtils.getCharset(mediaType)));
  
          final String line = reader.readLine();
          if (line == null || !line.startsWith(Utils.FORMAT_PREFIX) || !line.endsWith(Utils.FORMAT_SUFFIX)) {
              throw new WebApplicationException(
                      new IllegalArgumentException("Input content '" + line + "' is not in a valid format!"));
          }
          final String text = line.substring(Utils.FORMAT_PREFIX.length(), line.length() - Utils.FORMAT_SUFFIX.length());
  
          if (serverSide) {
              Utils.throwException(text, this,
                      Utils.TestAction.MESSAGE_BODY_READER_THROW_WEB_APPLICATION,
                      Utils.TestAction.MESSAGE_BODY_READER_THROW_PROCESSING,
                      Utils.TestAction.MESSAGE_BODY_READER_THROW_ANY);
          }
  
          return new Message(text);
      }
  }
  