1.1 --- a/ko-ws-tyrus/src/test/java/org/netbeans/html/wstyrus/TyrusDynamicHTTP.java Sat Aug 02 12:59:31 2014 +0200
1.2 +++ b/ko-ws-tyrus/src/test/java/org/netbeans/html/wstyrus/TyrusDynamicHTTP.java Wed May 27 23:37:25 2015 +0200
1.3 @@ -75,28 +75,28 @@
1.4 private static List<Resource> resources;
1.5 private static ServerConfiguration conf;
1.6 private static HttpServer server;
1.7 -
1.8 +
1.9 private TyrusDynamicHTTP() {
1.10 }
1.11 -
1.12 +
1.13 static URI initServer() throws Exception {
1.14 server = HttpServer.createSimpleServer(null, new PortRange(8080, 65535));
1.15 final WebSocketAddOn addon = new WebSocketAddOn();
1.16 for (NetworkListener listener : server.getListeners()) {
1.17 listener.registerAddOn(addon);
1.18 - }
1.19 + }
1.20 resources = new ArrayList<Resource>();
1.21
1.22 conf = server.getServerConfiguration();
1.23 final TyrusDynamicHTTP dh = new TyrusDynamicHTTP();
1.24
1.25 conf.addHttpHandler(dh, "/");
1.26 -
1.27 +
1.28 server.start();
1.29
1.30 return pageURL("http", server, "/test.html");
1.31 }
1.32 -
1.33 +
1.34 @Override
1.35 public void service(Request request, Response response) throws Exception {
1.36 if ("/test.html".equals(request.getRequestURI())) {
1.37 @@ -158,6 +158,8 @@
1.38 sb.append((char) ch);
1.39 }
1.40 params[i] = sb.toString();
1.41 + } else if (r.parameters[i].startsWith("http.header.")) {
1.42 + params[i] = request.getHeader(r.parameters[i].substring(12));
1.43 }
1.44 }
1.45 if (params[i] == null) {
1.46 @@ -170,7 +172,7 @@
1.47 }
1.48 }
1.49 }
1.50 -
1.51 +
1.52 private URI registerWebSocket(Resource r) {
1.53 WebSocketEngine.getEngine().register("", r.httpPath, new WS(r));
1.54 return pageURL("ws", server, r.httpPath);
1.55 @@ -183,7 +185,7 @@
1.56 }
1.57 return pageURL("http", server, r.httpPath);
1.58 }
1.59 -
1.60 +
1.61 private static URI pageURL(String proto, HttpServer server, final String page) {
1.62 NetworkListener listener = server.getListeners().iterator().next();
1.63 int port = listener.getPort();
1.64 @@ -193,7 +195,7 @@
1.65 throw new IllegalStateException(ex);
1.66 }
1.67 }
1.68 -
1.69 +
1.70 static final class Resource {
1.71
1.72 final InputStream httpContent;
1.73 @@ -234,7 +236,7 @@
1.74 }
1.75 }
1.76 }
1.77 -
1.78 +
1.79 private static class WS extends WebSocketApplication {
1.80 private final Resource r;
1.81
1.82 @@ -255,6 +257,6 @@
1.83 }
1.84 }
1.85 private static final Logger LOG = Logger.getLogger(WS.class.getName());
1.86 -
1.87 +
1.88 }
1.89 }