mirror of
https://github.com/coderaiser/cloudcmd.git
synced 2026-01-23 02:35:49 +00:00
feature(ponse) add from npm
This commit is contained in:
coderaiser
parent
bf825d6bf9
commit
8e94b38103
7 changed files with 17 additions and 361 deletions
|
|
@ -13,10 +13,12 @@
|
|||
minify = require(DIR_SERVER + 'minify'),
|
||||
rest = require(DIR_SERVER + 'rest'),
|
||||
route = require(DIR_SERVER + 'route'),
|
||||
ponse = require(DIR_SERVER + 'ponse'),
|
||||
tryRequire = require(DIR_SERVER + 'tryRequire'),
|
||||
|
||||
join = tryRequire('join-io', {log: true, exit: true}),
|
||||
tryRequire = require(DIR_SERVER + 'tryRequire'),
|
||||
tryOptions = {log: true, exit: true},
|
||||
|
||||
join = tryRequire('join-io', tryOptions),
|
||||
ponse = tryRequire('ponse', tryOptions),
|
||||
|
||||
WIN = process.platform === 'WIN32',
|
||||
terminal = !WIN ? require(DIR_SERVER + 'terminal') : function() {},
|
||||
|
|
|
|||
|
|
@ -16,10 +16,12 @@
|
|||
Util = require(DIR_LIB + 'util'),
|
||||
CloudFunc = require(DIR_LIB + 'cloudfunc'),
|
||||
|
||||
ponse = require(DIR_SERVER + 'ponse'),
|
||||
tryRequire = require(DIR_SERVER + 'tryRequire'),
|
||||
|
||||
pipe = tryRequire('pipe-io', {log: true, exit: true}),
|
||||
tryRequire = require(DIR_SERVER + 'tryRequire'),
|
||||
tryOptions = {log: true, exit: true},
|
||||
|
||||
pipe = tryRequire('pipe-io', tryOptions),
|
||||
ponse = tryRequire('ponse', tryOptions),
|
||||
|
||||
apiURL = CloudFunc.apiURL,
|
||||
|
||||
|
|
|
|||
|
|
@ -1,350 +0,0 @@
|
|||
(function() {
|
||||
'use strict';
|
||||
|
||||
var fs = require('fs'),
|
||||
zlib = require('zlib'),
|
||||
url = require('url'),
|
||||
path = require('path'),
|
||||
querystring = require('querystring'),
|
||||
|
||||
DIR_JSON = __dirname + '/../../json/',
|
||||
|
||||
Util = require('../util'),
|
||||
files = require('./files'),
|
||||
ext = require(DIR_JSON + 'ext'),
|
||||
|
||||
OK = 200,
|
||||
RANGE = 206,
|
||||
MOVED_PERMANENTLY = 301,
|
||||
FILE_NOT_FOUND = 404;
|
||||
|
||||
exports.redirect = redirect;
|
||||
|
||||
exports.send = send;
|
||||
exports.sendError = sendError;
|
||||
exports.sendFile = sendFile;
|
||||
|
||||
exports.isGZIP = isGZIP;
|
||||
|
||||
exports.getPathName = getPathName;
|
||||
exports.getQuery = getQuery;
|
||||
|
||||
exports.setHeader = setHeader;
|
||||
|
||||
exports.static = function(dir, options) {
|
||||
return getStatic.bind(null, dir, options);
|
||||
};
|
||||
|
||||
/* Функция высылает ответ серверу
|
||||
* @param data
|
||||
* @param params
|
||||
* @param notLog
|
||||
*/
|
||||
function send(data, params, notLog) {
|
||||
var isGzip, head,
|
||||
p = params;
|
||||
|
||||
checkParams(params);
|
||||
|
||||
isGzip = p.gzip && isGZIP(p.request);
|
||||
|
||||
head = generateHeaders({
|
||||
name : p.name,
|
||||
cache : p.cache,
|
||||
gzip : isGzip,
|
||||
query : p.query
|
||||
});
|
||||
|
||||
fillHeader(head, p.response);
|
||||
|
||||
if (!notLog)
|
||||
Util.log(data);
|
||||
|
||||
/* если браузер поддерживает gzip-сжатие - сжимаем данные*/
|
||||
Util.exec.if(!isGzip,
|
||||
function() {
|
||||
if (!p.data)
|
||||
p.data = data;
|
||||
|
||||
p.response.statusCode = p.status || OK;
|
||||
p.response.end(p.data);
|
||||
},
|
||||
|
||||
function(callback) {
|
||||
zlib.gzip(data, function(error, data) {
|
||||
if (!error)
|
||||
p.data = data;
|
||||
else {
|
||||
p.status = FILE_NOT_FOUND;
|
||||
p.data = error.message;
|
||||
}
|
||||
|
||||
callback();
|
||||
});
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* Функция создаёт заголовки файлов
|
||||
* в зависимости от расширения файла
|
||||
* перед отправкой их клиенту
|
||||
* @param pParams
|
||||
* name - имя файла
|
||||
* gzip - данные сжаты gzip'ом
|
||||
* query
|
||||
* https://developers.google.com/speed/docs/best-practices/caching?hl=ru#LeverageProxyCaching
|
||||
*/
|
||||
function generateHeaders(params) {
|
||||
var header, p, extension, type, encoding, isContain, cmp,
|
||||
maxAge = 31337 * 21;
|
||||
|
||||
if (params.name) {
|
||||
p = params,
|
||||
extension = Util.getExt(p.name),
|
||||
type = ext[extension] || 'text/plain',
|
||||
encoding = '';
|
||||
|
||||
isContain = /img|image|audio/.test(type);
|
||||
if (!isContain)
|
||||
encoding = '; charset=UTF-8';
|
||||
|
||||
isContain = /download/.test(p.query);
|
||||
if (isContain)
|
||||
type = 'application/octet-stream';
|
||||
|
||||
header = {
|
||||
'Access-Control-Allow-Origin' : '*',
|
||||
'Content-Type' : type + encoding,
|
||||
'Vary' : 'Accept-Encoding',
|
||||
'Accept-Ranges' : 'bytes'
|
||||
};
|
||||
|
||||
if (p.time)
|
||||
Util.copyObj(header, {
|
||||
'Last-Modified' : p.time
|
||||
});
|
||||
|
||||
if (p.range)
|
||||
Util.copyObj(header, {
|
||||
'Content-Range' : 'bytes ' + p.range.start +
|
||||
'-' + p.range.end +
|
||||
'/' + p.range.sizeTotal,
|
||||
|
||||
'Content-Length': p.range.size
|
||||
});
|
||||
else if (p.length)
|
||||
Util.copyObj(header, {
|
||||
'Content-Length': p.length
|
||||
});
|
||||
|
||||
cmp = Util.strCmp(extension, '.appcache');
|
||||
if (!p.cache || cmp)
|
||||
maxAge = 0;
|
||||
|
||||
header['Cache-Control'] = 'max-age=' + maxAge;
|
||||
|
||||
if (p.gzip)
|
||||
header['Content-Encoding'] = 'gzip';
|
||||
}
|
||||
|
||||
return header;
|
||||
}
|
||||
|
||||
function setHeader(params) {
|
||||
var header, gzip,
|
||||
p = params;
|
||||
|
||||
checkParams(params);
|
||||
|
||||
gzip = isGZIP(p.request) && p.gzip;
|
||||
|
||||
header = generateHeaders({
|
||||
name : p.name,
|
||||
time : p.time,
|
||||
range : p.range,
|
||||
length : p.length,
|
||||
cache : p.cache,
|
||||
gzip : gzip,
|
||||
query : getQuery(p.request)
|
||||
});
|
||||
|
||||
fillHeader(header, p.response);
|
||||
p.response.statusCode = p.status || OK;
|
||||
}
|
||||
|
||||
function fillHeader(header, response) {
|
||||
var isObject = Util.type.object(header),
|
||||
isSent = response.headersSent;
|
||||
|
||||
if (!isSent && isObject)
|
||||
Object.keys(header).forEach(function(name) {
|
||||
response.setHeader(name, header[name]);
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* send file to client thru pipe
|
||||
* and gzip it if client support
|
||||
*
|
||||
*/
|
||||
function sendFile(params) {
|
||||
var p = params;
|
||||
|
||||
checkParams(params);
|
||||
|
||||
fs.lstat(p.name, function(error, stat) {
|
||||
var time, length, range, isGzip,
|
||||
options = {};
|
||||
|
||||
if (error) {
|
||||
sendError(error, params);
|
||||
} else {
|
||||
isGzip = isGZIP(p.request) && p.gzip;
|
||||
time = stat.mtime,
|
||||
length = stat.size,
|
||||
range = getRange(p.request, length);
|
||||
|
||||
if (range)
|
||||
Util.copyObj(p, {
|
||||
range : range,
|
||||
status : RANGE
|
||||
});
|
||||
|
||||
Util.copyObj(p, {
|
||||
time : time
|
||||
});
|
||||
|
||||
if (!isGzip)
|
||||
p.length = length;
|
||||
|
||||
setHeader(params);
|
||||
|
||||
options = {
|
||||
gzip : isGzip,
|
||||
range : range
|
||||
};
|
||||
|
||||
files.pipe(p.name, p.response, options, function(error) {
|
||||
if (error)
|
||||
sendError(error, params);
|
||||
});
|
||||
}
|
||||
});
|
||||
}
|
||||
|
||||
/**
|
||||
* send error response
|
||||
*/
|
||||
function sendError(error, params) {
|
||||
var data;
|
||||
|
||||
checkParams(params);
|
||||
|
||||
params.status = FILE_NOT_FOUND;
|
||||
data = error.message || '' + error;
|
||||
|
||||
send(data, params);
|
||||
}
|
||||
|
||||
function checkParams(params) {
|
||||
var p = params;
|
||||
|
||||
Util.check([params], ['params'])
|
||||
.check([p.name, p.request, p.response], ['name', 'requst', 'response']);
|
||||
}
|
||||
|
||||
function getQuery(req) {
|
||||
var query, parsed;
|
||||
|
||||
Util.check([req], ['req']);
|
||||
|
||||
parsed = url.parse(req.url);
|
||||
query = parsed.query;
|
||||
|
||||
return query;
|
||||
}
|
||||
|
||||
function getPathName(req) {
|
||||
var pathname, parsed;
|
||||
|
||||
Util.check([req], ['req']);
|
||||
|
||||
parsed = url.parse(req.url);
|
||||
pathname = parsed.pathname;
|
||||
/* supporting of Russian language in directory names */
|
||||
pathname = querystring.unescape(pathname);
|
||||
|
||||
return pathname;
|
||||
}
|
||||
|
||||
function getRange(req, sizeTotal) {
|
||||
var range, start, end, size, parts,
|
||||
rangeStr = req.headers.range;
|
||||
|
||||
if (rangeStr) {
|
||||
parts = rangeStr.replace(/bytes=/, '').split('-');
|
||||
start = parts[0];
|
||||
end = parts[1] || sizeTotal - 1;
|
||||
size = (end - start) + 1;
|
||||
|
||||
range = {
|
||||
start : start - 0,
|
||||
end : end - 0,
|
||||
size : size,
|
||||
sizeTotal : sizeTotal
|
||||
};
|
||||
}
|
||||
|
||||
return range;
|
||||
}
|
||||
|
||||
function isGZIP(req) {
|
||||
var enc, is;
|
||||
|
||||
if (req) {
|
||||
enc = req.headers['accept-encoding'] || '';
|
||||
is = enc.match(/\bgzip\b/);
|
||||
}
|
||||
|
||||
return is;
|
||||
}
|
||||
|
||||
/**
|
||||
* redirect to another URL
|
||||
*/
|
||||
function redirect(url, response) {
|
||||
var header = {
|
||||
'Location': url
|
||||
};
|
||||
|
||||
Util.check([url, response], ['url', 'response']);
|
||||
|
||||
fillHeader(header, response);
|
||||
response.statusCode = MOVED_PERMANENTLY;
|
||||
response.end();
|
||||
}
|
||||
|
||||
function getStatic(dir, options, req, res) {
|
||||
var cache,
|
||||
o = options || {},
|
||||
name = getPathName(req);
|
||||
|
||||
name = path.join(dir, name);
|
||||
|
||||
if (Util.type.function(o.cache))
|
||||
cache = o.cache();
|
||||
else if (o.cache !== undefined)
|
||||
cache = o.cache;
|
||||
else
|
||||
cache = true;
|
||||
|
||||
sendFile({
|
||||
name : name,
|
||||
cache : cache,
|
||||
gzip : true,
|
||||
request : req,
|
||||
response : res
|
||||
});
|
||||
}
|
||||
|
||||
})();
|
||||
|
|
@ -23,13 +23,14 @@
|
|||
|
||||
github = require(DIR + 'github'),
|
||||
packer = require(DIR + 'packer'),
|
||||
ponse = require(DIR + 'ponse'),
|
||||
|
||||
tryRequire = require('./tryRequire'),
|
||||
tryOptions = {log: true, exit: true},
|
||||
|
||||
mellow = tryRequire('mellow', tryOptions),
|
||||
flop = tryRequire('flop', tryOptions),
|
||||
pipe = tryRequire('pipe-io', tryOptions),
|
||||
ponse = tryRequire('ponse', tryOptions),
|
||||
|
||||
isWin32 = process.platform === 'win32',
|
||||
|
||||
|
|
|
|||
|
|
@ -14,8 +14,7 @@
|
|||
|
||||
mellow = tryRequire('mellow', tryOptions),
|
||||
pipe = tryRequire('pipe-io', tryOptions),
|
||||
|
||||
ponse = require(DIR + 'ponse'),
|
||||
ponse = tryRequire('ponse', tryOptions),
|
||||
|
||||
marked = tryRequire('marked');
|
||||
|
||||
|
|
|
|||
|
|
@ -10,10 +10,11 @@
|
|||
fs = require('fs'),
|
||||
|
||||
tryRequire = require(DIR_SERVER + 'tryRequire'),
|
||||
tryOptions = {log: true, exit: true},
|
||||
|
||||
mellow = tryRequire('mellow', {log: true, exit: true}),
|
||||
mellow = tryRequire('mellow', tryOptions),
|
||||
ponse = tryRequire('ponse', tryOptions),
|
||||
|
||||
ponse = require(DIR_SERVER + 'ponse'),
|
||||
files = require(DIR_SERVER + 'files'),
|
||||
minify = require(DIR_SERVER + 'minify'),
|
||||
config = require(DIR_SERVER + 'config'),
|
||||
|
|
|
|||
|
|
@ -38,6 +38,7 @@
|
|||
"minify": "~1.3.0",
|
||||
"nicki": "~1.2.0",
|
||||
"pipe-io": "~1.1.1",
|
||||
"ponse": "~1.2.8",
|
||||
"socket.io": "~1.2.0",
|
||||
"tar": "~1.0.1"
|
||||
},
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue