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 :