sascha@27: package de.intevation.artifactdatabase.rest;
sascha@27: 
sascha@40: import org.restlet.resource.ResourceException;
sascha@27: 
sascha@27: import org.restlet.representation.Representation;
sascha@27: import org.restlet.representation.EmptyRepresentation;
sascha@27: 
sascha@27: import org.restlet.ext.xml.DomRepresentation;
sascha@27: 
sascha@27: import de.intevation.artifacts.ArtifactDatabase;
sascha@32: import de.intevation.artifacts.ArtifactDatabaseException;
sascha@27: import de.intevation.artifacts.Artifact;
sascha@29: import de.intevation.artifacts.ArtifactNamespaceContext;
sascha@27: 
sascha@27: import org.restlet.data.Request;
sascha@27: import org.restlet.data.Response;
sascha@27: import org.restlet.data.Status;
sascha@27: import org.restlet.data.MediaType;
sascha@27: 
sascha@27: import org.apache.log4j.Logger;
sascha@27: 
sascha@27: import org.w3c.dom.Document;
sascha@27: 
sascha@28: import java.io.IOException;
sascha@28: 
sascha@28: import de.intevation.artifactdatabase.XMLUtils;
sascha@28: 
sascha@27: /**
sascha@27:  * @author Sascha L. Teichmann (sascha.teichmann@intevation)
sascha@27:  */
sascha@27: public class ArtifactResource
sascha@40: extends      BaseResource
sascha@27: {
sascha@27:     private static Logger logger = Logger.getLogger(ArtifactResource.class);
sascha@27: 
sascha@28:     public static final String XPATH_ACTION = "/action/type/@name";
sascha@28: 
sascha@27:     public static final String PATH = "/artifact/{uuid}";
sascha@27: 
sascha@28:     public static final String NO_ACTION_MESSAGE      = "no action given";
sascha@28:     public static final String NO_SUCH_ACTION_MESSAGE = "no such action";
sascha@28: 
sascha@27:     public static final String NO_ARTIFACT_FOUND = "Artifact not found";
sascha@27: 
sascha@55:     public static final String ADVANCE  = "advance";
sascha@55:     public static final String FEED     = "feed";
sascha@55:     public static final String DESCRIBE = "describe";
sascha@28: 
sascha@40:     protected Representation innerGet()
sascha@40:     throws                   ResourceException
sascha@40:     {
sascha@27:         Request request = getRequest();
sascha@27: 
sascha@27:         String identifier = (String)request.getAttributes().get("uuid");
sascha@27: 
sascha@27:         if (logger.isDebugEnabled()) {
sascha@27:             logger.debug("looking for artifact id '" + identifier + "'");
sascha@27:         }
sascha@27: 
sascha@27:         ArtifactDatabase db = (ArtifactDatabase)getContext()
sascha@27:             .getAttributes().get("database");
sascha@27: 
sascha@32:         try {
sascha@32:             return new DomRepresentation(
sascha@32:                 MediaType.APPLICATION_XML,
sascha@55:                 db.describe(identifier, null, getCallMeta()));
sascha@32:         }
sascha@32:         catch (ArtifactDatabaseException adbe) {
sascha@35:             logger.warn(adbe.getLocalizedMessage(), adbe);
sascha@32:             Response response = getResponse();
sascha@32:             response.setStatus(
sascha@32:                 Status.CLIENT_ERROR_NOT_FOUND, adbe.getMessage());
sascha@32:             return new EmptyRepresentation();
sascha@32:         }
sascha@32:     }
sascha@27: 
sascha@32:     protected Representation dispatch(
sascha@32:         String           identifier,
sascha@32:         String           action,
sascha@32:         Document         source,
sascha@32:         ArtifactDatabase db
sascha@32:     ) {
sascha@32:         Document out = null;
sascha@32: 
sascha@32:         try {
sascha@32:             if (action.equals(FEED)) {
sascha@48:                 out = db.feed(identifier, source, getCallMeta());
sascha@32:             }
sascha@32:             else if (action.equals(ADVANCE)) {
sascha@48:                 out = db.advance(identifier, source, getCallMeta());
sascha@32:             }
sascha@55:             else if (action.equals(DESCRIBE)) {
sascha@55:                 out = db.describe(identifier, source, getCallMeta());
sascha@55:             }
sascha@32:             else {
sascha@32:                 throw new ArtifactDatabaseException(NO_SUCH_ACTION_MESSAGE);
sascha@32:             }
sascha@32:         }
sascha@32:         catch (ArtifactDatabaseException adbe) {
sascha@35:             logger.warn(adbe.getLocalizedMessage(), adbe);
sascha@27:             Response response = getResponse();
sascha@32:             response.setStatus(
sascha@32:                 Status.CLIENT_ERROR_BAD_REQUEST, adbe.getMessage());
sascha@27:             return new EmptyRepresentation();
sascha@27:         }
sascha@27: 
sascha@32:         return new DomRepresentation(MediaType.APPLICATION_XML, out);
sascha@27:     }
sascha@27: 
sascha@40:     protected Representation innerPost(Representation requestRepr) {
sascha@28: 
sascha@28:         Document inputDocument = null;
sascha@28:         try {
sascha@28:             DomRepresentation input = new DomRepresentation(requestRepr);
sascha@28:             inputDocument = input.getDocument();
sascha@28:         }
sascha@28:         catch (IOException ioe) {
sascha@28:             logger.error(ioe.getMessage());
sascha@28:             Response response = getResponse();
sascha@28:             response.setStatus(Status.CLIENT_ERROR_BAD_REQUEST, ioe);
sascha@28:             return new EmptyRepresentation();
sascha@28:         }
sascha@28: 
sascha@28:         String action = XMLUtils.xpathString(
sascha@28:             inputDocument,
sascha@28:             XPATH_ACTION,
sascha@28:             ArtifactNamespaceContext.INSTANCE);
sascha@28: 
sascha@28:         if (action == null || action.length() == 0) {
sascha@28:             Response response = getResponse();
sascha@32:             response.setStatus(
sascha@32:                 Status.CLIENT_ERROR_BAD_REQUEST, NO_ACTION_MESSAGE);
sascha@28:             return new EmptyRepresentation();
sascha@28:         }
sascha@28: 
sascha@40:         Request request = getRequest();
sascha@40: 
sascha@28:         String identifier = (String)request.getAttributes().get("uuid");
sascha@28: 
sascha@28:         ArtifactDatabase db = (ArtifactDatabase)getContext()
sascha@28:             .getAttributes().get("database");
sascha@28: 
sascha@32:         return dispatch(identifier, action, inputDocument, db);
sascha@27:     }
sascha@27: }
sascha@27: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8: