boxtec
/
yacy_search_server
mirror of https://github.com/yacy/yacy_search_server
4
1
Fork 0
Code Issues Projects Releases Wiki Activity

*) soap: adding function to query the peer list

Browse Source 
git-svn-id: https://svn.berlios.de/svnroot/repos/yacy/trunk@2968 6c8d7289-2bf4-0310-a012-ef5d649a1542
pull/1/head
theli 19 years ago
parent c9364246cc
commit 5c0669429e
4 changed files with 120 additions and 22 deletions
Show Stats Download Patch File Download Diff File

12
htroot/Network.xml
Unescape View File

@ -11,6 +11,18 @@
<uptime>#[uptime]#</uptime>
<links>#[links]#</links>
<words>#[words]#</words>
<lastseen>#[lastSeen]#</lastseen>
<sendWords>#[sI]#</sendWords>
<receivedWords>#[rI]#</receivedWords>
<sendURLs>#[sU]#</sendURLs>
<receivedURLs>#[rU]#</receivedURLs>
#(complete)#
::
<age>#[age]#</age>
<seeds>#[seeds]#</seeds>
<connects>#[connects]#</connects>
<address>#[ip]#:#[port]#</address>
#(/complete)#
</peer>
#{/list}#
</peers>

85
source/de/anomic/soap/services/StatusService.java
Unescape View File

