package org.glassfish.jersey.jaxb.internal;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.lang.annotation.Annotation;
import java.lang.reflect.Type;
import jakarta.ws.rs.BadRequestException;
import jakarta.ws.rs.Consumes;
import jakarta.ws.rs.InternalServerErrorException;
import jakarta.ws.rs.Produces;
import jakarta.ws.rs.WebApplicationException;
import jakarta.ws.rs.core.Context;
import jakarta.ws.rs.core.MediaType;
import jakarta.ws.rs.core.MultivaluedMap;
import jakarta.ws.rs.core.NoContentException;
import jakarta.ws.rs.ext.Providers;
import jakarta.inject.Provider;
import jakarta.inject.Singleton;
import jakarta.xml.bind.JAXBContext;
import jakarta.xml.bind.JAXBException;
import jakarta.xml.bind.UnmarshalException;
import jakarta.xml.bind.Unmarshaller;
import javax.xml.parsers.SAXParserFactory;
import org.glassfish.jersey.message.internal.EntityInputStream;
public abstract class XmlRootObjectJaxbProvider extends AbstractJaxbProvider<Object> {
private final Provider<SAXParserFactory> spf;
XmlRootObjectJaxbProvider(Provider<SAXParserFactory> spf, Providers ps) {
super(ps);
this.spf = spf;
}
XmlRootObjectJaxbProvider(Provider<SAXParserFactory> spf, Providers ps, MediaType mt) {
super(ps, mt);
this.spf = spf;
}
@Override
protected JAXBContext getStoredJaxbContext(Class type) throws JAXBException {
return null;
}
@Produces("application/xml")
@Consumes("application/xml")
@Singleton
public static final class App extends XmlRootObjectJaxbProvider {
public App(@Context Provider<SAXParserFactory> spf, @Context Providers ps) {
super(spf, ps, MediaType.APPLICATION_XML_TYPE);
}
}
@Produces("text/xml")
@Consumes("text/xml")
@Singleton
public static final class Text extends XmlRootObjectJaxbProvider {
public Text(@Context Provider<SAXParserFactory> spf, @Context Providers ps) {
super(spf, ps, MediaType.TEXT_XML_TYPE);
}
}
@Produces("*/*")
@Consumes("*/*")
@Singleton
public static final class General extends XmlRootObjectJaxbProvider {
public General(@Context Provider<SAXParserFactory> spf, @Context Providers ps) {
super(spf, ps);
}
@Override
protected boolean isSupported(MediaType m) {
return m.getSubtype().endsWith("+xml");
}
}
@Override
public boolean isReadable(Class<?> type, Type genericType, Annotation[] annotations, MediaType mediaType) {
try {
return Object.class == type && isSupported(mediaType) && getUnmarshaller(type, mediaType) != null;
} catch (JAXBException cause) {
throw new RuntimeException(LocalizationMessages.ERROR_UNMARSHALLING_JAXB(type), cause);
}
}
@Override
public final Object readFrom(
Class<Object> type,
Type genericType,
Annotation[] annotations,
MediaType mediaType,
MultivaluedMap<String, String> httpHeaders,
InputStream inputStream) throws IOException {
final EntityInputStream entityStream = EntityInputStream.create(inputStream);
if (entityStream.isEmpty()) {
throw new NoContentException(LocalizationMessages.ERROR_READING_ENTITY_MISSING());
}
try {
return getUnmarshaller(type, mediaType)
.unmarshal(getSAXSource(spf.get(), entityStream));
} catch (UnmarshalException ex) {
throw new BadRequestException(ex);
} catch (JAXBException ex) {
throw new InternalServerErrorException(ex);
}
}
@Override
public boolean isWriteable(Class<?> arg0, Type arg1, Annotation[] arg2, MediaType mediaType) {
return false;
}
@Override
public void writeTo(Object arg0, Class<?> arg1, Type arg2, Annotation[] arg3,
MediaType arg4, MultivaluedMap<String, Object> arg5, OutputStream arg6)
throws IOException, WebApplicationException {
throw new IllegalArgumentException();
}
}