cloudcmd/server.js
2012-07-24 14:45:12 -04:00

701 lines
No EOL
27 KiB
JavaScript
Raw Blame History

This file contains ambiguous Unicode characters

This file contains Unicode characters that might be confused with other characters. If you think that this is intentional, you can safely ignore this warning. Use the Escape button to reveal them.

"use strict";
/* Обьект содержащий все функции и переменные
* серверной части Cloud Commander'а
*/
var CloudServer = {
/* main Cloud Commander configuration
* readed from config.json if it's
* exist
*/
Config : {
cache : {allowed : true},
minification : {
js : false,
css : false,
html : true,
img : false
},
server : true,
logs : false,
port : 31337,
ip : '127.0.0.1'
},
/* функция, которая генерирует заголовки
* файлов, отправляемые сервером клиенту
*/
generateHeaders : function () {},
/* функция высылает
* данные клиенту
*/
sendResponse : function () {},
/* Обьект для работы с кэшем */
Cashe : {},
/* Обьект через который
* выполняеться сжатие
* скриптов и стилей
*/
Minify : {},
/* Асоциативный масив обьектов для
* работы с ответами сервера
* высылаемыми на запрос о файле и
* хранащий информацию в виде
* Responses[name]=responce;
*/
Responses : {},
/*
* Асоциативный масив статусов
* ответов сервера
* высылаемыми на запрос о файле и
* хранащий информацию в виде
* Statuses[name] = 404;
*/
Statuses : {},
/* ПЕРЕМЕННЫЕ
* Поддержка браузером JS */
NoJS : true,
/* Поддержка gzip-сжатия браузером */
Gzip : undefined,
/* КОНСТАНТЫ */
INDEX : 'index.html',
LIBDIR : './lib',
LIBDIRSERVER : './lib/server'
};
var DirPath = '/';
/* модуль для работы с путями*/
var Path = require('path');
var Fs = require('fs'); /* модуль для работы с файловой системой*/
var Querystring = require('querystring');
var Zlib;
/* node v0.4 not contains zlib
*/
try {
Zlib = require('zlib'); /* модуль для сжатия данных gzip-ом*/
} catch (error) {
console.log('to use gzip-commpression' +
'you should use newer node version\n');
}
/* добавляем модуль с функциями */
var CloudFunc;
try {
CloudFunc = require(CloudServer.LIBDIR +
'/cloudfunc');
CloudServer.Cache = require(CloudServer.LIBDIRSERVER +
'/object').Cache;
CloudServer.Minify = require(CloudServer.LIBDIRSERVER +
'/object').Minify;
}catch(pError){
console.log('could not found one of Cloud Commander SS files');
console.log(pError);
}
/* конструктор*/
CloudServer.init=(function(){
/* Determining server.js directory
* and chang current process directory
* (usually /) to it.
* argv[1] - is always script name
*/
var lServerDir = Path.dirname(process.argv[1]);
var lProcessDir = process.cwd();
console.log('current dir: ' + lProcessDir);
console.log('server dir: ' + lServerDir);
if(lProcessDir !== lServerDir)
process.chdir(lServerDir);
try{
console.log('reading configuretion file config.json...');
this.Config = require('./config');
console.log('config.json readed');
/* if command line parameter testing resolved
* setting config to testing, so server
* not created, just init and
* all logs writed to screen
*/
if (process.argv[2] === 'test') {
console.log(process.argv);
this.Config.server = false;
this.Config.logs = false;
}
if (this.Config.logs) {
console.log('log param setted up in config.json\n' +
'from now all logs will be writed to log.txt');
this.writeLogsToFile();
}
} catch (pError) {
console.log('warning: configuretion file config.json not found...\n' +
'using default values...\n' +
JSON.stringify(CloudServer.Config));
}
/* Переменная в которой храниться кэш*/
this.Cache.setAllowed(CloudServer.Config.cache.allowed);
/* Change default parameters of
* js/css/html minification
*/
this.Minify.setAllowed(CloudServer.Config.minification);
/* Если нужно минимизируем скрипты */
this.Minify.doit();
});
/* создаём сервер на порту 31337 */
CloudServer.start = function () {
this.init();
this.Port = process.env.PORT || /* c9 */
process.env.app_port || /* nodester */
process.env.VCAP_APP_PORT || /* cloudfoundry */
CloudServer.Config.port;
this.IP = process.env.IP || /* c9 */
CloudServer.Config.ip;
/* if Cloud Server started on jitsu */
if(process.env.HOME &&
!process.env.HOME.indexOf('/opt/haibu')) {
this.IP = '0.0.0.0';
}
/* server mode or testing mode */
if (!process.argv[2] && this.Config.server) {
var http = require('http');
try {
http.createServer(this._controller).listen(
this.Port, this.IP);
console.log('Cloud Commander server running at http://' +
this.IP +
':' +
this.Port);
}catch(pError){
console.log('Cloud Commander server could not started');
console.log(pError);
}
}else{
console.log('Cloud Commander testing mode');
}
};
/* Функция создаёт заголовки файлов
* в зависимости от расширения файла
* перед отправкой их клиенту
* @pName - имя файла
* @pGzip - данные сжаты gzip'ом
*/
CloudServer.generateHeaders = function(pName, pGzip){
var lType='';
/* высылаем заголовок в зависимости от типа файла */
/* если расширение у файла css -
* загружаем стили
*/
if(CloudFunc.checkExtension(pName,'css'))
lType='text/css';
/* загружаем js */
else if(CloudFunc.checkExtension(pName,'js'))
lType='text/javascript';
/* загружаем картинки*/
else if(CloudFunc.checkExtension(pName,'png'))
lType='image/png';
/* загружаем json*/
else if(CloudFunc.checkExtension(pName,'json'))
lType='application/json';
else if(CloudFunc.checkExtension(pName,'html'))
lType='text/html';
else if(CloudFunc.checkExtension(pName,'woff'))
lType='font/woff';
else if(CloudFunc.checkExtension(pName,'appcache'))
lType='text/cache-manifest';
/* если это неизвестный тип файла -
* высылаем его просто как текст
*/
else lType='text/plain';
return {
/* if type of file any, but img -
* then we shoud specify charset
*/
'Content-Type': lType + (lType.indexOf('img')<0?'; charset=UTF-8':''),
'cache-control': 'max-age='+(31337*21),
'last-modified': new Date().toString(),
'content-encoding': pGzip?'gzip':'',
/* https://developers.google.com/speed/docs/best-practices
/caching?hl=ru#LeverageProxyCaching */
'Vary': 'Accept-Encoding'
};
};
/*
* Главная функция, через которую проихсодит
* взаимодействие, обмен данными с клиентом
* @req - запрос клиента (Request)
* @res - ответ сервера (Response)
*/
CloudServer._controller=function(pReq, pRes)
{
/* Читаем содержимое папки,
переданное в url
*/
var url = require("url");
var pathname = url.parse(pReq.url).pathname;
/* added supporting of Russian language in directory names */
pathname = Querystring.unescape(pathname);
console.log('pathname: ' + pathname);
/* получаем поддерживаемые браузером кодировки*/
var lAcceptEncoding = pReq.headers['accept-encoding'];
/* запоминаем поддерживает ли браузер
* gzip-сжатие при каждом обращении к серверу
* и доступен ли нам модуль zlib
*/
if (lAcceptEncoding &&
lAcceptEncoding.match(/\bgzip\b/) &&
Zlib){
CloudServer.Gzip=true;
}
/* путь в ссылке, который говорит
* что js отключен
*/
var lNoJS_s=CloudFunc.NOJS;
var lFS_s=CloudFunc.FS;
if(pathname!=='/favicon.ico')
{
console.log("request for " + pathname + " received...");
var lName;
/* если в пути нет информации ни о ФС,
* ни об отсутствии js,
* ни о том, что это корневой
* каталог - загружаем файлы проэкта
*/
if(pathname.indexOf(lFS_s)<0 &&
pathname.indexOf(lNoJS_s)<0 &&
pathname!=='/'){
/* если имена файлов проекта - загружаем их*/
/* убираем слеш и читаем файл с текущец директории*/
/* добавляем текующий каталог к пути */
lName='.'+pathname;
console.log('reading '+lName);
/* сохраняем указатель на response и имя */
CloudServer.Responses[lName]=pRes;
/* saving status OK for current file */
CloudServer.Statuses[lName] = 200;
/* Берём значение из кэша
* сжатый файл - если gzip-поддерживаеться браузером
* не сжатый - в обратном случае
*/
var lFileData=CloudServer.Cache.get(
CloudServer.Gzip?(lName+'_gzip'):lName);
console.log(Path.basename(lName));
var lMinify=CloudServer.Minify;
/* object thet contains information
* about the source of file data
*/
var lFromCache_o={'cache': true};
/* if cache is empty and Cache allowed and Minify_allowed
* and in Minifys cache is files, so save it to
* CloudServer cache
*/
if(!lFileData &&
lMinify._allowed){
console.log('trying to read data from Minify.Cache');
lFromCache_o.cache=false;
lFileData = CloudServer.Minify.Cache[
Path.basename(lName)];
}
var lReadFileFunc_f=CloudServer.getReadFileFunc(lName);
/* если там что-то есть передаём данные в функцию
* readFile
*/
if(lFileData){
/* if file readed not from cache -
* he readed from minified cache
*/
if(lFromCache_o.cache===false)
lFromCache_o.minify=true;
else
lFromCache_o.minify=false;
console.log(lName + ' readed from cache');
/* передаём данные с кэша,
* если gzip включен - сжатые
* в обратном случае - несжатые
*/
lReadFileFunc_f(undefined,lFileData,lFromCache_o);
}
else Fs.readFile(lName,lReadFileFunc_f);
}else{/* если мы имеем дело с файловой системой*/
/* если путь не начинаеться с no-js - значит
* js включен
*/
/* убираем пометку cloud, без которой c9.io
* не работает поскольку путь из двух слешей
* (/fs/no-js/) - очень короткий, нужно
* длиннее
*/
if(pathname.indexOf(lNoJS_s)!==lFS_s.length && pathname!=='/'){
CloudServer.NoJS=false;
}else pathname=pathname.replace(lNoJS_s,'');
/* убираем индекс файловой системы */
if(pathname.indexOf(lFS_s)===0){
pathname=pathname.replace(lFS_s,'');
/* если посетитель только зашел на сайт
* no-js будет пустым, как и fs
*/
/* если в пути нету fs - посетитель только зашел на сайт
* загружаем его полностью.
*/
}else CloudServer.NoJS=true;
/* если в итоге путь пустой
* делаем его корневым
*/
if (pathname==='')
pathname = '/';
DirPath = pathname;
CloudServer.Responses[DirPath] = pRes;
CloudServer.Statuses[DirPath] = 200;
/* Проверяем с папкой ли мы имеем дело */
/* читаем сновные данные о файле */
var lStat;
try{
lStat=Fs.statSync(DirPath);
}catch(error){
console.log(error);
CloudServer.Statuses[DirPath] = 404;
CloudServer.sendResponse('OK',error.toString(),DirPath);
}
/* если это каталог -
* читаем его содержимое
*/
try{
/* если установлено сжатие
* меняем название html-файла и
* загружаем сжатый html-файл в дальнейшем
*/
CloudServer.INDEX=(CloudServer.Minify._allowed.html?
'.' + CloudServer.Minify.MinFolder + 'index.min.html'
:CloudServer.INDEX);
/*
* сохраним указатель на response
* и на статус ответа
*/
CloudServer.Responses[CloudServer.INDEX]=pRes;
CloudServer.Statuses[CloudServer.INDEX] = 200;
if(lStat.isDirectory()){
Fs.readdir(DirPath,CloudServer._readDir);
}
/* отдаём файл */
else if(lStat.isFile()){
Fs.readFile(DirPath,CloudServer.getReadFileFunc(DirPath));
console.log('reading file: '+DirPath);
}
}catch(error){console.log(error);}
}
}
};
/* Функция читает ссылку или выводит информацию об ошибке*/
CloudServer._readDir=function (pError, pFiles)
{
if(!pError)
{
/* данные о файлах в формате JSON*/
var lJSON=[];
var lJSONFile={};
/* Если мы не в корне добавляем слеш к будующим ссылкам */
if(DirPath!=='/')
{
DirPath+='/';
}
pFiles=pFiles.sort();
lJSON[0]={path:DirPath,size:'dir'};
var fReturnFalse=function returnFalse(){return false;};
for(var i=0;i<pFiles.length;i++)
{
/* Получаем информацию о файле*/
var lStats;
try{
lStats=Fs.statSync(DirPath+pFiles[i]);
}catch(err){
/*
console.log(err);
*/
lStats={
'mode':0,
'size':0,
'isDirectory':fReturnFalse
};
}
/*
*Переводим права доступа в 8-ричную систему
*/
var lMode=(lStats.mode-0).toString(8);
/* Если папка - выводим пиктограмму папки */
if(lStats.isDirectory())
{
lJSONFile={'name':pFiles[i],
'size':'dir',
'uid':lStats.uid,
'mode':lMode};
lJSON[i+1]=lJSONFile;
}
/* В противоположном случае - файла */
else
{
lJSONFile={'name':pFiles[i],
'uid':lStats.uid,
'size':lStats.size,
'mode':lMode};
lJSON[i+1]=lJSONFile;
}
}
/* заголовок ответа сервера */
var lHeader;
var lList;
/* если js недоступен */
/* если javascript отключен вылылаем html-код
* и прописываем соответствующие заголовки
*/
if(CloudServer.NoJS){
var lPanel=CloudFunc.buildFromJSON(lJSON);
lList='<ul id=left class=panel>';
lList+=lPanel;
lList+='</ul>';
lList+='<ul id=right class="panel hidden">';
lList+=lPanel;
lList+='</ul>';
try{
var lIndex;
/* пробуем достать данные из кэша
* с жатием или без, взависимости
* от настроек
*/
var lFileData=CloudServer.Cache.get(CloudServer.INDEX);
/* если их нет там - вычитываем из файла*/
if(!lFileData){
lIndex=Fs.readFileSync(CloudServer.INDEX);
/* и сохраняем в кэш */
CloudServer.Cache.set(CloudServer.INDEX,lIndex);
}else lIndex=lFileData;
/* если выбрана опция минифизировать скрпиты
* меняем в index.html обычный client.js на
* минифицированый
*/
lIndex=lIndex.toString();
/* if scripts shoud be minified and
* minification proceed sucessfully
* we include minified version of
* clien.js to index.html
*/
lIndex = CloudServer.Minify._allowed.css?
lIndex.replace('<link rel=stylesheet href="/css/reset.css">','')
.replace('/css/style.css',CloudServer.Minify.MinFolder + 'all.min.css')
:lIndex;
lIndex = CloudServer.Minify._allowed.js?lIndex.replace('client.js',
CloudServer.Minify.MinFolder +
'client.min.js')
:lIndex;
lIndex=lIndex.toString().replace('<div id=fm class=no-js>',
'<div id=fm class=no-js>'+lList);
/* меняем title */
lIndex=lIndex.replace('<title>Cloud Commander</title>',
'<title>'+CloudFunc.setTitle()+'</title>');
/* отображаем панель быстрых клавишь */
lList=lIndex;
/* если браузер поддерживает gzip-сжатие*/
lHeader=CloudServer.generateHeaders('text/html',CloudServer.Gzip);
}catch(error){console.log(error);}
}else{
/* в обычном режиме(когда js включен
* высылаем json-структуру файлов
* с соответствующими заголовками
*/
lList=JSON.stringify(lJSON);
lHeader=CloudServer.generateHeaders('application/json',CloudServer.Gzip);
}
/* если браузер поддерживает gzip-сжатие - сжимаем данные*/
if(CloudServer.Gzip){
Zlib.gzip(lList,CloudServer.getGzipDataFunc(lHeader,CloudServer.INDEX));
}
/* если не поддерживаеться - отсылаем данные без сжатия*/
else
CloudServer.sendResponse(lHeader,lList,CloudServer.INDEX);
}
else
{
console.log(pError);
CloudServer.sendResponse('OK',pError.toString(),
DirPath);
}
};
/* Функция генерирует функцию считывания файла
* таким образом, что бы у нас было
* имя считываемого файла
* @pName - полное имя файла
*/
CloudServer.getReadFileFunc = function(pName){
/*
* @pError - ошибка
* @pData - данные
* @pFromCache_o - прочитано с файла,
* или из одного из кешей
* Пример {cache: false, minify: true}
*/
var lReadFile=function(pError, pData, pFromCache_o){
if (!pError){
console.log('file ' + pName + ' readed');
/* берём из кэша данные файла
* если их нет в кэше -
* сохраняем
*/
if(pFromCache_o && !pFromCache_o.cache && CloudServer.Cache.isAllowed)
CloudServer.Cache.set(pName,pData);
/* если кэш есть
* сохраняем его в переменную
* которая до этого будет пустая
* по скольку мы будем вызывать этот метод
* сами, ведь файл уже вычитан
*/
var lHeader=CloudServer.generateHeaders(pName,CloudServer.Gzip);
/* если браузер поддерживает gzip-сжатие - сжимаем данные*/
if( CloudServer.Gzip && !(pFromCache_o && pFromCache_o.cache) ){
/* сжимаем содержимое */
Zlib.gzip(pData,CloudServer.getGzipDataFunc(lHeader,pName));
}
else{
/* высылаем несжатые данные */
CloudServer.sendResponse(lHeader,pData,pName);
}
}
else
{
console.log(pError.path);
if(pError.path!=='passwd.json')
{
console.log(pError);
/* sending page not found */
CloudServer.Statuses[pName] = 404;
CloudServer.sendResponse('file not found',pError.toString(),pName);
}else{
CloudServer.sendResponse('OK','passwd.json');
}
}
};
return lReadFile;
};
/* Функция получает сжатые данные
* @pHeader - заголовок файла
*/
CloudServer.getGzipDataFunc=function(pHeader,pName){
return function(error,pResult){
if(!error){
/* отправляем сжатые данные
* вместе с заголовком
*/
/* если установлена работа с кэшем
* сохраняем сжатые данные
*/
if(CloudServer.Cache.isAllowed){
/* устанавливаем кєш */
console.log(pName+' gziped');
CloudServer.Cache.set(pName+'_gzip',pResult);
}
CloudServer.sendResponse(pHeader,pResult,pName);
}
else{
console.log(error);
CloudServer.sendResponse(pHeader,error);
}
};
};
/* Функция высылает ответ серверу
* @pHead - заголовок
* @pData - данные
* @pName - имя отсылаемого файла
*/
CloudServer.sendResponse = function(pHead, pData,pName){
/* если у нас есть указатель на responce
* для соответствующего файла -
* высылаем его
*/
var lResponse = CloudServer.Responses[pName];
var lStatus = CloudServer.Statuses[pName];
if(lResponse){
lResponse.writeHead(
lStatus,
pHead);
lResponse.end(pData);
console.log(pName+' sended');
}
};
/* function sets stdout to file log.txt */
CloudServer.writeLogsToFile = function(){
var stdo = require('fs').createWriteStream('./log.txt');
process.stdout.write = (function(write) {
return function(string, encoding, fd) {
stdo.write(string);
};
})(process.stdout.write);
};
CloudServer.start();