/*

 * Copyright 2005-2006 Sun Microsystems, Inc.  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.

 *

 * 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 Sun Microsystems, Inc., 4150 Network Circle, Santa Clara,

 * CA 95054 USA or visit www.sun.com if you need additional information or

 * have any questions.

 */

/**

 * @test

 * @bug 6270015

 * @summary  Light weight HTTP server

 */

import com.sun.net.httpserver.*;

import java.util.*;

import java.util.concurrent.*;

import java.io.*;

import java.net.*;

import java.security.*;

import javax.security.auth.callback.*;

import javax.net.ssl.*;

/**

 * Test filters

 */

public class Test14 extends Test {

    static final String test_input = "Hello world";

    static final String test_output = "Ifmmp!xpsme";

    /* an outputstream which transforms the output data

     * by adding one to each byte

     */

    static class OffsetOutputStream extends FilterOutputStream {

        OffsetOutputStream (OutputStream os) {

            super (os);

        }

        public void write (int b) throws IOException {

            super.write (b+1);

        }

    }

    static class OffsetFilter extends Filter {

        public String description() {

            return "Translates outgoing data";

        }

        public void destroy(HttpContext c) {}

        public void init(HttpContext c) {}

        public void doFilter (HttpExchange exchange, Filter.Chain chain)

        throws IOException {

            exchange.setStreams (null, new OffsetOutputStream(

                exchange.getResponseBody()

            ));

            chain.doFilter (exchange);

        }

    }

    public static void main (String[] args) throws Exception {

        Handler handler = new Handler();

        InetSocketAddress addr = new InetSocketAddress (0);

        HttpServer server = HttpServer.create (addr, 0);

        HttpContext ctx = server.createContext ("/test", handler);

        File logfile = new File (

            System.getProperty ("test.classes")+ "/log.txt"

        );

        ctx.getFilters().add (new OffsetFilter());

        ctx.getFilters().add (new LogFilter(logfile));

        if (ctx.getFilters().size() != 2) {

            throw new RuntimeException ("wrong filter list size");

        }

        ExecutorService executor = Executors.newCachedThreadPool();

        server.setExecutor (executor);

        server.start ();

        URL url = new URL ("http://localhost:"+server.getAddress().getPort()+"/test/foo.html");

        System.out.print ("Test14: " );

        HttpURLConnection urlc = (HttpURLConnection)url.openConnection ();

        InputStream is = urlc.getInputStream();

        int x = 0;

        String output="";

        while ((x=is.read())!= -1) {

            output = output + (char)x;

        }

        error = !output.equals (test_output);

        server.stop(2);

        executor.shutdown();

        if (error ) {

            throw new RuntimeException ("test failed error");

        }

        System.out.println ("OK");

    }

    public static boolean error = false;

    static class Handler implements HttpHandler {

        int invocation = 1;

        public void handle (HttpExchange t)

            throws IOException

        {

            InputStream is = t.getRequestBody();

            Headers map = t.getRequestHeaders();

            Headers rmap = t.getResponseHeaders();

            while (is.read () != -1) ;

            is.close();

            String response = test_input;

            t.sendResponseHeaders (200, response.length());

            OutputStream os = t.getResponseBody();

            os.write (response.getBytes());

            t.close();

        }

    }

}