|
30 | 30 | import jooby.Response; |
31 | 31 | import jooby.Route; |
32 | 32 | import jooby.Route.Err; |
33 | | -import jooby.WebSocket; |
34 | | -import jooby.WebSocket.Definition; |
35 | 33 |
|
36 | 34 | import org.slf4j.Logger; |
37 | 35 | import org.slf4j.LoggerFactory; |
@@ -65,22 +63,18 @@ public class RouteHandler { |
65 | 63 |
|
66 | 64 | private Err.Handler err; |
67 | 65 |
|
68 | | - private Set<Definition> sockets; |
69 | | - |
70 | 66 | @Inject |
71 | 67 | public RouteHandler(final Injector injector, |
72 | 68 | final BodyConverterSelector selector, |
73 | 69 | final Set<Request.Module> modules, |
74 | 70 | final Set<Route.Definition> routes, |
75 | | - final Set<WebSocket.Definition> sockets, |
76 | 71 | final Charset defaultCharset, |
77 | 72 | final Locale defaultLocale, |
78 | 73 | final Route.Err.Handler err) { |
79 | 74 | this.rootInjector = requireNonNull(injector, "An injector is required."); |
80 | 75 | this.selector = requireNonNull(selector, "A message converter selector is required."); |
81 | 76 | this.modules = requireNonNull(modules, "Request modules are required."); |
82 | 77 | this.routeDefs = requireNonNull(routes, "The routes are required."); |
83 | | - this.sockets = requireNonNull(sockets, "The sockets are required."); |
84 | 78 | this.charset = requireNonNull(defaultCharset, "A defaultCharset is required."); |
85 | 79 | this.locale = requireNonNull(defaultLocale, "A defaultLocale is required."); |
86 | 80 | this.err = requireNonNull(err, "An err handler is required."); |
@@ -112,7 +106,7 @@ public void handle(final HttpServletRequest request, final HttpServletResponse r |
112 | 106 |
|
113 | 107 | final String path = verb + requestURI; |
114 | 108 |
|
115 | | - log.info("handling: {}", path); |
| 109 | + log.debug("handling: {}", path); |
116 | 110 |
|
117 | 111 | log.debug(" content-type: {}", type); |
118 | 112 |
|
@@ -170,14 +164,10 @@ public void handle(final HttpServletRequest request, final HttpServletResponse r |
170 | 164 | } |
171 | 165 | } finally { |
172 | 166 | long end = System.currentTimeMillis(); |
173 | | - log.info(" status -> {} in {}ms", response.getStatus(), end - start); |
| 167 | + log.debug(" status -> {} in {}ms", response.getStatus(), end - start); |
174 | 168 | } |
175 | 169 | } |
176 | 170 |
|
177 | | - public boolean hasWebSockets() { |
178 | | - return sockets.size() > 0; |
179 | | - } |
180 | | - |
181 | 171 | public Injector injector() { |
182 | 172 | return rootInjector; |
183 | 173 | } |
@@ -431,29 +421,6 @@ public String toString() { |
431 | 421 | routeDef.consumes(), routeDef.produces(), routeDef.name())); |
432 | 422 | } |
433 | 423 |
|
434 | | - if (sockets.size() > 0) { |
435 | | - buffer.append("\nWeb Sockets:\n"); |
436 | | - |
437 | | - verbMax = "WS".length(); |
438 | | - routeMax = 0; |
439 | | - consumesMax = 0; |
440 | | - producesMax = 0; |
441 | | - for (WebSocket.Definition socketDef : sockets) { |
442 | | - routeMax = Math.max(routeMax, socketDef.pattern().length()); |
443 | | - |
444 | | - consumesMax = Math.max(consumesMax, socketDef.consumes().toString().length()); |
445 | | - |
446 | | - producesMax = Math.max(producesMax, socketDef.produces().toString().length()); |
447 | | - } |
448 | | - |
449 | | - format = " %-" + verbMax + "s %-" + routeMax + "s %" + consumesMax + "s %" |
450 | | - + producesMax + "s (%s)\n"; |
451 | | - |
452 | | - for (WebSocket.Definition socketDef : sockets) { |
453 | | - buffer.append(String.format(format, "WS", socketDef.pattern(), |
454 | | - socketDef.consumes(), socketDef.produces(), socketDef.name())); |
455 | | - } |
456 | | - } |
457 | 424 | return buffer.toString(); |
458 | 425 | } |
459 | 426 | } |
0 commit comments