/*
 * Copyright (c) 1996, 2004, Oracle and/or its affiliates. All rights reserved.
 * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
 *
 * This code is free software; you can redistribute it and/or modify it
 * under the terms of the GNU General Public License version 2 only, as
 * published by the Free Software Foundation.  Oracle designates this
 * particular file as subject to the "Classpath" exception as provided
 * by Oracle in the LICENSE file that accompanied this code.
 *
 * This code is distributed in the hope that it will be useful, but WITHOUT
 * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
 * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
 * version 2 for more details (a copy is included in the LICENSE file that
 * accompanied this code).
 *
 * You should have received a copy of the GNU General Public License version
 * 2 along with this work; if not, write to the Free Software Foundation,
 * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
 *
 * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
 * or visit www.oracle.com if you need additional information or have any
 * questions.
 */
package sun.net.www.protocol.gopher;

import java.io.*;
import java.util.*;
import java.net.*;
import sun.net.www.*;
import sun.net.NetworkClient;
import java.net.URL;
import java.net.URLStreamHandler;

import sun.security.action.GetBooleanAction;

Class to maintain the state of a gopher fetch and handle the protocol
/** Class to maintain the state of a gopher fetch and handle the protocol */
public class GopherClient extends NetworkClient implements Runnable { /* The following three data members are left in for binary * backwards-compatibility. Unfortunately, HotJava sets them directly * when it wants to change the settings. The new design has us not * cache these, so this is unnecessary, but eliminating the data members * would break HJB 1.1 under JDK 1.2. * * These data members are not used, and their values are meaningless. * REMIND: Take them out for JDK 2.0! */
Deprecated:
/** * @deprecated */
@Deprecated public static boolean useGopherProxy;
Deprecated:
/** * @deprecated */
@Deprecated public static String gopherProxyHost;
Deprecated:
/** * @deprecated */
@Deprecated public static int gopherProxyPort; static { useGopherProxy = java.security.AccessController.doPrivileged( new sun.security.action.GetBooleanAction("gopherProxySet")) .booleanValue(); gopherProxyHost = java.security.AccessController.doPrivileged( new sun.security.action.GetPropertyAction("gopherProxyHost")); gopherProxyPort = java.security.AccessController.doPrivileged( new sun.security.action.GetIntegerAction("gopherProxyPort", 80)) .intValue(); } PipedOutputStream os; URL u; int gtype; String gkey; sun.net.www.URLConnection connection; GopherClient(sun.net.www.URLConnection connection) { this.connection = connection; }
Returns:true if gopher connections should go through a proxy, according to system properties.
/** * @return true if gopher connections should go through a proxy, according * to system properties. */
public static boolean getUseGopherProxy() { return java.security.AccessController.doPrivileged( new GetBooleanAction("gopherProxySet")).booleanValue(); }
Returns:the proxy host to use, or null if nothing is set.
/** * @return the proxy host to use, or null if nothing is set. */
public static String getGopherProxyHost() { String host = java.security.AccessController.doPrivileged( new sun.security.action.GetPropertyAction("gopherProxyHost")); if ("".equals(host)) { host = null; } return host; }
Returns:the proxy port to use. Will default reasonably.
/** * @return the proxy port to use. Will default reasonably. */
public static int getGopherProxyPort() { return java.security.AccessController.doPrivileged( new sun.security.action.GetIntegerAction("gopherProxyPort", 80)) .intValue(); }
Given a url, setup to fetch the gopher document it refers to
/** Given a url, setup to fetch the gopher document it refers to */
InputStream openStream(URL u) throws IOException { this.u = u; this.os = os; int i = 0; String s = u.getFile(); int limit = s.length(); int c = '1'; while (i < limit && (c = s.charAt(i)) == '/') i++; gtype = c == '/' ? '1' : c; if (i < limit) i++; gkey = s.substring(i); openServer(u.getHost(), u.getPort() <= 0 ? 70 : u.getPort()); MessageHeader msgh = new MessageHeader(); switch (gtype) { case '0': case '7': msgh.add("content-type", "text/plain"); break; case '1': msgh.add("content-type", "text/html"); break; case 'g': case 'I': msgh.add("content-type", "image/gif"); break; default: msgh.add("content-type", "content/unknown"); break; } if (gtype != '7') { serverOutput.print(decodePercent(gkey) + "\r\n"); serverOutput.flush(); } else if ((i = gkey.indexOf('?')) >= 0) { serverOutput.print(decodePercent(gkey.substring(0, i) + "\t" + gkey.substring(i + 1) + "\r\n")); serverOutput.flush(); msgh.add("content-type", "text/html"); } else { msgh.add("content-type", "text/html"); } connection.setProperties(msgh); if (msgh.findValue("content-type") == "text/html") { os = new PipedOutputStream(); PipedInputStream ret = new PipedInputStream(); ret.connect(os); new Thread(this).start(); return ret; } return new GopherInputStream(this, serverInput); }
Translate all the instances of %NN into the character they represent
/** Translate all the instances of %NN into the character they represent */
private String decodePercent(String s) { if (s == null || s.indexOf('%') < 0) return s; int limit = s.length(); char d[] = new char[limit]; int dp = 0; for (int sp = 0; sp < limit; sp++) { int c = s.charAt(sp); if (c == '%' && sp + 2 < limit) { int s1 = s.charAt(sp + 1); int s2 = s.charAt(sp + 2); if ('0' <= s1 && s1 <= '9') s1 = s1 - '0'; else if ('a' <= s1 && s1 <= 'f') s1 = s1 - 'a' + 10; else if ('A' <= s1 && s1 <= 'F') s1 = s1 - 'A' + 10; else s1 = -1; if ('0' <= s2 && s2 <= '9') s2 = s2 - '0'; else if ('a' <= s2 && s2 <= 'f') s2 = s2 - 'a' + 10; else if ('A' <= s2 && s2 <= 'F') s2 = s2 - 'A' + 10; else s2 = -1; if (s1 >= 0 && s2 >= 0) { c = (s1 << 4) | s2; sp += 2; } } d[dp++] = (char) c; } return new String(d, 0, dp); }
Turn special characters into the %NN form
/** Turn special characters into the %NN form */
private String encodePercent(String s) { if (s == null) return s; int limit = s.length(); char d[] = null; int dp = 0; for (int sp = 0; sp < limit; sp++) { int c = s.charAt(sp); if (c <= ' ' || c == '"' || c == '%') { if (d == null) d = s.toCharArray(); if (dp + 3 >= d.length) { char nd[] = new char[dp + 10]; System.arraycopy(d, 0, nd, 0, dp); d = nd; } d[dp] = '%'; int dig = (c >> 4) & 0xF; d[dp + 1] = (char) (dig < 10 ? '0' + dig : 'A' - 10 + dig); dig = c & 0xF; d[dp + 2] = (char) (dig < 10 ? '0' + dig : 'A' - 10 + dig); dp += 3; } else { if (d != null) { if (dp >= d.length) { char nd[] = new char[dp + 10]; System.arraycopy(d, 0, nd, 0, dp); d = nd; } d[dp] = (char) c; } dp++; } } return d == null ? s : new String(d, 0, dp); }
This method is run as a seperate thread when an incoming gopher document requires translation to html
/** This method is run as a seperate thread when an incoming gopher document requires translation to html */
public void run() { int qpos = -1; try { if (gtype == '7' && (qpos = gkey.indexOf('?')) < 0) { PrintStream ps = new PrintStream(os, false, encoding); ps.print("<html><head><title>Searchable Gopher Index</title></head>\n<body><h1>Searchable Gopher Index</h1><isindex>\n</body></html>\n"); } else if (gtype != '1' && gtype != '7') { byte buf[] = new byte[2048]; try { int n; while ((n = serverInput.read(buf)) >= 0) os.write(buf, 0, n); } catch(Exception e) { } } else { PrintStream ps = new PrintStream(os, false, encoding); String title = null; if (gtype == '7') title = "Results of searching for \"" + gkey.substring(qpos + 1) + "\" on " + u.getHost(); else title = "Gopher directory " + gkey + " from " + u.getHost(); ps.print("<html><head><title>"); ps.print(title); ps.print("</title></head>\n<body>\n<H1>"); ps.print(title); ps.print("</h1><dl compact>\n"); BufferedReader ds = new BufferedReader(new InputStreamReader(serverInput)); String s; while ((s = ds.readLine()) != null) { int len = s.length(); while (len > 0 && s.charAt(len - 1) <= ' ') len--; if (len <= 0) continue; int key = s.charAt(0); int t1 = s.indexOf('\t'); int t2 = t1 > 0 ? s.indexOf('\t', t1 + 1) : -1; int t3 = t2 > 0 ? s.indexOf('\t', t2 + 1) : -1; if (t3 < 0) { // ps.print("<br><i>"+s+"</i>\n"); continue; } String port = t3 + 1 < len ? ":" + s.substring(t3 + 1, len) : ""; String host = t2 + 1 < t3 ? s.substring(t2 + 1, t3) : u.getHost(); ps.print("<dt><a href=\"gopher://" + host + port + "/" + s.substring(0, 1) + encodePercent(s.substring(t1 + 1, t2)) + "\">\n"); ps.print("<img align=middle border=0 width=25 height=32 src="); switch (key) { default: ps.print(System.getProperty("java.net.ftp.imagepath.file")); break; case '0': ps.print(System.getProperty("java.net.ftp.imagepath.text")); break; case '1': ps.print(System.getProperty("java.net.ftp.imagepath.directory")); break; case 'g': ps.print(System.getProperty("java.net.ftp.imagepath.gif")); break; } ps.print(".gif align=middle><dd>\n"); ps.print(s.substring(1, t1) + "</a>\n"); } ps.print("</dl></body>\n"); ps.close(); } } catch (UnsupportedEncodingException e) { throw new InternalError(encoding+ " encoding not found"); } catch (IOException e) { } finally { try { closeServer(); os.close(); } catch (IOException e2) { } } } }
An input stream that does nothing more than hold on to the NetworkClient that created it. This is used when only the input stream is needed, and the network client needs to be closed when the input stream is closed.
/** An input stream that does nothing more than hold on to the NetworkClient that created it. This is used when only the input stream is needed, and the network client needs to be closed when the input stream is closed. */
class GopherInputStream extends FilterInputStream { NetworkClient parent; GopherInputStream(NetworkClient o, InputStream fd) { super(fd); parent = o; } public void close() { try { parent.closeServer(); super.close(); } catch (IOException e) { } } }