@ -66,21 +66,78 @@ public class StatusService extends AbstractService {
/**
* Service used to query the network properties
* @throws AxisFault if the service could not be executed propery.
* @throws Exception
*/
public Document network() throws AxisFault {
try {
// extracting the message context
extractMessageContext(NO_AUTHENTICATION);
// generating the template containing the network status information
byte[] result = writeTemplate(TEMPLATE_NETWORK_XML, new serverObjects());
// sending back the result to the client
return this.convertContentToXML(result);
} catch (Exception e) {
throw new AxisFault(e.getMessage());
}
public Document network() throws Exception {
// extracting the message context
extractMessageContext(NO_AUTHENTICATION);
// generating the template containing the network status information
byte[] result = writeTemplate(TEMPLATE_NETWORK_XML, new serverObjects());
// sending back the result to the client
return this.convertContentToXML(result);
}
/**
* Returns a list of peers this peer currently knows
* @param peerType the peer types to query. This could be
* <ul>
* <li>active</li>
* <li>passive</li>
* <li>potential</li>
* </ul>
* @param maxCount the maximum amount of records to return
* @param details if detailed informations should be returned
*
* @return a XML document of the following format
* <pre>
* &lt;?xml version="1.0" encoding="UTF-8"?&gt;
* &lt;peers&gt;
* &lt;peer&gt;
* &lt;hash&gt;XXXXXXX&lt;/hash&gt;
* &lt;fullname&gt;Peer Name&lt;/fullname&gt;
* &lt;version&gt;0.424/01505&lt;/version&gt;
* &lt;ppm&gt;0&lt;/ppm&gt;
* &lt;uptime&gt;2 days 14:37&lt;/uptime&gt;
* &lt;links&gt;-&lt;/links&gt;
* &lt;words&gt;-&lt;/words&gt;
* &lt;lastseen&gt;48&lt;/lastseen&gt;
* &lt;sendWords&gt;-&lt;/sendWords&gt;
* &lt;receivedWords&gt;-&lt;/receivedWords&gt;
* &lt;sendURLs&gt;-&lt;/sendURLs&gt;
* &lt;receivedURLs&gt;-&lt;/receivedURLs&gt;
* &lt;age&gt;369&lt;/age&gt;
* &lt;seeds&gt;61&lt;/seeds&gt;
* &lt;connects&gt;2&lt;/connects&gt;
* &lt;address&gt;127.0.0.1:8080&lt;/address&gt;
* &lt;/peer&gt;
* &lt;/peers&gt;
* </pre>
* @throws Exception
*/
public Document peerList(String peerType, int maxCount, boolean details) throws Exception {
// extracting the message context
extractMessageContext(NO_AUTHENTICATION);
if (peerType == null || peerType.length() == 0) throw new IllegalArgumentException("The peer type must not be null or empty.");
if (!(peerType.equalsIgnoreCase("active") || peerType.equalsIgnoreCase("passive") || peerType.equalsIgnoreCase("Potential")))
throw new IllegalArgumentException("Unknown peer type. Should be (active|passive|potential)");
// configuring output mode
serverObjects args = new serverObjects();
if (peerType.equalsIgnoreCase("active")) args.put("page","1");
else if (peerType.equalsIgnoreCase("passive")) args.put("page","2");
else if (peerType.equalsIgnoreCase("potential")) args.put("page","3");
// specifying if the detailed list should be returned
if (details) args.put("ip","1");
// generating the template containing the network status information
byte[] result = writeTemplate(TEMPLATE_NETWORK_XML, args);
// sending back the result to the client
return this.convertContentToXML(result);
}

40
source/de/anomic/soap/services/status.wsdl
Unescape View File

@ -1,26 +1,35 @@
<?xml version="1.0" encoding="UTF-8"?>
<wsdl:definitions targetNamespace="http://yacy:8080/soap/status" xmlns:apachesoap="http://xml.apache.org/xml-soap" xmlns:impl="http://yacy:8080/soap/status" xmlns:intf="http://yacy:8080/soap/status" xmlns:soapenc="http://schemas.xmlsoap.org/soap/encoding/" xmlns:wsdl="http://schemas.xmlsoap.org/wsdl/" xmlns:wsdlsoap="http://schemas.xmlsoap.org/wsdl/soap/" xmlns:xsd="http://www.w3.org/2001/XMLSchema"><!--WSDL created by Apache Axis version: 1.4
Built on Apr 22, 2006 (06:55:48 PDT)-->
<wsdl:message name="peerListRequest">
<wsdl:part name="peerType" type="xsd:string"/>
<wsdl:part name="maxCount" type="xsd:int"/>
<wsdl:part name="details" type="xsd:boolean"/>
</wsdl:message>
<wsdl:message name="getQueueStatusResponse">
<wsdl:part name="getQueueStatusReturn" type="apachesoap:Document"/>
</wsdl:message>
<wsdl:message name="createNewXMLDocumentResponse">
<wsdl:part name="createNewXMLDocumentReturn" type="apachesoap:Document"/>
</wsdl:message>
<wsdl:message name="createNewXMLDocumentRequest">
<wsdl:part name="rootElementName" type="xsd:string"/>
</wsdl:message>
<wsdl:message name="getQueueStatusRequest">
<wsdl:part name="localqueueCount" type="xsd:int"/>
<wsdl:part name="loaderqueueCount" type="xsd:int"/>
<wsdl:part name="localcrawlerqueueCount" type="xsd:int"/>
<wsdl:part name="remotecrawlerqueueCount" type="xsd:int"/>
</wsdl:message>
<wsdl:message name="peerListResponse">
<wsdl:part name="peerListReturn" type="apachesoap:Document"/>
</wsdl:message>
<wsdl:message name="networkResponse">
<wsdl:part name="networkReturn" type="apachesoap:Document"/>
</wsdl:message>
<wsdl:message name="networkRequest">
</wsdl:message>
<wsdl:message name="getStatusResponse">
@ -29,8 +38,8 @@ Built on Apr 22, 2006 (06:55:48 PDT)-->
<wsdl:message name="getStatusRequest">
</wsdl:message>
<wsdl:portType name="StatusService">
<wsdl:operation name="getStatus">
<wsdl:input message="impl:getStatusRequest" name="getStatusRequest"/>
<wsdl:output message="impl:getStatusResponse" name="getStatusResponse"/>
</wsdl:operation>
@ -38,63 +47,78 @@ Built on Apr 22, 2006 (06:55:48 PDT)-->
<wsdl:input message="impl:networkRequest" name="networkRequest"/>
<wsdl:output message="impl:networkResponse" name="networkResponse"/>
</wsdl:operation>
<wsdl:operation name="getQueueStatus" parameterOrder="localqueueCount loaderqueueCount localcrawlerqueueCount remotecrawlerqueueCount">
<wsdl:operation name="peerList" parameterOrder="peerType maxCount details">
<wsdl:input message="impl:peerListRequest" name="peerListRequest"/>
<wsdl:output message="impl:peerListResponse" name="peerListResponse"/>
</wsdl:operation>
<wsdl:operation name="getQueueStatus" parameterOrder="localqueueCount loaderqueueCount localcrawlerqueueCount remotecrawlerqueueCount">
<wsdl:input message="impl:getQueueStatusRequest" name="getQueueStatusRequest"/>
<wsdl:output message="impl:getQueueStatusResponse" name="getQueueStatusResponse"/>
</wsdl:operation>
<wsdl:operation name="createNewXMLDocument" parameterOrder="rootElementName">
<wsdl:input message="impl:createNewXMLDocumentRequest" name="createNewXMLDocumentRequest"/>
<wsdl:output message="impl:createNewXMLDocumentResponse" name="createNewXMLDocumentResponse"/>
</wsdl:operation>
</wsdl:portType>
<wsdl:binding name="statusSoapBinding" type="impl:StatusService">
<wsdlsoap:binding style="rpc" transport="http://schemas.xmlsoap.org/soap/http"/>
<wsdl:operation name="getStatus">
<wsdlsoap:operation soapAction=""/>
<wsdl:input name="getStatusRequest">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" namespace="http://services.soap.anomic.de" use="encoded"/>
</wsdl:input>
<wsdl:output name="getStatusResponse">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" namespace="http://yacy:8080/soap/status" use="encoded"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="network">
<wsdlsoap:operation soapAction=""/>
<wsdl:input name="networkRequest">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" namespace="http://services.soap.anomic.de" use="encoded"/>
</wsdl:input>
<wsdl:output name="networkResponse">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" namespace="http://yacy:8080/soap/status" use="encoded"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="peerList">
<wsdlsoap:operation soapAction=""/>
<wsdl:input name="peerListRequest">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" namespace="http://services.soap.anomic.de" use="encoded"/>
</wsdl:input>
<wsdl:output name="peerListResponse">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" namespace="http://yacy:8080/soap/status" use="encoded"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="getQueueStatus">
<wsdlsoap:operation soapAction=""/>
<wsdl:input name="getQueueStatusRequest">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" namespace="http://services.soap.anomic.de" use="encoded"/>
</wsdl:input>
<wsdl:output name="getQueueStatusResponse">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" namespace="http://yacy:8080/soap/status" use="encoded"/>
</wsdl:output>
</wsdl:operation>
<wsdl:operation name="createNewXMLDocument">
<wsdlsoap:operation soapAction=""/>
<wsdl:input name="createNewXMLDocumentRequest">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" namespace="http://soap.anomic.de" use="encoded"/>
</wsdl:input>
<wsdl:output name="createNewXMLDocumentResponse">
<wsdlsoap:body encodingStyle="http://schemas.xmlsoap.org/soap/encoding/" namespace="http://yacy:8080/soap/status" use="encoded"/>
</wsdl:output>
</wsdl:operation>
</wsdl:binding>
<wsdl:service name="StatusServiceService">
<wsdl:port binding="impl:statusSoapBinding" name="status">
<wsdlsoap:address location="http://yacy:8080/soap/status"/>
</wsdl:port>
</wsdl:service>
</wsdl:definitions>

5
test/de/anomic/soap/services/StatusServiceTest.java
Unescape View File

@ -34,4 +34,9 @@ public class StatusServiceTest extends AbstractServiceTest {
Document xml = ((StatusService)service).getStatus();
System.out.println(XMLUtils.DocumentToString(xml));
}
public void testPeerList() throws RemoteException {
Document xml = ((StatusService)service).peerList("active",300,true);
System.out.println(XMLUtils.DocumentToString(xml));
}
}

Write Preview
Loading…
Cancel
Save