mirror of
https://github.com/alibaba/anyproxy.git
synced 2025-08-04 21:39:04 +00:00
update api
This commit is contained in:
@@ -1,5 +1,5 @@
|
||||
//manage https servers
|
||||
var getPort = require('./getPort'),
|
||||
var getPort = require('./getPort'),
|
||||
async = require("async"),
|
||||
http = require('http'),
|
||||
https = require('https'),
|
||||
@@ -8,9 +8,7 @@ var getPort = require('./getPort'),
|
||||
url = require('url'),
|
||||
color = require('colorful'),
|
||||
certMgr = require("./certMgr"),
|
||||
requestHandler = require("./requestHandler"),
|
||||
asyncTask = require("./asyncTaskMgr");
|
||||
|
||||
asyncTask = require("./asyncTaskMgr");
|
||||
|
||||
var DEFAULT_RELEASE_TIME = 120*1000;
|
||||
|
||||
@@ -29,7 +27,7 @@ module.exports =function(){
|
||||
};
|
||||
|
||||
//fetch a port for https server with hostname
|
||||
this.fetchPort = function(hostname,userCB){
|
||||
this.fetchPort = function(hostname,userRequesthandler,userCB){
|
||||
var serverInfo = self.serverList[hostname],
|
||||
port;
|
||||
|
||||
@@ -41,7 +39,7 @@ module.exports =function(){
|
||||
|
||||
//create server with corresponding CA
|
||||
}else{
|
||||
|
||||
|
||||
asyncTaskMgr.addTask(hostname ,userCB,function(cb){
|
||||
createServer(cb);
|
||||
});
|
||||
@@ -60,7 +58,7 @@ module.exports =function(){
|
||||
,function(callback){
|
||||
|
||||
certMgr.getCertificate(hostname,function(err,keyContent,crtContent){
|
||||
var server = createHttpsServer(port,keyContent,crtContent);
|
||||
var server = createHttpsServer(port,keyContent,crtContent,userRequesthandler);
|
||||
self.serverList[hostname] = {
|
||||
port : port,
|
||||
server : server,
|
||||
@@ -96,11 +94,11 @@ module.exports =function(){
|
||||
},DEFAULT_RELEASE_TIME);
|
||||
}
|
||||
|
||||
function createHttpsServer(port,keyContent,crtContent){
|
||||
function createHttpsServer(port,keyContent,crtContent,userRequesthandler){
|
||||
return https.createServer({
|
||||
key : keyContent,
|
||||
cert: crtContent
|
||||
},requestHandler.userRequestHandler).listen(port);
|
||||
},userRequesthandler).listen(port);
|
||||
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user