package org.oxerr.chbtc.dto.valuereader;
   
   import java.io.IOException;
   import java.io.InputStream;
   
   import org.apache.commons.io.IOUtils;
   import org.oxerr.chbtc.CHBTCClientException;
   import org.oxerr.chbtc.dto.CHBTCError;
   import org.slf4j.Logger;
  import org.slf4j.LoggerFactory;
  
  import com.fasterxml.jackson.core.type.TypeReference;
  import com.fasterxml.jackson.databind.JsonMappingException;
  import com.fasterxml.jackson.databind.ObjectMapper;
  
  public class ErrorableJsonValueTypeRefReader<T> extends JsonValueTypeRefReader<T> {
  
  	private final Logger log = LoggerFactory.getLogger(getClass());
  
  	private final ObjectMapper objectMapper;
  
  	private final TypeReference<T> valueTypeRef;
  
  	public ErrorableJsonValueTypeRefReader(ObjectMapper objectMapper,
  			TypeReference<T> valueTypeRef) {
  		super(objectMapper, valueTypeRef);
  
  		this.objectMapper = objectMapper;
  		this.valueTypeRef = valueTypeRef;
  	}
  
  	@Override
  	public T read(final InputStream inputStream) throws IOException {
  		String content = IOUtils.toString(inputStream);
  
  		if (log.isTraceEnabled()) {
  			log.trace("content: {}", content);
  		}
  
  		try {
  			return objectMapper.readValue(content, valueTypeRef);
  		} catch (JsonMappingException e) {
  			CHBTCError error = objectMapper.readValue(
  					content, CHBTCError.class);
  			throw new CHBTCClientException(error);
  		}
  	}
  
  }