ingo@29: package de.intevation.flys.client.server;
ingo@29:
ingo@29: import java.util.ArrayList;
ingo@29: import java.util.List;
ingo@29:
ingo@29: import javax.xml.xpath.XPathConstants;
ingo@29:
ingo@29: import org.w3c.dom.Document;
ingo@29: import org.w3c.dom.NodeList;
ingo@29: import org.w3c.dom.Node;
ingo@29:
ingo@1367: import org.apache.log4j.Logger;
ingo@1367:
ingo@29:
ingo@29: import de.intevation.artifacts.common.ArtifactNamespaceContext;
ingo@29: import de.intevation.artifacts.common.utils.XMLUtils;
ingo@29:
ingo@29: import de.intevation.artifacts.httpclient.exceptions.ConnectionException;
ingo@29: import de.intevation.artifacts.httpclient.http.HttpClient;
ingo@29: import de.intevation.artifacts.httpclient.http.HttpClientImpl;
ingo@29:
ingo@217: import de.intevation.flys.client.shared.exceptions.ServerException;
ingo@29: import de.intevation.flys.client.shared.model.DefaultRiver;
ingo@29: import de.intevation.flys.client.shared.model.River;
ingo@29: import de.intevation.flys.client.client.services.RiverService;
ingo@29:
bjoern@3492: import de.intevation.flys.client.server.auth.User;
bjoern@3492:
ingo@29:
ingo@29: /**
ingo@29: * This interface provides a method to list the supported rivers of the artifact
ingo@29: * server.
ingo@29: *
ingo@29: * @author Ingo Weinzierl
ingo@29: */
ingo@29: public class RiverServiceImpl
ingo@29: extends RemoteServiceServlet
ingo@29: implements RiverService
ingo@29: {
felix@2940: /** Private logger. */
ingo@1367: private static final Logger logger =
ingo@1367: Logger.getLogger(RiverServiceImpl.class);
ingo@1367:
ingo@29: /** The XPath string that points to the rivers in the resulting document.*/
ingo@29: public static final String XPATH_RIVERS = "/art:rivers/art:river";
ingo@29:
ingo@217: /** The error message key that is thrown if an error occured while reading
ingo@217: * the supported rivers from server.*/
ingo@217: public static final String ERROR_NO_RIVERS_FOUND = "error_no_rivers_found";
ingo@29:
ingo@217:
felix@2940: /** Get river list. */
raimund@1425: public River[] list(String locale)
ingo@217: throws ServerException
ingo@217: {
raimund@1425: String url = getServletContext().getInitParameter("server-url");
raimund@1425:
felix@2940: Document doc = XMLUtils.newDocument();
ingo@29:
ingo@29: XMLUtils.ElementCreator ec = new XMLUtils.ElementCreator(
ingo@29: doc,
ingo@29: ArtifactNamespaceContext.NAMESPACE_URI,
ingo@29: ArtifactNamespaceContext.NAMESPACE_PREFIX);
ingo@29:
ingo@29: doc.appendChild(ec.create("action"));
ingo@29:
raimund@1425: HttpClient client = new HttpClientImpl(url, locale);
ingo@29:
ingo@29: try {
raimund@1425: Document res = client.callService(url, "rivers", doc);
ingo@29:
ingo@29: NodeList rivers = (NodeList) XMLUtils.xpath(
ingo@29: res,
ingo@29: XPATH_RIVERS,
ingo@29: XPathConstants.NODESET,
ingo@29: ArtifactNamespaceContext.INSTANCE);
ingo@29:
ingo@217: if (rivers == null || rivers.getLength() == 0) {
ingo@217: throw new ServerException(ERROR_NO_RIVERS_FOUND);
ingo@217: }
ingo@217:
ingo@29: int count = rivers.getLength();
bjoern@3492: int rcount = 0;
ingo@29:
ingo@29: List theRivers = new ArrayList(count);
bjoern@3492: User user = this.getUser();
ingo@29:
ingo@29: for (int i = 0; i < count; i++) {
ingo@29: Node tmp = rivers.item(i);
ingo@29:
ingo@29: String name = XMLUtils.xpathString(
ingo@29: tmp, "@art:name", ArtifactNamespaceContext.INSTANCE);
ingo@29:
bjoern@3492: if (user.canUseFeature("river:" + name)) {
bjoern@3492: theRivers.add(new DefaultRiver(name));
bjoern@3492: rcount++;
bjoern@3492: }
ingo@29: }
ingo@29:
bjoern@3492: return theRivers.toArray(new River[rcount]);
ingo@29: }
ingo@29: catch (ConnectionException ce) {
ingo@1367: logger.error(ce, ce);
ingo@29: }
ingo@29:
ingo@217: throw new ServerException(ERROR_NO_RIVERS_FOUND);
ingo@29: }
ingo@29: }
ingo@29: // vim:set ts=4 sw=4 si et sta sts=4 fenc=utf8 :