001: /*
002: License $Id: RequestLine.java,v 1.6 2003/09/13 04:59:55 hendriks73 Exp $
003:
004: Copyright (c) 2001-2005 tagtraum industries.
005:
006: LGPL
007: ====
008:
009: jo! is free software; you can redistribute it and/or
010: modify it under the terms of the GNU Lesser General Public
011: License as published by the Free Software Foundation; either
012: version 2.1 of the License, or (at your option) any later version.
013:
014: jo! is distributed in the hope that it will be useful,
015: but WITHOUT ANY WARRANTY; without even the implied warranty of
016: MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
017: Lesser General Public License for more details.
018:
019: You should have received a copy of the GNU Lesser General Public
020: License along with this library; if not, write to the Free Software
021: Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA 02111-1307 USA
022:
023: For LGPL see <http://www.fsf.org/copyleft/lesser.txt>
024:
025:
026: Sun license
027: ===========
028:
029: This release contains software by Sun Microsystems. Therefore
030: the following conditions have to be met, too. They apply to the
031: files
032:
033: - lib/mail.jar
034: - lib/activation.jar
035: - lib/jsse.jar
036: - lib/jcert.jar
037: - lib/jaxp.jar
038: - lib/crimson.jar
039: - lib/servlet.jar
040: - lib/jnet.jar
041: - lib/jaas.jar
042: - lib/jaasmod.jar
043:
044: contained in this release.
045:
046: a. Licensee may not modify the Java Platform
047: Interface (JPI, identified as classes contained within the javax
048: package or any subpackages of the javax package), by creating additional
049: classes within the JPI or otherwise causing the addition to or modification
050: of the classes in the JPI. In the event that Licensee creates any
051: Java-related API and distribute such API to others for applet or
052: application development, you must promptly publish broadly, an accurate
053: specification for such API for free use by all developers of Java-based
054: software.
055:
056: b. Software is confidential copyrighted information of Sun and
057: title to all copies is retained by Sun and/or its licensors. Licensee
058: shall not modify, decompile, disassemble, decrypt, extract, or otherwise
059: reverse engineer Software. Software may not be leased, assigned, or
060: sublicensed, in whole or in part. Software is not designed or intended
061: for use in on-line control of aircraft, air traffic, aircraft navigation
062: or aircraft communications; or in the design, construction, operation or
063: maintenance of any nuclear facility. Licensee warrants that it will not
064: use or redistribute the Software for such purposes.
065:
066: c. Software is provided "AS IS," without a warranty
067: of any kind. ALL EXPRESS OR IMPLIED REPRESENTATIONS AND WARRANTIES,
068: INCLUDING ANY IMPLIED WARRANTY OF MERCHANTABILITY, FITNESS FOR A
069: PARTICULAR PURPOSE OR NON-INFRINGEMENT, ARE HEREBY EXCLUDED.
070:
071: d. This License is effective until terminated. Licensee may
072: terminate this License at any time by destroying all copies of Software.
073: This License will terminate immediately without notice from Sun if Licensee
074: fails to comply with any provision of this License. Upon such termination,
075: Licensee must destroy all copies of Software.
076:
077: e. Software, including technical data, is subject to U.S.
078: export control laws, including the U.S. Export Administration Act and its
079: associated regulations, and may be subject to export or import regulations
080: in other countries. Licensee agrees to comply strictly with all such
081: regulations and acknowledges that it has the responsibility to obtain
082: licenses to export, re-export, or import Software. Software may not be
083: downloaded, or otherwise exported or re-exported (i) into, or to a national
084: or resident of, Cuba, Iraq, Iran, North Korea, Libya, Sudan, Syria or any
085: country to which the U.S. has embargoed goods; or (ii) to anyone on the
086: U.S. Treasury Department's list of Specially Designated Nations or the U.S.
087: Commerce Department's Table of Denial Orders.
088:
089:
090: Feedback
091: ========
092:
093: We encourage your feedback and suggestions and want to use your feedback to
094: improve the Software. Send all such feedback to:
095: <feedback@tagtraum.com>
096:
097: For more information on tagtraum industries and jo!
098: please see <http://www.tagtraum.com/>.
099:
100:
101: */
102: package com.tagtraum.framework.http;
103:
104: import com.tagtraum.framework.util.UnSyncStringBuffer;
105: import com.tagtraum.perf.util.SingleDelimiterStringTokenizer;
106:
107: import javax.servlet.ServletOutputStream;
108: import javax.servlet.http.HttpServletResponse;
109: import java.io.*;
110:
111: /**
112: * Encapsulates a RequestLine. This class is not synchronized.
113: *
114: * @version 1.1beta1 $Id: RequestLine.java,v 1.6 2003/09/13 04:59:55 hendriks73 Exp $
115: * @author Hendrik Schreiber
116: */
117: public class RequestLine implements C_Http, Serializable {
118:
119: /**
120: * Source-Version
121: */
122: public static String vcid = "$Id: RequestLine.java,v 1.6 2003/09/13 04:59:55 hendriks73 Exp $";
123:
124: private URI uri;
125: private String protocol;
126: private String method;
127: private byte[] readbuf;
128: private SingleDelimiterStringTokenizer tokenizer;
129:
130: public RequestLine() {
131: uri = new URI();
132: readbuf = new byte[1024];
133: tokenizer = new SingleDelimiterStringTokenizer();
134: }
135:
136: public RequestLine(String requestLine) throws HttpException {
137: this ();
138: read(requestLine);
139: }
140:
141: /**
142: * Reads a RequestLine from an <code>String</code>.
143: *
144: * @param requestLine the request line
145: */
146: public void read(String requestLine) throws HttpException {
147: parseRequestLine(requestLine);
148: }
149:
150: /**
151: * Reads a RequestLine from an <code>InputStream</code>.
152: *
153: * @param inputStream the InputStream
154: */
155: public void read(InputStream inputStream) throws IOException,
156: HttpException {
157: protocol = null;
158: method = null;
159: uri.init(null);
160: int c;
161: int size = 0;
162: int offset = 0;
163: int token = 0;
164:
165: LineLoop: while ((c = inputStream.read()) != -1) {
166: switch (c) {
167: case 10: // \n
168: break LineLoop;
169: case 13: // \r
170: case 32: // SPACE
171: if (token == 0) {
172: // this is not totally failsafe, but fast
173: if (readbuf[0] == (byte) 'G') {
174: method = C_HTTP_GET;
175: } else if (readbuf[0] == (byte) 'H') {
176: method = C_HTTP_HEAD;
177: } else if (readbuf[0] == (byte) 'P') {
178: if (readbuf[1] == (byte) 'O') {
179: method = C_HTTP_POST;
180: } else {
181: method = C_HTTP_PUT;
182: }
183: } else if (readbuf[0] == (byte) 'D') {
184: method = C_HTTP_DELETE;
185: } else if (readbuf[0] == (byte) 'O') {
186: method = C_HTTP_OPTIONS;
187: } else if (readbuf[0] == (byte) 'T') {
188: method = C_HTTP_TRACE;
189: } else if (readbuf[0] == (byte) 'C') {
190: method = C_HTTP_CONNECT;
191: } else {
192: throw new HttpException(
193: HttpServletResponse.SC_BAD_REQUEST,
194: "Method '"
195: + new String(readbuf, 0,
196: offset, size - offset)
197: + "' is not supported.");
198: }
199: } // this line is expensive (rik)
200: else if (token == 1) {
201: uri.init(new String(readbuf, 0, offset, size
202: - offset)); // deprecated, but fast
203: } else if (token == 2) {
204: if (readbuf[size - 3] == (byte) '0') {
205: protocol = C_HTTP_0_9;
206: } else if (readbuf[size - 3] == (byte) '1') {
207: if (readbuf[size - 1] == (byte) '0') {
208: protocol = C_HTTP_1_0;
209: } else if (readbuf[size - 1] == (byte) '1') {
210: protocol = C_HTTP_1_1;
211: } else {
212: protocol = new String(readbuf, 0, offset,
213: size - offset); // deprecated, but fast
214: }
215: } else {
216: protocol = new String(readbuf, 0, offset, size
217: - offset); // deprecated, but fast
218: }
219: }
220: token++;
221: offset = size;
222: break;
223: default:
224: readbuf[size] = (byte) c;
225: size++;
226: if (size == 1024) {
227: throw new HttpException(
228: HttpServletResponse.SC_REQUEST_URI_TOO_LONG);
229: }
230: break;
231: }
232: }
233: if (size == 0) {
234: throw new EOFException(
235: "The stream has been closed by the peer.");
236: }
237: if (token < 2 || token > 3) {
238: throw new HttpException(HttpServletResponse.SC_BAD_REQUEST);
239: }
240: if (protocol == null || !protocol.startsWith("HTTP/")) {
241: protocol = C_HTTP_0_9;
242: }
243: }
244:
245: /**
246: * Writes the RequestLine to an <code>OuputStream</code>.
247: *
248: * @param out the OutputStream
249: */
250: public void write(OutputStream out) throws IOException {
251: out.write(toString().getBytes("ISO-8859-1"));
252: }
253:
254: /**
255: * Writes the RequestLine to an <code>ServletOuputStream</code>.
256: *
257: * @param out the ServletOutputStream
258: */
259: public void write(ServletOutputStream out) throws IOException {
260: out.print(toString());
261: }
262:
263: /**
264: * Returns the {@link URI}.
265: */
266: public URI getURI() {
267: return uri;
268: }
269:
270: /**
271: * Sets a {@link URI}.
272: */
273: public void setURI(URI aURI) {
274: this .uri = aURI;
275: }
276:
277: /**
278: * Returns the protocol.
279: */
280: public String getProtocol() {
281: return protocol;
282: }
283:
284: /**
285: * Sets a protocol.
286: */
287: public void setProtocol(String aProtocol) {
288: this .protocol = aProtocol;
289: }
290:
291: /**
292: * Returns the method.
293: */
294: public String getMethod() {
295: return method;
296: }
297:
298: /**
299: * Sets a method.
300: */
301: public void setMethod(String aMethod) {
302: this .method = aMethod;
303: }
304:
305: /**
306: * String.
307: */
308: public String toString() {
309: UnSyncStringBuffer sb = new UnSyncStringBuffer();
310: if (method != null) {
311: sb.append(method);
312: sb.append(' ');
313: }
314: if (uri != null) {
315: sb.append(uri.toString());
316: sb.append(' ');
317: }
318: if (protocol != null) {
319: sb.append(protocol);
320: }
321: return sb.toString();
322: }
323:
324: /**
325: * Returns a clone.
326: */
327: public Object clone() {
328: RequestLine theRequestLine = new RequestLine();
329: try {
330: theRequestLine.read(toString());
331: } catch (HttpException he) {
332: // ignore
333: }
334: return theRequestLine;
335: }
336:
337: /**
338: * Parses a RequestLine.
339: */
340: private void parseRequestLine(String aRequestLine)
341: throws HttpException {
342: tokenizer.init(aRequestLine, ' ');
343: int count = tokenizer.countTokens();
344: if (count == 3) {
345: method = tokenizer.nextToken();
346: uri.init(tokenizer.nextToken());
347: protocol = tokenizer.nextToken();
348: } else if (count == 2) {
349: method = tokenizer.nextToken();
350: uri.init(tokenizer.nextToken());
351: protocol = C_HTTP_0_9;
352: } else {
353: throw new HttpException(HttpServletResponse.SC_BAD_REQUEST);
354: }
355: if (protocol == null || !protocol.startsWith("HTTP/")) {
356: protocol = C_HTTP_0_9;
357: }
358: }
359:
360: }
|