()
| 8881 | socket.typebuffer = true; |
| 8882 | |
| 8883 | var next = function() { |
| 8884 | |
| 8885 | if (req.$total_middleware) |
| 8886 | req.$total_middleware = null; |
| 8887 | |
| 8888 | if (F.connections[id]) { |
| 8889 | socket.upgrade(F.connections[id]); |
| 8890 | return; |
| 8891 | } |
| 8892 | |
| 8893 | var connection = new WebSocket(path, route.controller, id); |
| 8894 | connection.encodedecode = CONF.default_websocket_encodedecode === true; |
| 8895 | connection.route = route; |
| 8896 | connection.options = route.options; |
| 8897 | F.connections[id] = connection; |
| 8898 | route.onInitialize.apply(connection, framework_internal.routeParam(route.param.length ? req.split : req.path, route)); |
| 8899 | setImmediate(next_upgrade_continue, socket, connection); |
| 8900 | }; |
| 8901 | |
| 8902 | if (route.middleware) |
| 8903 | async_middleware(0, req, req.websocket, route.middleware, next, route.options); |
no outgoing calls
no test coverage detected