sjero.net Git - linphone/blob - p2pproxy/dependencies-src/jxse-src-2.5/impl/src/net/jxta/impl/protocol/PeerInfoResponseMsg.java

   1 /*
   2  * Copyright (c) 2001-2007 Sun Microsystems, Inc.  All rights reserved.
   3  *
   4  *  The Sun Project JXTA(TM) Software License
   5  *
   6  *  Redistribution and use in source and binary forms, with or without
   7  *  modification, are permitted provided that the following conditions are met:
   8  *
   9  *  1. Redistributions of source code must retain the above copyright notice,
  10  *     this list of conditions and the following disclaimer.
  11  *
  12  *  2. Redistributions in binary form must reproduce the above copyright notice,
  13  *     this list of conditions and the following disclaimer in the documentation
  14  *     and/or other materials provided with the distribution.
  15  *
  16  *  3. The end-user documentation included with the redistribution, if any, must
  17  *     include the following acknowledgment: "This product includes software
  18  *     developed by Sun Microsystems, Inc. for JXTA(TM) technology."
  19  *     Alternately, this acknowledgment may appear in the software itself, if
  20  *     and wherever such third-party acknowledgments normally appear.
  21  *
  22  *  4. The names "Sun", "Sun Microsystems, Inc.", "JXTA" and "Project JXTA" must
  23  *     not be used to endorse or promote products derived from this software
  24  *     without prior written permission. For written permission, please contact
  25  *     Project JXTA at http://www.jxta.org.
  26  *
  27  *  5. Products derived from this software may not be called "JXTA", nor may
  28  *     "JXTA" appear in their name, without prior written permission of Sun.
  29  *
  30  *  THIS SOFTWARE IS PROVIDED ``AS IS'' AND ANY EXPRESSED OR IMPLIED WARRANTIES,
  31  *  INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND
  32  *  FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL SUN
  33  *  MICROSYSTEMS OR ITS CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT,
  34  *  INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT
  35  *  LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA,
  36  *  OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF
  37  *  LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
  38  *  NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE,
  39  *  EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE.
  40  *
  41  *  JXTA is a registered trademark of Sun Microsystems, Inc. in the United
  42  *  States and other countries.
  43  *
  44  *  Please see the license information page at :
  45  *  <http://www.jxta.org/project/www/license.html> for instructions on use of
  46  *  the license in source files.
  47  *
  48  *  ====================================================================
  49  *
  50  *  This software consists of voluntary contributions made by many individuals
  51  *  on behalf of Project JXTA. For more information on Project JXTA, please see
  52  *  http://www.jxta.org.
  53  *
  54  *  This license is based on the BSD license adopted by the Apache Foundation.
  55  */
  56
  57 package net.jxta.impl.protocol;
  58
  59
  60 import net.jxta.document.*;
  61 import net.jxta.id.ID;
  62 import net.jxta.id.IDFactory;
  63 import net.jxta.peer.PeerID;
  64 import net.jxta.protocol.PeerInfoResponseMessage;
  65
  66 import java.net.URI;
  67 import java.net.URISyntaxException;
  68 import java.util.Enumeration;
  69
  70
  71 /**
  72  * This class implements {@link net.jxta.protocol.PeerInfoResponseMessage}.
  73  * <p/>
  74  * <p>This message is part of the Peer PeerInfoService protocol
  75  * <p/>
  76  * <pre>
  77  * &lt;xs:element name="<classname>PeerInfoResponse</classname>" type="jxta:PeerInfoResponse"/>
  78  * <p/>
  79  * &lt;xs:complexType name="PeerInfoResponse">
  80  *     &lt;xs:element name="sourcePid" type="xs:anyURI"/>
  81  *     &lt;xs:element name="targetPid" type="xs:anyURI"/>
  82  *     &lt;xs:element name="uptime" type="xs:unsignedLong" minOccurs="0"/>
  83  *     &lt;xs:element name="timestamp" type="xs:unsignedLong" minOccurs="0"/>
  84  *     &lt;xs:element name="response" type="xs:anyType" minOccurs="0"/>
  85  * &lt;/xs:complexType>
  86  * </pre>
  87  *
  88  * @since JXTA 1.0
  89  */
  90 public class PeerInfoResponseMsg extends PeerInfoResponseMessage {
  91
  92     public PeerInfoResponseMsg() {}
  93
  94     /**
  95      * @param spid      source PeerID
  96      * @param tpid      target PeerID
  97      * @param uptime    uotime in millis
  98      * @param timestamp TimeStamp
  99      * @deprecated Please use the individual setters
 100      */
 101     @Deprecated
 102     public PeerInfoResponseMsg(PeerID spid, PeerID tpid, long uptime, long timestamp) {
 103         setSourcePid(spid);
 104         setTargetPid(tpid);
 105         setUptime(uptime);
 106         setTimestamp(timestamp);
 107     }
 108
 109     public PeerInfoResponseMsg(Element root) {
 110         initialize(root);
 111     }
 112
 113     private void initialize(Element root) {
 114
 115         if (!TextElement.class.isInstance(root)) {
 116             throw new IllegalArgumentException(getClass().getName() + " only supports TextElement");
 117         }
 118
 119         setSourcePid(null);
 120         setTargetPid(null);
 121         setUptime(0);
 122         setTimestamp(0);
 123
 124         TextElement doc = (TextElement) root;
 125
 126         Enumeration elements;
 127
 128         elements = doc.getChildren();
 129
 130         while (elements.hasMoreElements()) {
 131             TextElement element = (TextElement) elements.nextElement();
 132             String elementName = element.getName();
 133
 134             if (elementName.equals("sourcePid")) {
 135                 try {
 136                     URI peerid = new URI(element.getTextValue());
 137                     ID id = IDFactory.fromURI(peerid);
 138
 139                     if (!(id instanceof PeerID)) {
 140                         throw new IllegalArgumentException("Bad ID in advertisement, not a PeerID");
 141                     }
 142                     setSourcePid((PeerID) id);
 143                 } catch (URISyntaxException badID) {
 144                     throw new IllegalArgumentException("Bad peerid ID in advertisement");
 145                 }
 146                 continue;
 147             }
 148
 149             if (elementName.equals("targetPid")) {
 150                 try {
 151                     URI peerid = new URI(element.getTextValue());
 152                     PeerID id = (PeerID) IDFactory.fromURI(peerid);
 153
 154                     setTargetPid(id);
 155                 } catch (URISyntaxException badID) {
 156                     throw new IllegalArgumentException("Bad peerid ID in advertisement");
 157                 } catch (ClassCastException badID) {
 158                     throw new IllegalArgumentException("Bad ID in advertisement, not a PeerID");
 159                 }
 160             }
 161
 162             if (elementName.equals("uptime")) {
 163                 setUptime(Long.parseLong(element.getTextValue()));
 164                 continue;
 165             }
 166
 167             if (elementName.equals("timestamp")) {
 168                 setTimestamp(Long.parseLong(element.getTextValue()));
 169                 continue;
 170             }
 171
 172             if (elementName.equals("response")) {
 173                 Enumeration elems = element.getChildren();
 174
 175                 if (elems.hasMoreElements()) {
 176                     setResponse(StructuredDocumentUtils.copyAsDocument((Element) elems.nextElement()));
 177                 }
 178             }
 179
 180         }
 181     }
 182
 183     @Override
 184     public Document getDocument(MimeMediaType encodeAs) {
 185
 186         StructuredTextDocument doc = (StructuredTextDocument)
 187                 StructuredDocumentFactory.newStructuredDocument(encodeAs, getMessageType());
 188         TextElement e;
 189
 190         if (doc instanceof Attributable) {
 191             ((Attributable) doc).addAttribute("xmlns:jxta", "http://jxta.org");
 192         }
 193
 194         e = doc.createElement("sourcePid", getSourcePid().toString());
 195         doc.appendChild(e);
 196
 197         e = doc.createElement("targetPid", getTargetPid().toString());
 198         doc.appendChild(e);
 199
 200         Element response = getResponse();
 201
 202         if (null != response) {
 203             e = doc.createElement("response");
 204             doc.appendChild(e);
 205
 206             StructuredDocumentUtils.copyElements(doc, e, response);
 207         }
 208
 209         e = doc.createElement("uptime", String.valueOf(getUptime()));
 210         doc.appendChild(e);
 211
 212         e = doc.createElement("timestamp", String.valueOf(getTimestamp()));
 213         doc.appendChild(e);
 214
 215         return doc;
 216     }
 217
 218 }
 219