1 /*
2  * Copyright (c) 2005, 2019, Oracle and/or its affiliates. All rights reserved.
3  * DO NOT ALTER OR REMOVE COPYRIGHT NOTICES OR THIS FILE HEADER.
4  *
5  * This code is free software; you can redistribute it and/or modify it
6  * under the terms of the GNU General Public License version 2 only, as
7  * published by the Free Software Foundation.
8  *
9  * This code is distributed in the hope that it will be useful, but WITHOUT
10  * ANY WARRANTY; without even the implied warranty of MERCHANTABILITY or
11  * FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
12  * version 2 for more details (a copy is included in the LICENSE file that
13  * accompanied this code).
14  *
15  * You should have received a copy of the GNU General Public License version
16  * 2 along with this work; if not, write to the Free Software Foundation,
17  * Inc., 51 Franklin St, Fifth Floor, Boston, MA 02110-1301 USA.
18  *
19  * Please contact Oracle, 500 Oracle Parkway, Redwood Shores, CA 94065 USA
20  * or visit www.oracle.com if you need additional information or have any
21  * questions.
22  */
23 
24 /**
25  * @test
26  * @bug 6270015
27  * @summary  Light weight HTTP server
28  * @library /test/lib
29  * @run main Test14
30  * @run main/othervm -Djava.net.preferIPv6Addresses=true Test14
31  */
32 
33 import com.sun.net.httpserver.*;
34 
35 import java.util.*;
36 import java.util.concurrent.*;
37 import java.io.*;
38 import java.net.*;
39 import java.security.*;
40 import javax.security.auth.callback.*;
41 import javax.net.ssl.*;
42 import jdk.test.lib.net.URIBuilder;
43 
44 /**
45  * Test filters
46  */
47 
48 public class Test14 extends Test {
49 
50     static final String test_input = "Hello world";
51     static final String test_output = "Ifmmp!xpsme";
52 
53     /* an outputstream which transforms the output data
54      * by adding one to each byte
55      */
56     static class OffsetOutputStream extends FilterOutputStream {
OffsetOutputStream(OutputStream os)57         OffsetOutputStream (OutputStream os) {
58             super (os);
59         }
write(int b)60         public void write (int b) throws IOException {
61             super.write (b+1);
62         }
63     }
64 
65     static class OffsetFilter extends Filter {
description()66         public String description() {
67             return "Translates outgoing data";
68         }
69 
destroy(HttpContext c)70         public void destroy(HttpContext c) {}
init(HttpContext c)71         public void init(HttpContext c) {}
72 
doFilter(HttpExchange exchange, Filter.Chain chain)73         public void doFilter (HttpExchange exchange, Filter.Chain chain)
74         throws IOException {
75             exchange.setStreams (null, new OffsetOutputStream(
76                 exchange.getResponseBody()
77             ));
78             chain.doFilter (exchange);
79         }
80     }
81 
main(String[] args)82     public static void main (String[] args) throws Exception {
83         Handler handler = new Handler();
84         InetAddress loopback = InetAddress.getLoopbackAddress();
85         InetSocketAddress addr = new InetSocketAddress(loopback, 0);
86         HttpServer server = HttpServer.create (addr, 0);
87         HttpContext ctx = server.createContext ("/test", handler);
88 
89         File logfile = new File (
90             System.getProperty ("test.classes")+ "/log.txt"
91         );
92 
93         ctx.getFilters().add (new OffsetFilter());
94         ctx.getFilters().add (new LogFilter(logfile));
95         if (ctx.getFilters().size() != 2) {
96             throw new RuntimeException ("wrong filter list size");
97         }
98         ExecutorService executor = Executors.newCachedThreadPool();
99         server.setExecutor (executor);
100         server.start ();
101 
102         URL url = URIBuilder.newBuilder()
103                   .scheme("http")
104                   .loopback()
105                   .port(server.getAddress().getPort())
106                   .path("/test/foo.html")
107                   .toURL();
108         System.out.print ("Test14: " );
109         HttpURLConnection urlc = (HttpURLConnection)url.openConnection(Proxy.NO_PROXY);
110         InputStream is = urlc.getInputStream();
111         int x = 0;
112         String output="";
113         while ((x=is.read())!= -1) {
114             output = output + (char)x;
115         }
116         error = !output.equals (test_output);
117         server.stop(2);
118         executor.shutdown();
119         if (error ) {
120             throw new RuntimeException ("test failed error");
121         }
122         System.out.println ("OK");
123 
124     }
125 
126     public static boolean error = false;
127 
128     static class Handler implements HttpHandler {
129         int invocation = 1;
handle(HttpExchange t)130         public void handle (HttpExchange t)
131             throws IOException
132         {
133             InputStream is = t.getRequestBody();
134             Headers map = t.getRequestHeaders();
135             Headers rmap = t.getResponseHeaders();
136             while (is.read () != -1) ;
137             is.close();
138             String response = test_input;
139             t.sendResponseHeaders (200, response.length());
140             OutputStream os = t.getResponseBody();
141             os.write (response.getBytes());
142             t.close();
143         }
144     }
145 }
146