From ba1c1d1c31116357139d584196559dfd5a26896c Mon Sep 17 00:00:00 2001 From: Florian Vallee Date: Fri, 12 Sep 2014 11:17:12 +0200 Subject: expose initial http request to WebSocket handlers replace headers object with the complete AsyncHttpServerRequest in callback see #232 --- .../src/com/koushikdutta/async/http/server/AsyncHttpServer.java | 4 ++-- AndroidAsync/test/src/com/koushikdutta/async/test/WebSocketTests.java | 3 ++- README.md | 2 +- 3 files changed, 5 insertions(+), 4 deletions(-) diff --git a/AndroidAsync/src/com/koushikdutta/async/http/server/AsyncHttpServer.java b/AndroidAsync/src/com/koushikdutta/async/http/server/AsyncHttpServer.java index b1b393d..41bbfe0 100644 --- a/AndroidAsync/src/com/koushikdutta/async/http/server/AsyncHttpServer.java +++ b/AndroidAsync/src/com/koushikdutta/async/http/server/AsyncHttpServer.java @@ -285,7 +285,7 @@ public class AsyncHttpServer { } public static interface WebSocketRequestCallback { - public void onConnected(WebSocket webSocket, RequestHeaders headers); + public void onConnected(WebSocket webSocket, AsyncHttpServerRequest request); } public void websocket(String regex, final WebSocketRequestCallback callback) { @@ -318,7 +318,7 @@ public class AsyncHttpServer { response.end(); return; } - callback.onConnected(new WebSocketImpl(request, response), request.getHeaders()); + callback.onConnected(new WebSocketImpl(request, response), request); } }); } diff --git a/AndroidAsync/test/src/com/koushikdutta/async/test/WebSocketTests.java b/AndroidAsync/test/src/com/koushikdutta/async/test/WebSocketTests.java index a5a7f92..5784e38 100644 --- a/AndroidAsync/test/src/com/koushikdutta/async/test/WebSocketTests.java +++ b/AndroidAsync/test/src/com/koushikdutta/async/test/WebSocketTests.java @@ -9,6 +9,7 @@ import com.koushikdutta.async.http.WebSocket.StringCallback; import com.koushikdutta.async.http.libcore.RequestHeaders; import com.koushikdutta.async.http.server.AsyncHttpServer; import com.koushikdutta.async.http.server.AsyncHttpServer.WebSocketRequestCallback; +import com.koushikdutta.async.http.server.AsyncHttpServerRequest; import junit.framework.TestCase; @@ -34,7 +35,7 @@ public class WebSocketTests extends TestCase { httpServer.websocket("/ws", new WebSocketRequestCallback() { @Override - public void onConnected(final WebSocket webSocket, RequestHeaders headers) { + public void onConnected(final WebSocket webSocket, AsyncHttpServerRequest request) { webSocket.setStringCallback(new StringCallback() { @Override public void onStringAvailable(String s) { diff --git a/README.md b/README.md index 042c091..9fed2d4 100644 --- a/README.md +++ b/README.md @@ -216,7 +216,7 @@ server.listen(5000); ```java server.websocket("/live", new WebSocketRequestCallback() { @Override - public void onConnected(final WebSocket webSocket, RequestHeaders headers) { + public void onConnected(final WebSocket webSocket, AsyncHttpServerRequest request) { _sockets.add(webSocket); //Use this to clean up any references to your websocket -- cgit v1.2.3