0.5.2/java/NodeImpl.java

/*************************************************************************************************
 * Java interface of Hyper Estraier
 *                                                      Copyright (C) 2004-2005 Mikio Hirabayashi
 *                                                                           All rights reserved.
 * This file is part of Hyper Estraier.
 * Redistribution and use in source and binary forms, with or without modification, are
 * permitted provided that the following conditions are met:
 *
 *   * Redistributions of source code must retain the above copyright notice, this list of
 *     conditions and the following disclaimer.
 *   * Redistributions in binary form must reproduce the above copyright notice, this list of
 *     conditions and the following disclaimer in the documentation and/or other materials
 *     provided with the distribution.
 *   * Neither the name of Mikio Hirabayashi nor the names of its contributors may be used to
 *     endorse or promote products derived from this software without specific prior written
 *     permission.
 *
 * THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS
 * OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
 * MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
 * COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
 * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
 * GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
 * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
 * NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
 * OF THE POSSIBILITY OF SUCH DAMAGE.
 *************************************************************************************************/


package estraier;

import java.util.*;
import java.io.*;
import java.net.*;


/**
 * Implementation of connection to P2P node.
 */
public class NodeImpl implements Node {
  //----------------------------------------------------------------
  // private fields
  //----------------------------------------------------------------
  private int status;
  private String url;
  private String pxhost;
  private int pxport;
  private int timeout;
  private String auth;
  private String name;
  private String label;
  private int dnum;
  private int wnum;
  private double size;
  //----------------------------------------------------------------
  // public methods
  //----------------------------------------------------------------
  public NodeImpl(){
    status = -1;
    url = null;
    pxhost = null;
    pxport = -1;
    timeout = -1;
    auth = null;
    name = null;
    label = null;
    dnum = -1;
    wnum = -1;
    size = -1.0;
  }
  public int status(){
    return status;
  }
  public void set_url(String url){
    this.url = url;
  }
  public void set_proxy(String host, int port){
    pxhost = host;
    pxport = port;
  }
  public void set_timeout(int msec){
    timeout = msec;
  }
  public void set_auth(String name, String password){
    auth = name + ":" + password;
  }
  public boolean put_doc(Document doc){
    status = -1;
    if(url == null) return false;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/put_doc");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: text/x-estraier-draft");
      byte[] reqbody = doc.dump_draft().getBytes("UTF-8");
      ByteArrayOutputStream resbody = new ByteArrayOutputStream();
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, resbody);
      if(status != 200) return false;
      return true;
    } catch(Exception e){
      return false;
    }
  }
  public boolean out_doc(int id){
    status = -1;
    if(url == null) return false;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/out_doc");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: application/x-www-form-urlencoded");
      byte[] reqbody = ("id=" + id).getBytes("ISO-8859-1");
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, null);
      if(status != 200) return false;
      return true;
    } catch(Exception e){
      return false;
    }
  }
  public boolean out_doc_by_uri(String uri){
    status = -1;
    if(url == null) return false;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/out_doc");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: application/x-www-form-urlencoded");
      byte[] reqbody = ("uri=" + URLEncoder.encode(uri, "UTF-8")).getBytes("ISO-8859-1");
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, null);
      if(status != 200) return false;
      return true;
    } catch(Exception e){
      return false;
    }
  }
  public Document get_doc(int id){
    status = -1;
    if(url == null) return null;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/get_doc");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: application/x-www-form-urlencoded");
      byte[] reqbody = ("id=" + id).getBytes("ISO-8859-1");
      ByteArrayOutputStream resbody = new ByteArrayOutputStream();
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, resbody);
      if(status != 200) return null;
      return new DocumentImpl(resbody.toString("UTF-8"));
    } catch(Exception e){
      return null;
    }
  }
  public Document get_doc_by_uri(String uri){
    status = -1;
    if(url == null) return null;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/get_doc");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: application/x-www-form-urlencoded");
      byte[] reqbody = ("uri=" + URLEncoder.encode(uri, "UTF-8")).getBytes("ISO-8859-1");
      ByteArrayOutputStream resbody = new ByteArrayOutputStream();
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, resbody);
      if(status != 200) return null;
      return new DocumentImpl(resbody.toString("UTF-8"));
    } catch(Exception e){
      return null;
    }
  }
  public String get_doc_attr(int id, String name){
    status = -1;
    if(url == null) return null;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/get_doc_attr");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: application/x-www-form-urlencoded");
      String qstr = "id=" + id + "&attr=" + URLEncoder.encode(name, "UTF-8");
      byte[] reqbody = qstr.getBytes("ISO-8859-1");
      ByteArrayOutputStream resbody = new ByteArrayOutputStream();
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, resbody);
      if(status != 200) return null;
      return resbody.toString("UTF-8").trim();
    } catch(Exception e){
      return null;
    }
  }
  public String get_doc_attr_by_uri(String uri, String name){
    status = -1;
    if(url == null) return null;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/get_doc_attr");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: application/x-www-form-urlencoded");
      String qstr = "uri=" + URLEncoder.encode(uri, "UTF-8") +
        "&attr=" + URLEncoder.encode(name, "UTF-8");
      byte[] reqbody = qstr.getBytes("ISO-8859-1");
      ByteArrayOutputStream resbody = new ByteArrayOutputStream();
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, resbody);
      if(status != 200) return null;
      return resbody.toString("UTF-8").trim();
    } catch(Exception e){
      return null;
    }
  }
  public int uri_to_id(String uri){
    status = -1;
    if(url == null) return -1;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/uri_to_id");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: application/x-www-form-urlencoded");
      byte[] reqbody = ("uri=" + URLEncoder.encode(uri, "UTF-8")).getBytes("ISO-8859-1");
      ByteArrayOutputStream resbody = new ByteArrayOutputStream();
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, resbody);
      if(status != 200) return -1;
      return Integer.parseInt(resbody.toString("ISO-8859-1").trim());
    } catch(Exception e){
      return -1;
    }
  }
  public String name(){
    if(name == null) set_info();
    return name;
  }
  public String label(){
    if(label == null) set_info();
    return label;
  }
  public int doc_num(){
    if(dnum < 0) set_info();
    return dnum;
  }
  public int word_num(){
    if(wnum < 0) set_info();
    return wnum;
  }
  public double size(){
    if(size < 0.0) set_info();
    return size;
  }
  public NodeResult search(Condition cond, int depth){
    status = -1;
    if(url == null) return null;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/search");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: application/x-www-form-urlencoded");
      byte[] reqbody = cond_to_query(cond, depth).getBytes("ISO-8859-1");
      ByteArrayOutputStream resbody = new ByteArrayOutputStream();
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, resbody);
      if(status != 200) return null;
      String[] lines = Utility.splitLines(resbody.toString("UTF-8"));
      if(lines.length < 1) return null;
      List docs = new ArrayList(31);
      Map hints = new HashMap(31);
      NodeResultImpl nres = new NodeResultImpl(docs, hints);
      String border = lines[0];
      int lnum = 1;
      while(lnum < lines.length){
        String line = lines[lnum++];
        if(line.equals(border)) break;
        int lidx = line.indexOf('\t');
        if(lidx != -1){
          String key = line.substring(0, lidx);
          String value = line.substring(lidx + 1, line.length());
          hints.put(key, value);
        }
      }
      int snum = lnum;
      boolean end = false;
      while(lnum < lines.length){
        String line = lines[lnum++];
        if(line.startsWith(border)){
          if(lnum > snum){
            Map rdattrs = new HashMap(31);
            StringBuffer sb = new StringBuffer();
            int rlnum = snum;
            while(rlnum < lnum - 1){
              String rdline = lines[rlnum++];
              if(rdline.length() < 1) break;
              int lidx = rdline.indexOf('=');
              if(lidx != -1){
                String key = rdline.substring(0, lidx);
                String value = rdline.substring(lidx + 1, rdline.length());
                rdattrs.put(key, value);
              }
            }
            while(rlnum < lnum - 1){
              String rdline = lines[rlnum++];
              sb.append(rdline);
              sb.append("\n");
            }
            String rduri = (String)rdattrs.get("@uri");
            String rdsnippet = sb.toString();
            if(rduri != null){
              ResultDocument doc = new ResultDocumentImpl(rduri, rdattrs, rdsnippet);
              docs.add(doc);
            }
          }
          snum = lnum;
          if(line.substring(border.length(), line.length()).equals(":END")) end = true;
        }
        if(end) break;
      }
      return nres;
    } catch(Exception e){
      return null;
    }
  }
  public boolean set_user(String name, int mode){
    status = -1;
    if(url == null) return false;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/_set_user");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: application/x-www-form-urlencoded");
      String qstr = "name=" + URLEncoder.encode(name, "UTF-8") + "&mode=" + mode;
      byte[] reqbody = qstr.getBytes("ISO-8859-1");
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, null);
      if(status != 200) return false;
      return true;
    } catch(Exception e){
      return false;
    }
  }
  public boolean set_link(String url, String label, int credit){
    status = -1;
    if(this.url == null) return false;
    try {
      URL purl = new URL(this.url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/_set_link");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      reqheads.add("Content-Type: application/x-www-form-urlencoded");
      String qstr = "url=" + URLEncoder.encode(url, "UTF-8") +
        "&label=" + URLEncoder.encode(label, "UTF-8");
      if(credit >= 0) qstr = qstr + "&credit=" + credit;
      byte[] reqbody = qstr.getBytes("ISO-8859-1");
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
                                  null, null);
      if(status != 200) return false;
      return true;
    } catch(Exception e){
      return false;
    }
  }
  //----------------------------------------------------------------
  // private methods
  //----------------------------------------------------------------
  private void set_info(){
    status = -1;
    if(url == null) return;
    try {
      URL purl = new URL(url);
      URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
                         purl.getPath() + "/inform");
      List reqheads = new ArrayList(2);
      if(auth != null)
        reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
      ByteArrayOutputStream resbody = new ByteArrayOutputStream();
      status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, null,
                                  null, resbody);
      if(status != 200) return;
      String resstr = resbody.toString("UTF-8");
      String[] lines = Utility.splitLines(resstr);
      if(lines.length < 1) return;
      String[] fields = Utility.splitFields(lines[0]);
      if(fields.length != 5) return;
      name = fields[0];
      label = fields[1];
      dnum = Integer.parseInt(fields[2]);
      wnum = Integer.parseInt(fields[3]);
      size = Double.parseDouble(fields[4]);
      if(dnum < 0 || wnum < 0 || size < 0.0){
        dnum = -1;
        wnum = -1;
        size = -1.0;
      }
    } catch(Exception e){
      name = null;
      label = null;
      dnum = -1;
      wnum = -1;
      size = -1.0;
    }
  }
  private String cond_to_query(Condition cond, int depth){
    StringBuffer sb = new StringBuffer();
    try {
      String phrase = cond.phrase();
      sb.append("phrase=");
      if(phrase != null) sb.append(URLEncoder.encode(phrase, "UTF-8"));
      List attrs = cond.attrs();
      Iterator it = cond.attrs().iterator();
      for(int i = 1; it.hasNext(); i++){
        sb.append("&attr=");
        sb.append(i);
        sb.append(URLEncoder.encode((String)it.next(), "UTF-8"));
      }
      String order = cond.order();
      if(order != null){
        sb.append("&order=");
        sb.append(URLEncoder.encode(order, "UTF-8"));
      }
      int max = cond.max();
      if(max >= 0){
        sb.append("&max=");
        sb.append(max);
      }
      int options = cond.options();
      if(options > 0){
        sb.append("&options=");
        sb.append(options);
      }
      if(depth > 0){
        sb.append("&depth=");
        sb.append(depth);
      }
    } catch(UnsupportedEncodingException e){
      throw new RuntimeException(e);
    }
    return sb.toString();
  }
}


