-/*\r
- * \90Ý\92è\r
+/*\r
+ * 設定\r
*/\r
-$max_room_number = 1; //\8dÅ\91å\83\8b\81[\83\80\90\94\r
-$log_directory = "log"; //\83\8d\83O\83t\83@\83C\83\8b\82ð\92u\82\83t\83H\83\8b\83_\81[\r
-$log_file_name = "logfile%d.txt"; //\83\8d\83O\83t\83@\83C\83\8b\96¼(%d\82Í\82»\82Ì\82Ü\82Ü\82É\82µ\82Ä\82¨\82\82±\82Æ)\r
-$splited_log_file_name = "logfile%d_%s.txt" //\95ª\8a\84\8cã\82Ì\83t\83@\83C\83\8b\96¼(%d\82Æ%s\82Í\82»\82Ì\82Ü\82Ü\82É\82µ\82Ä\82¨\82\82±\82Æ)\r
-$spilt_size = 1024 * 512; //\95ª\8a\84\82·\82é\83T\83C\83Y\r
-$block_message = "failed to send your message."; //\83u\83\8d\83b\83N\8e\9e\82Ì\83\81\83b\83Z\81[\83W\r
-$ip_ban_list_file_name = "ipbanlist.txt"; //\83A\83N\83Z\83X\82ð\8bÖ\8e~\82·\82éIP\82ª\8bL\98^\82³\82ê\82Ä\82¢\82é\83t\83@\83C\83\8b\r
-$port = process.env.port || 3000; //\83|\81[\83g\r
-$username = "admin"; //\8aÇ\97\9d\8eÒ\97p\82Ì\83y\81[\83W\82É\83A\83N\83Z\83X\82Å\82«\82é\83\86\81[\83U\96¼\r
-$password = "admin"; //\8aÇ\97\9d\8eÒ\97p\82Ì\83y\81[\83W\82É\83A\83N\83Z\83X\82·\82é\82Ì\82É\95K\97v\82È\83p\83X\83\8f\81[\83h\r
-$pastlogfile_pattern = "logfile%d(_+.*)?\.txt"; //\89ß\8b\8e\83\8d\83O\82Æ\94»\92è\82·\82é\90³\8bK\95\\8c»\r
-$logfile_pattern = "logfile[0-9]+(_*.*)?\.txt" //\89ß\8b\8e\83\8d\83O\82Æ\94»\92è\82·\82é\90³\8bK\95\\8c»\r
-$token_length = 16; //\83g\81[\83N\83\93\82Ì\92·\82³\r
-$redisHost = "localhost"; //redis\83T\81[\83o\82Ì\83A\83h\83\8c\83X\r
-$redisPort = 6379; //redis\83T\81[\83o\82Ì\83|\81[\83g\r
-$redisPassword = ""; //redis\83T\81[\83o\82Ì\83p\83X\83\8f\81[\83h\r
+$max_room_number = 3; //最大ルーム数\r
+$spilt_size = 1024 * 512; //分割するサイズ\r
+$reset_password_diff = 1000 * 60 * 60;\r
+$block_message = "メッセージの送信に失敗しました"; //ブロック時のメッセージ\r
+$not_match_password = "パスワードが一致しませんでした"; //パスワードが一致しない場合に表示されるメッセージ\r
+$password_setted_message = "パスワードを設定しました"; //パスワードが設定されたときに表示されるメッセージ\r
+$password_resetted_message = "パスワードをリセットしました"; //パスワードが再設定されたときに表示されるメッセージ\r
+$failed_set_password_message = "パスワードの設定に失敗しました"; //パスワードが再設定されたときに表示されるメッセージ\r
+$free_password1 = "最初に入室する人が自由にパスワードを設定できます"; //自由パスワードメッセージ１\r
+$free_password2 = "この部屋は使用されています。パスワードを入力してください"; //自由パスワードメッセージ２\r
+$fixed_password = "この部屋にはパスワードが設定されています"; //固定パスワードルーム\r
+$ip_ban_list_file_name = "ipbanlist.txt"; //アクセスを禁止するIPが記録されているファイル\r
+$port = process.env.port || 3000; //ポート\r
+$username = "admin"; //管理者用のページにアクセスできるユーザ名\r
+$password = "admin"; //管理者用のページにアクセスするのに必要なパスワード\r
+$token_length = 32; //トークンの長さ\r
+$redisHost = "localhost"; //redisサーバのアドレス\r
+$redisPort = 6379; //redisサーバのポート\r
+$redisPassword = ""; //redisサーバのパスワード\r
+$system_name = "system"; //システム発言を表す名前\r
+$log_directory = "log"; //ログファイルを置くフォルダー\r
+$log_file_name = "logfile%d.txt"; //ログファイル名(%dはそのままにしておくこと)\r
+$splited_log_file_name = "logfile%d_%s.txt" //分割後のファイル名(%dと%sはそのままにしておくこと)\r
+$pastlogfile_pattern = "logfile%d(_+.*)?\.txt"; //過去ログと判定する正規表現\r
+$logfile_pattern = "logfile[0-9]+(_*.*)?\.txt" //過去ログと判定する正規表現\r
+//パスワードを自由に設定できる部屋のリスト\r
+// rno 設定したい部屋番号\r
+// password パスワードを設定する。nullにすると利用者がパスワードの設定をすることができる\r
+//記述例：\r
+// new RoomInfomationCollection(\r
+// {rno:"1",password:"test"},\r
+// {rno:"2",password:null}\r
+// )\r
+$rooms = new RoomInfomationCollection(\r
+ {rno:"1",password:"test"},\r
+ {rno:"2",password:null}\r
+);\r
\r
/**\r
* Module dependencies.\r
var parseCookie = require("connect").utils.parseCookie;\r
\r
var RedisStore = require("connect-redis")(express);\r
-//var sessionStore = new (require('connect').session.MemoryStore)();\r
var sessionStore = new RedisStore({host:$redisHost,port:$redisPort,pass:$redisPassword});\r
\r
var async = require("async");\r
var room_number = 0;\r
if(typeof(req.query.rno) != "undefined")\r
room_number = req.query.rno;\r
- res.render("chat",{rno:room_number,token:auth_string});\r
+ var msg = "";\r
+ if($rooms.IsFixedPassword(room_number))\r
+ msg = $fixed_password;\r
+ else if($rooms.IsContains(room_number))\r
+ msg = $free_password2;\r
+ if($rooms.IsFirstAuth(room_number))\r
+ msg = $free_password1;\r
+ res.render("chat",{rno:room_number,token:auth_string,message:msg});\r
});\r
\r
app.all("/log/" + $logfile_pattern,express.basicAuth(function (user, pass) {\r
}\r
if(typeof(req.body.registor) != "undefined")\r
{\r
- updateIpBanList(req.body.newbanlist,function(){\r
+ ipbanlist.Update(req.body.newbanlist,function(){\r
renderAdmin(req,res);\r
});\r
}\r
+ if(typeof(req.body.updateroom) != "undefined")\r
+ {\r
+ CreateRoomsFromString(req.body.newroomlist);\r
+ renderAdmin(req,res);\r
+ }\r
});\r
\r
function renderAdmin(req,res)\r
{\r
var auth_string = getRandomString($token_length);\r
req.session.items = {token:auth_string};\r
+ var iplist = ipbanlist.GetText();\r
\r
fs.readdir($log_directory,function(err,list){\r
res.render("admin", {\r
files: list,\r
log_directory:$log_directory,\r
- ipbanlist:getTextFromIpBanlist(ipbanlist),\r
- token:auth_string\r
+ ipbanlist:iplist,\r
+ token:auth_string,\r
+ roomlist:$rooms.GetString()\r
});\r
});\r
}\r
});\r
}\r
\r
-function getTextFromIpBanlist(list)\r
-{\r
- var text = "";\r
- for(var key in ipbanlist)\r
- {\r
- if(ipbanlist[key] == "")\r
- text += key + "\r\n";\r
- else\r
- text += key + ":" + ipbanlist[key] + "\r\n";\r
- }\r
- return text;\r
-}\r
-\r
-function updateIpBanList(text,callfunc)\r
-{\r
- async.waterfall([\r
- function(callback){\r
- fs.open($ip_ban_list_file_name,"w",callback);\r
- },\r
- function(fd,callback){\r
- var buf = new Buffer(text);\r
- fs.write(fd,buf,0,Buffer.byteLength(text),null,function(){\r
- callback(null,fd);\r
- });\r
- },\r
- function(fd,callback){\r
- fs.close(fd,function(){\r
- getIpBanList(callfunc);\r
- });\r
- }\r
- ]);\r
-}\r
-\r
app.listen($port);\r
console.log("Express server listening on port %d in %s mode", app.address().port, app.settings.env);\r
\r
/*\r
- * \83T\81[\83o\81[\95\94\95ª\r
+ * サーバー部分\r
*/\r
\r
var io = require("socket.io").listen(app);\r
io.configure('production', function(){\r
- io.enable('browser client minification'); // minified \82³\82ê\82½\83N\83\89\83C\83A\83\93\83g\83t\83@\83C\83\8b\82ð\91\97\90M\82·\82é\r
- io.enable('browser client etag'); // \83o\81[\83W\83\87\83\93\82É\82æ\82Á\82Ä etag \82É\82æ\82é\83L\83\83\83b\83V\83\93\83O\82ð\97L\8cø\82É\82·\82é\r
- io.set('log level', 1); // \83\8d\83O\83\8c\83x\83\8b\82ð\90Ý\92è(\83f\83t\83H\83\8b\83g\82æ\82è\89º\82°\82Ä\82¢\82é)\r
+ io.enable('browser client minification'); // minified されたクライアントファイルを送信する\r
+ io.enable('browser client etag'); // バージョンによって etag によるキャッシングを有効にする\r
+ io.set('log level', 1); // ログレベルを設定(デフォルトより下げている)\r
});\r
var clients = new Array();\r
\r
-var ipbanlist = {};\r
+var ipbanlist = new IpBanCollecion();\r
\r
createLogDirectory();\r
\r
-getIpBanList();\r
-\r
for(var i = 0; i < $max_room_number; i++)\r
{\r
clients[i] =io\r
.authorization(ParseAuthorization)\r
.on("connection", function (socket) {\r
console.log("connected from %s",GetClientIPAdress(socket));\r
+ socket.json.emit("send roomlist",$rooms.GetKeys());\r
socket.on("get pastLogList", function (msg) {\r
ParseGetPastLogList(socket,msg);\r
});\r
socket.on("get pastLog", function (msg) {\r
ParseGetPastLog(socket,msg);\r
});\r
+ socket.on("join",function(msg){\r
+ ParseJoin(socket,msg);\r
+ });\r
+ socket.on("quit",function(msg){\r
+ ParseQuit(socket,msg);\r
+ });\r
+ socket.on("set password",function(msg){\r
+ ParseSetPassword(socket,msg);\r
+ });\r
socket.on("send msg", function (msg) {\r
ParseSendMsg(socket,msg);\r
});\r
});\r
}\r
\r
-function getIpBanList(callback)\r
-{\r
- ipbanlist = {};\r
- path.exists($ip_ban_list_file_name,function(exists){\r
- if(exists == false)\r
- {\r
- if(typeof(callback) == "function")\r
- callback();\r
- return;\r
- }\r
- var stream = fs.createReadStream($ip_ban_list_file_name);\r
- new lazy(stream)\r
- .lines\r
- .forEach(function(line){\r
- var token = line.toString().split(":");\r
- var ip = token[0].replace(/(\r|\n|\r\n)/gm, "");\r
- if(token.length == 1)\r
- ipbanlist[ip] = "";\r
- else\r
- ipbanlist[ip] = token[1];\r
- })\r
- .join(function(){\r
- if(typeof(callback) == "function")\r
- callback();\r
- });\r
- });\r
-}\r
-\r
function ParseAuthorization(handshakeData, callback)\r
{\r
if(handshakeData.headers.cookie) {\r
var sessionID = parseCookie(cookie)["connect.sid"];\r
sessionStore.get(sessionID, function (err, session) {\r
var result = null;\r
- if (err || ipbanlist[handshakeData.address.address] == "r")\r
+ if (err || ipbanlist.IsBaned(handshakeData.address.address))\r
result = "failed get from session store";\r
else if(handshakeData.query.token != session.items.token)\r
result = "invaild token";\r
console.log("disconnected");\r
}\r
\r
-//socket \90Ú\91±\92\86\82Ì\83\\83P\83b\83g\r
-//msg msg\83N\83\89\83X\r
+function ParseSetPassword(socket,msg)\r
+{\r
+ var rno = GetRoomNumberFromName(socket.namespace.name);\r
+ var newMeg = {\r
+ name:$system_name,\r
+ message:null,\r
+ };\r
+ if($rooms.SetPassword(rno,msg.owner,msg.password))\r
+ newMeg.message = $password_setted_message;\r
+ else\r
+ newMeg.message = $failed_set_password_message;\r
+ ParseSendMsg(socket,newMeg);\r
+}\r
+\r
+function ParseJoin(socket,msg)\r
+{\r
+ var ip = GetClientIPAdress(socket);\r
+\r
+ if(ipbanlist.IsBlockedToWrite(ip))\r
+ {\r
+ socket.emit("error",$block_message);\r
+ return;\r
+ }\r
+\r
+ var rno = GetRoomNumberFromName(socket.namespace.name);\r
+ if($rooms.IsContains(rno))\r
+ {\r
+ if($rooms.IsTimeout(rno) ||\r
+ $rooms.IsFirstAuth(rno))\r
+ {\r
+ $rooms.Reset(rno,msg.name);\r
+ ParseGetPastLog(socket,util.format($log_file_name,rno));\r
+ }\r
+ else if($rooms.Auth(rno,msg.name,msg.password))\r
+ {\r
+ ParseGetPastLog(socket,util.format($log_file_name,rno));\r
+ }\r
+ else\r
+ {\r
+ socket.emit("error",$not_match_password);\r
+ return;\r
+ }\r
+ }\r
+\r
+ var newMeg = {\r
+ name:$system_name,\r
+ message:util.format("/enteredby %s %s %s",msg.name,msg.color,msg.mailto),\r
+ };\r
+ ParseSendMsg(socket,newMeg);\r
+}\r
+\r
+function ParseQuit(socket,msg)\r
+{\r
+ var ip = GetClientIPAdress(socket);\r
+\r
+ if(ipbanlist.IsBlockedToWrite(ip))\r
+ {\r
+ socket.emit("error",$block_message);\r
+ return;\r
+ }\r
+\r
+ var rno = GetRoomNumberFromName(socket.namespace.name);\r
+\r
+ var newMeg = {\r
+ name:$system_name,\r
+ message:$password_resetted_message,\r
+ };\r
+ if($rooms.IsContains(rno))\r
+ {\r
+ if($rooms.IsOwner(rno,msg.name))\r
+ {\r
+ $rooms.Reset(rno,null);\r
+ ParseSendMsg(socket,newMeg);\r
+ }\r
+ if(!$rooms.IsFirstAuth(rno) &&\r
+ !$rooms.IsAuthed(rno,msg.name))\r
+ return;\r
+ else\r
+ $rooms.RemoveAuth(rno,msg.name);\r
+ }\r
+\r
+ newMeg.message = util.format("/quitedby %s",msg.name);\r
+ ParseSendMsg(socket,newMeg);\r
+}\r
+\r
+//socket 接続中のソケット\r
+//msg msgクラス\r
function ParseSendMsg(socket,msg)\r
{\r
var ip = GetClientIPAdress(socket);\r
return;\r
}\r
\r
+ var rno = GetRoomNumberFromName(socket.namespace.name);\r
+\r
+ if(msg.name != $system_name && \r
+ $rooms.IsContains(rno) &&\r
+ !$rooms.IsAuthed(rno,msg.name) &&\r
+ !$rooms.IsOwner(rno,msg.name))\r
+ {\r
+ return;\r
+ }\r
+\r
var date = new Date();\r
- //var dateString = date.toFormat("YYYY/MM/DD HH24:MI:SS");\r
\r
- var repacked_msg = CreateMessage(msg,date);\r
+ var repacked_msg = CreateMessage(msg.name,date,msg.message);\r
\r
socket.json.emit("req msg", repacked_msg);\r
\r
socket.json.broadcast.emit("req msg", repacked_msg);\r
\r
- var rno = GetRoomNumberFromName(socket.namespace.name);\r
var path = $log_directory + "/" + util.format($log_file_name,rno);\r
var log = new ChatLog(path);\r
- log.Save(repacked_msg,ip);\r
+ log.Save(repacked_msg,ip,rno);\r
}\r
\r
function GetNameFromRoomNumber(number)\r
});\r
}\r
\r
- this.Save = function(msg,ip){\r
+ this.Save = function(msg,ip,rno){\r
var text = GetTextFromMessage(msg,ip);\r
\r
- SplitLog(path,function(){\r
+ SplitLog(rno,function(){\r
WritePastLog(path,text);\r
});\r
};\r
return text;\r
}\r
\r
- function SplitLog(path,callback)\r
+ function SplitLog(rno,callback)\r
{\r
var state = fs.stat(path,function(err,state){\r
if(err && typeof(callback) == "function")\r
if(state.size > $spilt_size)\r
{\r
var date = new Date();\r
+ var dateString = ""+date.getFullYear()+date.getMonth()+date.getDate()+date.getHours()+date.getMinutes()+date.getSeconds();\r
\r
var newpath = $log_directory + "/" +\r
- util.format($splited_log_file_name,rno,date.toFormat("YYYYMMDDHH24MISS"));\r
+ util.format($splited_log_file_name,rno,dateString);\r
fs.rename(path,newpath,callback);\r
}else{\r
if(typeof(callback) == "function")\r
return socket.handshake.headers["x-forwarded-for"] || socket.handshake.address.address;\r
}\r
\r
-// Message \83N\83\89\83X\r
-function CreateMessage(msg,date)\r
+// Message クラス\r
+function CreateMessage(name,date,message)\r
{\r
- var result = {name:msg.name,\r
+ var result = {name:name,\r
date:date,\r
- message:msg.message};\r
+ message:message};\r
return result;\r
}\r
function CreateMessageFromText(text)\r
message:data[3]};\r
return msg;\r
}\r
+\r
+//RoomInfomationCollecionクラス\r
+function RoomInfomationCollection()\r
+{\r
+ var collection = {};\r
+ this.Clear = function(){\r
+ collection = {};\r
+ };\r
+ this.Add = function(rno,pass){\r
+ collection[rno] = {time : null,\r
+ password : pass,\r
+ owner : null,\r
+ authed_list : {}};\r
+ if(pass != null)\r
+ collection[rno].owner = $system_name;\r
+ };\r
+ this.Reset = function(rno,owner){\r
+ var date = new Date();\r
+ var time = date.getTime();\r
+ collection[rno].password = null;\r
+ collection[rno].authed_list = {};\r
+ collection[rno].owner = owner;\r
+ collection[rno].time = time;\r
+ console.log(util.format("password is reseted in %s",rno));\r
+ };\r
+ this.IsContains = function(rno){\r
+ return rno in collection;\r
+ };\r
+ this.IsFirstAuth = function(rno){\r
+ if(!this.IsContains(rno) || typeof(collection[rno].owner) == "undefined")\r
+ return false;\r
+ return collection[rno].owner == null;\r
+ }\r
+ this.IsAuthed = function(rno,name){\r
+ if(!this.IsContains(rno))\r
+ return false;\r
+ console.log(util.inspect(collection[rno].authed_list));\r
+ return name == collection[rno].owner ||\r
+ name in collection[rno].authed_list;\r
+ };\r
+ this.IsFixedPassword = function(rno){\r
+ if(!this.IsContains(rno))\r
+ return false;\r
+ return collection[rno].owner == $system_name;\r
+ };\r
+ this.IsOwner = function(rno,name){\r
+ return this.IsContains(rno) &&\r
+ typeof(collection[rno].owner) != "undefined" &&\r
+ collection[rno].owner == name;\r
+ }\r
+ this.IsTimeout = function(rno){\r
+ var date = new Date();\r
+ var time = date.getTime();\r
+ return this.IsContains(rno) &&\r
+ !this.IsFixedPassword(rno) &&\r
+ (typeof(collection[rno].time) != "undefined" &&\r
+ time - collection[rno].time >= $reset_password_diff);\r
+ };\r
+ this.RemoveAuth = function(rno,name)\r
+ {\r
+ delete collection[rno].authed_list[name];\r
+ }\r
+ this.Auth = function(rno,name,password){\r
+ if(typeof(collection[rno].password) != "undefined" &&\r
+ collection[rno].password != password)\r
+ return false;\r
+ var date = new Date();\r
+ var time = date.getTime();\r
+ collection[rno].time = time;\r
+ collection[rno].authed_list[name] = "";\r
+ return true;\r
+ }\r
+ this.SetPassword = function(rno,owner,password){\r
+ if(this.IsContains(rno) && \r
+ owner == collection[rno].owner &&\r
+ !this.IsFixedPassword(rno))\r
+ {\r
+ var date = new Date();\r
+ collection[rno].time = date.getTime();\r
+ collection[rno].password = password;\r
+ \r
+ console.log(util.format("password is seted to %s in %s",password,rno));\r
+ return true;\r
+ }\r
+ return false;\r
+ };\r
+ this.GetString = function(){\r
+ var retval = "";\r
+ for(var rno in collection)\r
+ {\r
+ var pass = collection[rno].password;\r
+ if(pass == null)\r
+ pass = "";\r
+ retval += rno + ":" + pass + "\r\n";\r
+ }\r
+ return retval;\r
+ };\r
+ this.GetKeys = function(){\r
+ var retval = {};\r
+ for(var rno in collection)\r
+ {\r
+ retval[rno] = {};\r
+ }\r
+ return retval;\r
+ }\r
+\r
+ for(var i=0; i<arguments.length; i++)\r
+ {\r
+ this.Add(arguments[i].rno,arguments[i].password);\r
+ } \r
+}\r
+\r
+function CreateRoomsFromString(str)\r
+{\r
+ $rooms.Clear();\r
+ var lines = str.split("\r\n");\r
+ for(var i in lines)\r
+ {\r
+ var token = lines[i].split(":");\r
+ console.log(util.inspect(token));\r
+ if(token.length == 1)\r
+ {\r
+ $rooms.Add(token[0],null);\r
+ }\r
+ else if(token.length == 2)\r
+ {\r
+ var rno = token[0];\r
+ var pass = token[1];\r
+ if(pass == "")\r
+ pass = null;\r
+ $rooms.Add(rno, pass);\r
+ }\r
+ }\r
+}\r
+\r
+//IPBANクラス\r
+function IpBanCollecion()\r
+{\r
+ var collection = {};\r
+ this.IsBaned = function(ip){\r
+ return collection[ip] == "r";\r
+ }\r
+ this.IsBlockedToWrite = function(ip){\r
+ return ip in collection;\r
+ }\r
+ this.GetText = function(){\r
+ var text = "";\r
+ for(var key in collection)\r
+ {\r
+ if(collection[key] == "")\r
+ text += key + "\r\n";\r
+ else\r
+ text += key + ":" + collection[key] + "\r\n";\r
+ }\r
+ return text;\r
+ }\r
+ this.Update = function(text,callfunc){\r
+ async.waterfall([\r
+ function(callback){\r
+ fs.open($ip_ban_list_file_name,"w",callback);\r
+ },\r
+ function(fd,callback){\r
+ var buf = new Buffer(text);\r
+ fs.write(fd,buf,0,Buffer.byteLength(text),null,function(){\r
+ callback(null,fd);\r
+ });\r
+ },\r
+ function(fd,callback){\r
+ fs.close(fd,function(){\r
+ GetIpBanList(callfunc);\r
+ });\r
+ }\r
+ ]);\r
+ }\r
+ function GetIpBanList(callback)\r
+ {\r
+ collection = {};\r
+ path.exists($ip_ban_list_file_name,function(exists){\r
+ if(exists == false)\r
+ {\r
+ if(typeof(callback) == "function")\r
+ callback();\r
+ return;\r
+ }\r
+ var stream = fs.createReadStream($ip_ban_list_file_name);\r
+ new lazy(stream)\r
+ .lines\r
+ .forEach(function(line){\r
+ var token = line.toString().replace(/(\r|\n|\r\n)/gm, "").split(":");\r
+ var ip = token[0];\r
+ if(token.length == 1)\r
+ collection[ip] = "";\r
+ else\r
+ collection[ip] = token[1];\r
+ })\r
+ .join(function(){\r
+ if(typeof(callback) == "function")\r
+ callback();\r
+ });\r
+ });\r
+ }\r
+ GetIpBanList();\r
+}\r
+\r
OSDN Git Service
