GithubStar/whistle
1
0
Fork 0
mirror of https://github.com/avwo/whistle.git synced 2026-10-27 04:19:59 +08:00
Code Issues Packages Projects Releases Wiki Activity

refactor: Add hparser

Browse Source
This commit is contained in:
avwo
2017-11-21 23:53:23 +08:00
parent c2f9ffedc0
commit cfdf99ceaf
9 changed files with 27 additions and 278 deletions
Download Patch File Download Diff File Expand all files Collapse all files
lib/https/index.js
+5 -3
View File
@@ -12,6 +12,8 @@ var pluginMgr = require('../plugins');
var socketMgr = require('../socket-mgr');
var serverAgent = require('./util').serverAgent;
var logger = require('../util/logger');
var parseReq = require('hparser').parse;
var LOCALHOST = '127.0.0.1';
var tunnelTmplData = {};
var proxy;
@@ -295,7 +297,7 @@ function handleWebsocket(socket, clientIp, clientPort, callback, wss) {
reqSocket.write(socket.getBuffer((isInternalProxy || reqHeaders
|| plugin || matchedUrl || _rules.hostname || util.hasHeaderRules(headers)) ? headers : null,
matchedUrl ? options.path : null));
util.parseReq(reqSocket, function(err, res) {
parseReq(reqSocket, function(err, res) {
if (err) {
return execCallback(err);
}
@@ -410,7 +412,7 @@ function handleTlsSocket(socket) {
return socket.on('error', destroy).on('close', destroy);
}
util.parseReq(socket, function(err, socket) {
parseReq(socket, function(err, socket) {
if (err) {
return destroy(err);
}
@@ -471,7 +473,7 @@ module.exports = function dispatch(socket, hostname, callback) {
}
if (/upgrade\s*:\s*websocket/i.test(chunk.toString())) { //ws
util.parseReq(socket, function(err, socket) {
parseReq(socket, function(err, socket) {
if (err) {
return destroy(err);
}