/* END OF FILE */
1	/*************************************************************************************************
2	* Java interface of Hyper Estraier
3	* Copyright (C) 2004-2005 Mikio Hirabayashi
4	* All rights reserved.
5	* This file is part of Hyper Estraier.
6	* Redistribution and use in source and binary forms, with or without modification, are
7	* permitted provided that the following conditions are met:
8	*
9	* * Redistributions of source code must retain the above copyright notice, this list of
10	* conditions and the following disclaimer.
11	* * Redistributions in binary form must reproduce the above copyright notice, this list of
12	* conditions and the following disclaimer in the documentation and/or other materials
13	* provided with the distribution.
14	* * Neither the name of Mikio Hirabayashi nor the names of its contributors may be used to
15	* endorse or promote products derived from this software without specific prior written
16	* permission.
17	*
18	* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS" AND ANY EXPRESS
19	* OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF
20	* MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE
21	* COPYRIGHT OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL,
22	* EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE
23	* GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND
24	* ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING
25	* NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED
26	* OF THE POSSIBILITY OF SUCH DAMAGE.
27	*************************************************************************************************/
28
29
30	package estraier;
31
32	import java.util.*;
33	import java.io.*;
34	import java.net.*;
35
36
37
38	/**
39	* Implementation of connection to P2P node.
40	*/
41	public class NodeImpl implements Node {
42	//----------------------------------------------------------------
43	// private fields
44	//----------------------------------------------------------------
45	private int status;
46	private String url;
47	private String pxhost;
48	private int pxport;
49	private int timeout;
50	private String auth;
51	private String name;
52	private String label;
53	private int dnum;
54	private int wnum;
55	private double size;
56	//----------------------------------------------------------------
57	// public methods
58	//----------------------------------------------------------------
59	public NodeImpl(){
60	status = -1;
61	url = null;
62	pxhost = null;
63	pxport = -1;
64	timeout = -1;
65	auth = null;
66	name = null;
67	label = null;
68	dnum = -1;
69	wnum = -1;
70	size = -1.0;
71	}
72	public int status(){
73	return status;
74	}
75	public void set_url(String url){
76	this.url = url;
77	}
78	public void set_proxy(String host, int port){
79	pxhost = host;
80	pxport = port;
81	}
82	public void set_timeout(int msec){
83	timeout = msec;
84	}
85	public void set_auth(String name, String password){
86	auth = name + ":" + password;
87	}
88	public boolean put_doc(Document doc){
89	status = -1;
90	if(url == null) return false;
91	try {
92	URL purl = new URL(url);
93	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
94	purl.getPath() + "/put_doc");
95	List reqheads = new ArrayList(2);
96	if(auth != null)
97	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
98	reqheads.add("Content-Type: text/x-estraier-draft");
99	byte[] reqbody = doc.dump_draft().getBytes("UTF-8");
100	ByteArrayOutputStream resbody = new ByteArrayOutputStream();
101	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
102	null, resbody);
103	if(status != 200) return false;
104	return true;
105	} catch(Exception e){
106	return false;
107	}
108	}
109	public boolean out_doc(int id){
110	status = -1;
111	if(url == null) return false;
112	try {
113	URL purl = new URL(url);
114	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
115	purl.getPath() + "/out_doc");
116	List reqheads = new ArrayList(2);
117	if(auth != null)
118	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
119	reqheads.add("Content-Type: application/x-www-form-urlencoded");
120	byte[] reqbody = ("id=" + id).getBytes("ISO-8859-1");
121	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
122	null, null);
123	if(status != 200) return false;
124	return true;
125	} catch(Exception e){
126	return false;
127	}
128	}
129	public boolean out_doc_by_uri(String uri){
130	status = -1;
131	if(url == null) return false;
132	try {
133	URL purl = new URL(url);
134	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
135	purl.getPath() + "/out_doc");
136	List reqheads = new ArrayList(2);
137	if(auth != null)
138	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
139	reqheads.add("Content-Type: application/x-www-form-urlencoded");
140	byte[] reqbody = ("uri=" + URLEncoder.encode(uri, "UTF-8")).getBytes("ISO-8859-1");
141	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
142	null, null);
143	if(status != 200) return false;
144	return true;
145	} catch(Exception e){
146	return false;
147	}
148	}
149	public Document get_doc(int id){
150	status = -1;
151	if(url == null) return null;
152	try {
153	URL purl = new URL(url);
154	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
155	purl.getPath() + "/get_doc");
156	List reqheads = new ArrayList(2);
157	if(auth != null)
158	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
159	reqheads.add("Content-Type: application/x-www-form-urlencoded");
160	byte[] reqbody = ("id=" + id).getBytes("ISO-8859-1");
161	ByteArrayOutputStream resbody = new ByteArrayOutputStream();
162	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
163	null, resbody);
164	if(status != 200) return null;
165	return new DocumentImpl(resbody.toString("UTF-8"));
166	} catch(Exception e){
167	return null;
168	}
169	}
170	public Document get_doc_by_uri(String uri){
171	status = -1;
172	if(url == null) return null;
173	try {
174	URL purl = new URL(url);
175	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
176	purl.getPath() + "/get_doc");
177	List reqheads = new ArrayList(2);
178	if(auth != null)
179	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
180	reqheads.add("Content-Type: application/x-www-form-urlencoded");
181	byte[] reqbody = ("uri=" + URLEncoder.encode(uri, "UTF-8")).getBytes("ISO-8859-1");
182	ByteArrayOutputStream resbody = new ByteArrayOutputStream();
183	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
184	null, resbody);
185	if(status != 200) return null;
186	return new DocumentImpl(resbody.toString("UTF-8"));
187	} catch(Exception e){
188	return null;
189	}
190	}
191	public String get_doc_attr(int id, String name){
192	status = -1;
193	if(url == null) return null;
194	try {
195	URL purl = new URL(url);
196	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
197	purl.getPath() + "/get_doc_attr");
198	List reqheads = new ArrayList(2);
199	if(auth != null)
200	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
201	reqheads.add("Content-Type: application/x-www-form-urlencoded");
202	String qstr = "id=" + id + "&attr=" + URLEncoder.encode(name, "UTF-8");
203	byte[] reqbody = qstr.getBytes("ISO-8859-1");
204	ByteArrayOutputStream resbody = new ByteArrayOutputStream();
205	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
206	null, resbody);
207	if(status != 200) return null;
208	return resbody.toString("UTF-8").trim();
209	} catch(Exception e){
210	return null;
211	}
212	}
213	public String get_doc_attr_by_uri(String uri, String name){
214	status = -1;
215	if(url == null) return null;
216	try {
217	URL purl = new URL(url);
218	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
219	purl.getPath() + "/get_doc_attr");
220	List reqheads = new ArrayList(2);
221	if(auth != null)
222	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
223	reqheads.add("Content-Type: application/x-www-form-urlencoded");
224	String qstr = "uri=" + URLEncoder.encode(uri, "UTF-8") +
225	"&attr=" + URLEncoder.encode(name, "UTF-8");
226	byte[] reqbody = qstr.getBytes("ISO-8859-1");
227	ByteArrayOutputStream resbody = new ByteArrayOutputStream();
228	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
229	null, resbody);
230	if(status != 200) return null;
231	return resbody.toString("UTF-8").trim();
232	} catch(Exception e){
233	return null;
234	}
235	}
236	public int uri_to_id(String uri){
237	status = -1;
238	if(url == null) return -1;
239	try {
240	URL purl = new URL(url);
241	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
242	purl.getPath() + "/uri_to_id");
243	List reqheads = new ArrayList(2);
244	if(auth != null)
245	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
246	reqheads.add("Content-Type: application/x-www-form-urlencoded");
247	byte[] reqbody = ("uri=" + URLEncoder.encode(uri, "UTF-8")).getBytes("ISO-8859-1");
248	ByteArrayOutputStream resbody = new ByteArrayOutputStream();
249	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
250	null, resbody);
251	if(status != 200) return -1;
252	return Integer.parseInt(resbody.toString("ISO-8859-1").trim());
253	} catch(Exception e){
254	return -1;
255	}
256	}
257	public String name(){
258	if(name == null) set_info();
259	return name;
260	}
261	public String label(){
262	if(label == null) set_info();
263	return label;
264	}
265	public int doc_num(){
266	if(dnum < 0) set_info();
267	return dnum;
268	}
269	public int word_num(){
270	if(wnum < 0) set_info();
271	return wnum;
272	}
273	public double size(){
274	if(size < 0.0) set_info();
275	return size;
276	}
277	public NodeResult search(Condition cond, int depth){
278	status = -1;
279	if(url == null) return null;
280	try {
281	URL purl = new URL(url);
282	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
283	purl.getPath() + "/search");
284	List reqheads = new ArrayList(2);
285	if(auth != null)
286	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
287	reqheads.add("Content-Type: application/x-www-form-urlencoded");
288	byte[] reqbody = cond_to_query(cond, depth).getBytes("ISO-8859-1");
289	ByteArrayOutputStream resbody = new ByteArrayOutputStream();
290	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
291	null, resbody);
292	if(status != 200) return null;
293	String[] lines = Utility.splitLines(resbody.toString("UTF-8"));
294	if(lines.length < 1) return null;
295	List docs = new ArrayList(31);
296	Map hints = new HashMap(31);
297	NodeResultImpl nres = new NodeResultImpl(docs, hints);
298	String border = lines[0];
299	int lnum = 1;
300	while(lnum < lines.length){
301	String line = lines[lnum++];
302	if(line.equals(border)) break;
303	int lidx = line.indexOf('\t');
304	if(lidx != -1){
305	String key = line.substring(0, lidx);
306	String value = line.substring(lidx + 1, line.length());
307	hints.put(key, value);
308	}
309	}
310	int snum = lnum;
311	boolean end = false;
312	while(lnum < lines.length){
313	String line = lines[lnum++];
314	if(line.startsWith(border)){
315	if(lnum > snum){
316	Map rdattrs = new HashMap(31);
317	StringBuffer sb = new StringBuffer();
318	int rlnum = snum;
319	while(rlnum < lnum - 1){
320	String rdline = lines[rlnum++];
321	if(rdline.length() < 1) break;
322	int lidx = rdline.indexOf('=');
323	if(lidx != -1){
324	String key = rdline.substring(0, lidx);
325	String value = rdline.substring(lidx + 1, rdline.length());
326	rdattrs.put(key, value);
327	}
328	}
329	while(rlnum < lnum - 1){
330	String rdline = lines[rlnum++];
331	sb.append(rdline);
332	sb.append("\n");
333	}
334	String rduri = (String)rdattrs.get("@uri");
335	String rdsnippet = sb.toString();
336	if(rduri != null){
337	ResultDocument doc = new ResultDocumentImpl(rduri, rdattrs, rdsnippet);
338	docs.add(doc);
339	}
340	}
341	snum = lnum;
342	if(line.substring(border.length(), line.length()).equals(":END")) end = true;
343	}
344	if(end) break;
345	}
346	return nres;
347	} catch(Exception e){
348	return null;
349	}
350	}
351	public boolean set_user(String name, int mode){
352	status = -1;
353	if(url == null) return false;
354	try {
355	URL purl = new URL(url);
356	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
357	purl.getPath() + "/_set_user");
358	List reqheads = new ArrayList(2);
359	if(auth != null)
360	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
361	reqheads.add("Content-Type: application/x-www-form-urlencoded");
362	String qstr = "name=" + URLEncoder.encode(name, "UTF-8") + "&mode=" + mode;
363	byte[] reqbody = qstr.getBytes("ISO-8859-1");
364	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
365	null, null);
366	if(status != 200) return false;
367	return true;
368	} catch(Exception e){
369	return false;
370	}
371	}
372	public boolean set_link(String url, String label, int credit){
373	status = -1;
374	if(this.url == null) return false;
375	try {
376	URL purl = new URL(this.url);
377	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
378	purl.getPath() + "/_set_link");
379	List reqheads = new ArrayList(2);
380	if(auth != null)
381	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
382	reqheads.add("Content-Type: application/x-www-form-urlencoded");
383	String qstr = "url=" + URLEncoder.encode(url, "UTF-8") +
384	"&label=" + URLEncoder.encode(label, "UTF-8");
385	if(credit >= 0) qstr = qstr + "&credit=" + credit;
386	byte[] reqbody = qstr.getBytes("ISO-8859-1");
387	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, reqbody,
388	null, null);
389	if(status != 200) return false;
390	return true;
391	} catch(Exception e){
392	return false;
393	}
394	}
395	//----------------------------------------------------------------
396	// private methods
397	//----------------------------------------------------------------
398	private void set_info(){
399	status = -1;
400	if(url == null) return;
401	try {
402	URL purl = new URL(url);
403	URL eurl = new URL("http://" + purl.getHost() + ":" + purl.getPort() +
404	purl.getPath() + "/inform");
405	List reqheads = new ArrayList(2);
406	if(auth != null)
407	reqheads.add("Authorization: Basic " + Utility.baseEncode(auth.getBytes()));
408	ByteArrayOutputStream resbody = new ByteArrayOutputStream();
409	status = Utility.shuttleURL(eurl.toString(), pxhost, pxport, reqheads, null,
410	null, resbody);
411	if(status != 200) return;
412	String resstr = resbody.toString("UTF-8");
413	String[] lines = Utility.splitLines(resstr);
414	if(lines.length < 1) return;
415	String[] fields = Utility.splitFields(lines[0]);
416	if(fields.length != 5) return;
417	name = fields[0];
418	label = fields[1];
419	dnum = Integer.parseInt(fields[2]);
420	wnum = Integer.parseInt(fields[3]);
421	size = Double.parseDouble(fields[4]);
422	if(dnum < 0 \|\| wnum < 0 \|\| size < 0.0){
423	dnum = -1;
424	wnum = -1;
425	size = -1.0;
426	}
427	} catch(Exception e){
428	name = null;
429	label = null;
430	dnum = -1;
431	wnum = -1;
432	size = -1.0;
433	}
434	}
435	private String cond_to_query(Condition cond, int depth){
436	StringBuffer sb = new StringBuffer();
437	try {
438	String phrase = cond.phrase();
439	sb.append("phrase=");
440	if(phrase != null) sb.append(URLEncoder.encode(phrase, "UTF-8"));
441	List attrs = cond.attrs();
442	Iterator it = cond.attrs().iterator();
443	for(int i = 1; it.hasNext(); i++){
444	sb.append("&attr=");
445	sb.append(i);
446	sb.append(URLEncoder.encode((String)it.next(), "UTF-8"));
447	}
448	String order = cond.order();
449	if(order != null){
450	sb.append("&order=");
451	sb.append(URLEncoder.encode(order, "UTF-8"));
452	}
453	int max = cond.max();
454	if(max >= 0){
455	sb.append("&max=");
456	sb.append(max);
457	}
458	int options = cond.options();
459	if(options > 0){
460	sb.append("&options=");
461	sb.append(options);
462	}
463	if(depth > 0){
464	sb.append("&depth=");
465	sb.append(depth);
466	}
467	} catch(UnsupportedEncodingException e){
468	throw new RuntimeException(e);
469	}
470	return sb.toString();
471	}
472	}
473
474
475
476	/* END OF FILE */