chatServer.js

   1 /*\r
   2  * 設定\r
   3  */\r
   4 $max_room_number = 3;   //最大ルーム数\r
   5 $spilt_size = 1024 * 512;       //分割するサイズ\r
   6 $reset_password_diff = 1000 * 60 * 60;  //ルームパスワードをリセットする間隔\r
   7 $gc_time_interval = 1000 * 60 * 60;     //ゴミ掃除を行う間隔\r
   8 $block_message = "メッセージの送信に失敗しました";       //ブロック時のメッセージ\r
   9 $not_match_password = "パスワードが一致しませんでした";  //パスワードが一致しない場合に表示されるメッセージ\r
  10 $password_setted_message = "パスワードを設定しました";      //パスワードが設定されたときに表示されるメッセージ\r
  11 $password_resetted_message = "パスワードをリセットしました";      //パスワードが再設定されたときに表示されるメッセージ\r
  12 $failed_set_password_message = "パスワードの設定に失敗しました"; //パスワードが再設定されたときに表示されるメッセージ\r
  13 $ip_ban_list_file_name = "ipbanlist.txt";       //アクセスを禁止するIPが記録されているファイル\r
  14 $room_configure_file_name = "roomlist.txt";     //ルームの設定が記録されているファイル\r
  15 $port = process.env.port || 3000;       //ポート\r
  16 $username = "admin";    //管理者用のページにアクセスできるユーザ名\r
  17 $password = "admin";    //管理者用のページにアクセスするのに必要なパスワード\r
  18 $token_length = 32;     //トークンの長さ\r
  19 $redisHost = "localhost";       //redisサーバのアドレス\r
  20 $redisPort = 6379;      //redisサーバのポート\r
  21 $redisPassword = "";    //redisサーバのパスワード\r
  22 $system_name = "system";        //システム発言を表す名前\r
  23 $log_directory = "log"; //ログファイルを置くフォルダー\r
  24 $log_file_name = "logfile%d.txt";       //ログファイル名(%dはそのままにしておくこと)\r
  25 $splited_log_file_name = "logfile%d_%s.txt"     //分割後のファイル名(%dと%sはそのままにしておくこと)\r
  26 $pastlogfile_pattern = "logfile%d(_+.*)?\.txt"; //過去ログと判定する正規表現\r
  27 $secret = "5514EA2B-C9B2-4D65-8D81-1F33A180A0C2";\r
  28 /**\r
  29  * Module dependencies.\r
  30  */\r
  31 \r
  32 // Server\r
  33 var express = require("express");\r
  34 \r
  35 var app = express();\r
  36 \r
  37 var http = require("http");\r
  38 \r
  39 var util = require("util");\r
  40 \r
  41 var lazy = require("./lazy.js");\r
  42 \r
  43 var fs = require("fs");\r
  44 \r
  45 var cookie = require("express/node_modules/cookie");\r
  46 \r
  47 var connectUtils = require("express/node_modules/connect/lib/utils");\r
  48 \r
  49 var RedisStore = require("connect-redis")(express);\r
  50 var sessionStore = new RedisStore({host:$redisHost,port:$redisPort,pass:$redisPassword});\r
  51 \r
  52 var async = require("async");\r
  53 \r
  54 var path = require("path");\r
  55 \r
  56 // Configuration\r
  57 \r
  58 app.configure(function(){\r
  59         app.disabled("view cache");\r
  60         app.set("view options", { layout: false })\r
  61         app.set("views", __dirname + "/public");\r
  62         app.set("view engine", "ejs");\r
  63         app.use(express.bodyParser());\r
  64         app.use(express.methodOverride());\r
  65         app.use(express.cookieParser($secret));\r
  66         app.use(express.session({\r
  67                 store:sessionStore,\r
  68                 cookie: { httpOnly: false }\r
  69         }));\r
  70         app.use(app.router);\r
  71         app.use(express.static(__dirname + "/public"));\r
  72 });\r
  73 \r
  74 app.configure('development', function(){\r
  75   app.use(express.errorHandler({ dumpExceptions: true, showStack: true })); \r
  76 });\r
  77 \r
  78 app.configure('production', function(){\r
  79   app.use(express.errorHandler()); \r
  80 });\r
  81 \r
  82 function SessionInfomation(token,admin)\r
  83 {\r
  84         this.token = token;\r
  85         this.admin = admin;\r
  86 }\r
  87 \r
  88 // Routes\r
  89 app.get("/chat", function(req, res){\r
  90         var auth_string = getRandomString($token_length);\r
  91         req.session.items = new SessionInfomation(auth_string,false);\r
  92 \r
  93         var room_number = 0;\r
  94         if(typeof(req.query.rno) != "undefined")\r
  95                 room_number = req.query.rno;\r
  96         res.render("chat",{rno:room_number,token:auth_string});\r
  97 });\r
  98 \r
  99 app.all("/log/*",express.basicAuth(function (user, pass) {\r
 100         return user === $username && pass === $password;\r
 101 }));\r
 102 \r
 103 app.get("/log/*",function (req, res) {\r
 104         res.sendfile(__dirname + req.url);\r
 105 });\r
 106 \r
 107 app.all("/admin_chat",express.basicAuth(function (user, pass) {\r
 108         return user === $username && pass === $password;\r
 109 }));\r
 110 \r
 111 app.get("/admin_chat", function(req, res){\r
 112         var auth_string = getRandomString($token_length);\r
 113         req.session.items = new SessionInfomation(auth_string,true);\r
 114 \r
 115         var room_number = 0;\r
 116         if(typeof(req.query.rno) != "undefined")\r
 117                 room_number = req.query.rno;\r
 118         res.render("chat",{rno:room_number,token:auth_string});\r
 119 });\r
 120 \r
 121 app.all("/admin",express.basicAuth(function (user, pass) {\r
 122         return user === $username && pass === $password;\r
 123 }));\r
 124 \r
 125 app.get("/admin", function(req, res){\r
 126         renderAdmin(req,res);\r
 127 });\r
 128 \r
 129 app.post("/admin",function(req,res){\r
 130         if(req.session.items.token != req.body.token)\r
 131         {\r
 132                 res.send($invaild_token_message);\r
 133                 return;\r
 134         }\r
 135         if(typeof(req.body.erase) != "undefined")\r
 136         {\r
 137                 removeLog(req.body.file,function(){\r
 138                         renderAdmin(req,res);\r
 139                 });\r
 140         }\r
 141         if(typeof(req.body.registor) != "undefined")\r
 142         {\r
 143                 ipbanlist.Update(req.body.newbanlist,function(){\r
 144                         renderAdmin(req,res);\r
 145                 });\r
 146         }\r
 147         if(typeof(req.body.updateroom) != "undefined")\r
 148         {\r
 149                 $rooms.Update(req.body.newroomlist,function(){\r
 150                         renderAdmin(req,res);\r
 151                 });\r
 152         }\r
 153 });\r
 154 \r
 155 function renderAdmin(req,res)\r
 156 {\r
 157         var auth_string = getRandomString($token_length);\r
 158         req.session.items = {token:auth_string};\r
 159         var iplist = ipbanlist.GetText();\r
 160 \r
 161         fs.readdir($log_directory,function(err,list){\r
 162                 res.render("admin", {\r
 163                         files: list,\r
 164                         log_directory:$log_directory,\r
 165                         ipbanlist:iplist,\r
 166                         token:auth_string,\r
 167                         roomlist:$rooms.GetString()\r
 168                 });\r
 169         });\r
 170 }\r
 171 \r
 172 function getRandomString(length)\r
 173 {\r
 174         var RandomString = "";\r
 175         var BaseString ="ABCDEFGHIJKLMNOPQRSTUVWXYZabcdefghijklmnopqrstuvwxyz0123456789!#$%&'()=~|-^\@[;:],./\`{+*}<>?_";\r
 176         for(var i=0; i<length; i++) {\r
 177                 RandomString += BaseString.charAt( Math.floor( Math.random() * BaseString.length));\r
 178         }\r
 179         return RandomString\r
 180 }\r
 181 \r
 182 function removeLog(files,callback)\r
 183 {\r
 184         async.map(files,\r
 185         function(item,callback){\r
 186                 fs.unlink($log_directory + "/" + item,callback);\r
 187         },\r
 188         function(err,results){\r
 189                 if(typeof(callback) == "function")\r
 190                         callback();\r
 191         });\r
 192 }\r
 193 \r
 194 var server = http.createServer(app).listen($port);\r
 195 \r
 196 /*\r
 197  * サーバー部分\r
 198  */\r
 199 \r
 200 var io = require("socket.io").listen(server);\r
 201 io.configure('production', function(){\r
 202   io.enable('browser client minification');  // minified されたクライアントファイルを送信する\r
 203   io.enable('browser client etag');          // バージョンによって etag によるキャッシングを有効にする\r
 204   io.set('log level', 1);                    // ログレベルを設定(デフォルトより下げている)\r
 205 });\r
 206 var clients = new Array();\r
 207 \r
 208 var ipbanlist = new IpBanCollecion();\r
 209 var $rooms = new RoomInfomationCollection();\r
 210 \r
 211 createLogDirectory();\r
 212 \r
 213 for(var i = 0; i < $max_room_number; i++)\r
 214 {\r
 215         clients[i] =io\r
 216         .of(GetNameFromRoomNumber(i))\r
 217         .authorization(ParseAuthorization)\r
 218         .on("connection", function (socket) {\r
 219                 var ip = GetClientIPAdress(socket);\r
 220 \r
 221                 console.log("connected from %s",ip);\r
 222 \r
 223                 var rno = GetRoomNumberFromName(socket.namespace.name);\r
 224                 var roomconfig = {};\r
 225                 $rooms.Get(rno).AddRom(ip);\r
 226                 if($rooms.Get(rno).IsVolatile() == false)\r
 227                 {\r
 228                         if($rooms.Get(rno).IsFixedPassword())\r
 229                                 roomconfig.type = 2;\r
 230                         else if($rooms.Get(rno).IsHiddenLogFromRom())\r
 231                                 roomconfig.type = 3;\r
 232                         else\r
 233                                 roomconfig.type = 1;\r
 234                         roomconfig.IsOwned = !$rooms.Get(rno).IsFirstAuth();\r
 235                 }else{\r
 236                         roomconfig.type = 0;\r
 237                 }\r
 238                 roomconfig.admin = socket.handshake.admin;\r
 239                 socket.json.emit("send roominfo",roomconfig);\r
 240 \r
 241                 var romcount = $rooms.Get(rno).GetRomCount();\r
 242                 socket.json.emit("send romcount",romcount);\r
 243                 socket.json.broadcast.emit("send romcount",romcount);\r
 244 \r
 245                 socket.on("get pastLogList", function (msg) {\r
 246                         ParseGetPastLogList(socket,msg);\r
 247                 });\r
 248                 socket.on("get pastLog", function (msg) {\r
 249                         ParseGetPastLog(socket,msg);\r
 250                 });\r
 251                 socket.on("join",function(msg){\r
 252                         ParseJoin(socket,msg);\r
 253                 });\r
 254                 socket.on("quit",function(msg){\r
 255                         ParseQuit(socket,msg);\r
 256                 });\r
 257                 socket.on("set password",function(msg){\r
 258                         ParseSetPassword(socket,msg);\r
 259                 });\r
 260                 socket.on("send msg", function (msg) {\r
 261                         ParseSendMsg(socket,msg);\r
 262                 });\r
 263                 socket.on("disconnect", function (msg) {\r
 264                         ParseDisconnect(socket,msg);\r
 265                 });\r
 266         });\r
 267 }\r
 268 \r
 269 function createLogDirectory()\r
 270 {\r
 271         fs.exists($log_directory,function(exists){\r
 272                 if(exists == false)\r
 273                         fs.mkdirSync($log_directory);\r
 274         });\r
 275 }\r
 276 \r
 277 function ParseAuthorization(handshakeData, callback)\r
 278 {\r
 279         if(handshakeData.headers.cookie) {\r
 280                 var signedCookie = cookie.parse(handshakeData.headers.cookie);\r
 281                 var sessionID = connectUtils.parseSignedCookies(signedCookie, $secret)["connect.sid"];\r
 282                 sessionStore.get(sessionID, function (err, session) {\r
 283                         var result = null;\r
 284                         if (ipbanlist.IsBaned(handshakeData.address.address))\r
 285                                 result = "failed get from session store";\r
 286                         else if(err)\r
 287                                 result = err;\r
 288                         else if(handshakeData.query.token != session.items.token)\r
 289                                 result = "invaild token";\r
 290                         if(typeof(session) != "undefined" && result == null)\r
 291                         {\r
 292                                 handshakeData.admin = session.items.admin;\r
 293                                 handshakeData.sessionID = sessionID;\r
 294                         }\r
 295                         callback(result,result == null && !err);\r
 296                 });\r
 297         } else {\r
 298                 return callback("failed get cookie", false);\r
 299         }\r
 300 }\r
 301 \r
 302 function ParseDisconnect(socket,msg)\r
 303 {\r
 304         var ip = GetClientIPAdress(socket);\r
 305         var rno = GetRoomNumberFromName(socket.namespace.name);\r
 306         $rooms.Get(rno).RemoveRom(ip);\r
 307 \r
 308         var romcount = $rooms.Get(rno).GetRomCount();\r
 309         socket.json.emit("send romcount",romcount);\r
 310         socket.json.broadcast.emit("send romcount",romcount);\r
 311 \r
 312         sessionStore.destroy(socket.handshake.sessionID);\r
 313 \r
 314         console.log("disconnected");\r
 315 }\r
 316 \r
 317 function ParseSetPassword(socket,msg)\r
 318 {\r
 319         var rno = GetRoomNumberFromName(socket.namespace.name);\r
 320         var newMeg = {\r
 321                 name:$system_name,\r
 322                 message:null,\r
 323         };\r
 324         if($rooms.Get(rno).IsVolatile() == false && $rooms.Get(rno).SetPassword(msg.owner,msg.password))\r
 325                 newMeg.message = $password_setted_message;\r
 326         else\r
 327                 newMeg.message = $failed_set_password_message;\r
 328         ParseSendMsg(socket,newMeg);\r
 329 }\r
 330 \r
 331 function ParseJoin(socket,msg)\r
 332 {\r
 333         var ip = GetClientIPAdress(socket);\r
 334 \r
 335         if(ipbanlist.IsBlockedToWrite(ip))\r
 336         {\r
 337                 socket.emit("error",$block_message);\r
 338                 return;\r
 339         }\r
 340 \r
 341         var rno = GetRoomNumberFromName(socket.namespace.name);\r
 342 \r
 343         $rooms.Get(rno).RemoveRom(ip);\r
 344         \r
 345         var romcount = $rooms.Get(rno).GetRomCount();\r
 346         socket.json.emit("send romcount",romcount);\r
 347         socket.json.broadcast.emit("send romcount",romcount);\r
 348 \r
 349         if($rooms.Get(rno).IsVolatile() == false)\r
 350         {\r
 351                 if($rooms.Get(rno).IsTimeout() ||\r
 352                         $rooms.Get(rno).IsFirstAuth())\r
 353                 {\r
 354                         $rooms.Get(rno).Reset(msg.name);\r
 355                         ParseGetPastLog(socket,util.format($log_file_name,rno));\r
 356                 }\r
 357                 else if($rooms.Get(rno).Auth(msg.name,msg.password))\r
 358                 {\r
 359                         ParseGetPastLog(socket,util.format($log_file_name,rno));\r
 360                 }\r
 361                 else\r
 362                 {\r
 363                         socket.emit("error",$not_match_password);\r
 364                         return;\r
 365                 }\r
 366         }\r
 367 \r
 368         var newMeg = {\r
 369                 name:$system_name,\r
 370                 message:util.format("/enteredby %s %s %s",msg.name,msg.color,msg.mailto),\r
 371         };\r
 372         ParseSendMsg(socket,newMeg);\r
 373 }\r
 374 \r
 375 function ParseQuit(socket,msg)\r
 376 {\r
 377         var ip = GetClientIPAdress(socket);\r
 378 \r
 379         if(ipbanlist.IsBlockedToWrite(ip))\r
 380         {\r
 381                 socket.emit("error",$block_message);\r
 382                 return;\r
 383         }\r
 384 \r
 385         var rno = GetRoomNumberFromName(socket.namespace.name);\r
 386 \r
 387         var newMeg = {\r
 388                 name:$system_name,\r
 389                 message:$password_resetted_message,\r
 390         };\r
 391 \r
 392         $rooms.Get(rno).AddRom(ip);\r
 393 \r
 394         var romcount = $rooms.Get(rno).GetRomCount();\r
 395         socket.json.emit("send romcount",romcount);\r
 396         socket.json.broadcast.emit("send romcount",romcount);\r
 397 \r
 398         if($rooms.Get(rno).IsVolatile() == false)\r
 399         {\r
 400                 if($rooms.Get(rno).IsOwner(msg.name))\r
 401                 {\r
 402                         $rooms.Get(rno).Reset(null);\r
 403                         ParseSendMsg(socket,newMeg);\r
 404                 }\r
 405                 if(!$rooms.Get(rno).IsFirstAuth() &&\r
 406                         !$rooms.Get(rno).IsAuthed(msg.name))\r
 407                         return;\r
 408                 else\r
 409                         $rooms.Get(rno).RemoveAuth(msg.name);\r
 410         }\r
 411 \r
 412         newMeg.message = util.format("/quitedby %s",msg.name);\r
 413         ParseSendMsg(socket,newMeg);\r
 414 }\r
 415 \r
 416 //socket 接続中のソケット\r
 417 //msg msgクラス\r
 418 function ParseSendMsg(socket,msg)\r
 419 {\r
 420         var ip = GetClientIPAdress(socket);\r
 421 \r
 422         if(ip in ipbanlist)\r
 423         {\r
 424                 socket.emit("error",$block_message);\r
 425                 return;\r
 426         }\r
 427 \r
 428         var rno = GetRoomNumberFromName(socket.namespace.name);\r
 429 \r
 430         if(msg.name != $system_name && \r
 431                 $rooms.Get(rno).IsVolatile() == false &&\r
 432                 !$rooms.Get(rno).IsAuthed(msg.name) &&\r
 433                 !$rooms.Get(rno).IsOwner(rno,msg.name))\r
 434         {\r
 435                 return;\r
 436         }\r
 437 \r
 438         var date = new Date();\r
 439 \r
 440         var repacked_msg = CreateMessage(msg.name,date,msg.message);\r
 441 \r
 442         if(socket.handshake.admin)\r
 443                 repacked_msg.ip = ip;\r
 444 \r
 445         socket.json.emit("req msg", repacked_msg);\r
 446 \r
 447         socket.json.broadcast.emit("req msg", repacked_msg);\r
 448 \r
 449         var path = $log_directory + "/" + util.format($log_file_name,rno);\r
 450         var log = new ChatLog(path);\r
 451         log.Save(repacked_msg,ip,rno);\r
 452 }\r
 453 \r
 454 function GetNameFromRoomNumber(number)\r
 455 {\r
 456         return "/" + number;\r
 457 }\r
 458 \r
 459 function GetRoomNumberFromName(name)\r
 460 {\r
 461         if(name.charAt(0) == "/")\r
 462                 return parseInt(name.substr(1));\r
 463         throw "GetRoomNumberFromName error";\r
 464 }\r
 465 \r
 466 function ParseGetPastLogList(socket,msg)\r
 467 {\r
 468         var list = fs.readdir($log_directory,function(err,files){\r
 469                 var text = "";\r
 470                 var rno = GetRoomNumberFromName(socket.namespace.name);\r
 471                 var pattern = $pastlogfile_pattern.replace("%d",rno);\r
 472                 for(var i = 0; i < files.length; i++)\r
 473                 {\r
 474                         var logname = files[i];\r
 475                         if(logname.match(pattern))\r
 476                                 text += files[i] + "\n";\r
 477                 }\r
 478                 socket.emit("req pastloglist",text);\r
 479         });\r
 480 }\r
 481 \r
 482 function ParseGetPastLog(socket,file)\r
 483 {\r
 484         if(file == "")\r
 485                 return;\r
 486         var path = $log_directory + "/" + file;\r
 487         var log = new ChatLog(path);\r
 488         log.ToArray(socket.handshake.admin,function(array){\r
 489                 socket.json.emit("req pastlog",array);\r
 490         });\r
 491 }\r
 492 \r
 493 function ChatLog(path)\r
 494 {\r
 495         this.ToArray = function(hasIp,callback)\r
 496         {\r
 497                 var state = fs.stat(path,function(err,state){\r
 498                         if(err)\r
 499                                 return;\r
 500                         var array = new Array();\r
 501                         var stream = fs.createReadStream(path);\r
 502                         new lazy(stream)\r
 503                                 .spilt(";")\r
 504                                 .forEach(function(line){\r
 505                                         var msg = CreateMessageFromText(line.toString());\r
 506                                         if(hasIp == false)\r
 507                                                 msg.ip = "";\r
 508                                         array.push(msg);\r
 509                                 })\r
 510                                 .join(function(){\r
 511                                         callback(array);\r
 512                                 });\r
 513                 });\r
 514         }\r
 515 \r
 516         this.Save = function(msg,ip,rno){\r
 517                 var text = GetTextFromMessage(msg,ip);\r
 518 \r
 519                 SplitLog(rno,function(){\r
 520                         WritePastLog(path,text);\r
 521                 });\r
 522         };\r
 523 \r
 524         function GetTextFromMessage(msg,ip)\r
 525         {\r
 526                 var text = msg.name + "<>" +\r
 527                                 msg.date + "<>" +\r
 528                                 ip + "<>" +\r
 529                                 msg.message +\r
 530                                 ";";\r
 531                 return text;\r
 532         }\r
 533 \r
 534         function SplitLog(rno,callback)\r
 535         {\r
 536                 var state = fs.stat(path,function(err,state){\r
 537                         if(err && typeof(callback) == "function")\r
 538                         {\r
 539                                 callback();\r
 540                                 return;\r
 541                         }\r
 542                         if(state.size > $spilt_size)\r
 543                         {\r
 544                                 var date = new Date();\r
 545                                 var dateString = ""+date.getFullYear()+date.getMonth()+date.getDate()+date.getHours()+date.getMinutes()+date.getSeconds();\r
 546 \r
 547                                 var newpath = $log_directory + "/" +\r
 548                                         util.format($splited_log_file_name,rno,dateString);\r
 549                                 fs.rename(path,newpath,callback);\r
 550                         }else{\r
 551                                 if(typeof(callback) == "function")\r
 552                                         callback();\r
 553                         }\r
 554                 });\r
 555         }\r
 556 \r
 557         function WritePastLog(path,text)\r
 558         {\r
 559                 async.waterfall([\r
 560                         function(callback){\r
 561                                 fs.open(path,"a",callback);\r
 562                         },\r
 563                         function(fd,callback){\r
 564                                 var buf = new Buffer(text);\r
 565                                 fs.write(fd,buf,0,Buffer.byteLength(text),null,function(){\r
 566                                         callback(null,fd);\r
 567                                 });\r
 568                         },\r
 569                         function(fd){\r
 570                                 fs.close(fd);\r
 571                         }\r
 572                 ]);\r
 573         }\r
 574 }\r
 575 \r
 576 function GetClientIPAdress(socket)\r
 577 {\r
 578         return socket.handshake.headers["x-forwarded-for"] || socket.handshake.address.address;\r
 579 }\r
 580 \r
 581 // Message クラス\r
 582 function CreateMessage(name,date,message)\r
 583 {\r
 584         var result = {name:name,\r
 585                 date:date,\r
 586                 ip:"",\r
 587                 message:message};\r
 588         return result;\r
 589 }\r
 590 function CreateMessageFromText(text)\r
 591 {\r
 592         var data = text.split("<>");\r
 593         var msg = {name:data[0],\r
 594                 ip:data[2],\r
 595                 date:data[1],\r
 596                 message:data[3]};\r
 597         return msg;\r
 598 }\r
 599 \r
 600 //RoomInfomationCollecionクラス\r
 601 function RoomInfomationCollection()\r
 602 {\r
 603         var collection = {};\r
 604         this.Get = function(rno){\r
 605                 return collection[rno];\r
 606         }\r
 607         this.IsContains = function(rno){\r
 608                 return rno in collection;\r
 609         };\r
 610         this.GetString = function(){\r
 611                 var retval = "";\r
 612                 for(var rno in collection)\r
 613                 {\r
 614                         if($rooms.Get(rno).IsVolatile())\r
 615                                 continue;\r
 616                         var pass = collection[rno].password;\r
 617                         if(pass == null)\r
 618                                 pass = "";\r
 619                         var hiddenlog = collection[rno].hiddenlog;\r
 620                         retval += rno + ":" + pass + ":" + hiddenlog + "\r\n";\r
 621                 }\r
 622                 return retval;\r
 623         };\r
 624         this.GetKeys = function(){\r
 625                 var retval = {};\r
 626                 for(var rno in collection)\r
 627                 {\r
 628                         retval[rno] = {};\r
 629                 }\r
 630                 return retval;\r
 631         }\r
 632         this.Update = function(text,callfunc){\r
 633                 async.waterfall([\r
 634                         function(callback){\r
 635                                 fs.open($room_configure_file_name,"w",callback);\r
 636                         },\r
 637                         function(fd,callback){\r
 638                                 var buf = new Buffer(text);\r
 639                                 fs.write(fd,buf,0,Buffer.byteLength(text),null,function(){\r
 640                                         callback(null,fd);\r
 641                                 });\r
 642                         },\r
 643                         function(fd,callback){\r
 644                                 fs.close(fd,function(){\r
 645                                         GetRoomList(callfunc);\r
 646                                 });\r
 647                         }\r
 648                 ]);\r
 649         }\r
 650         function GetRoomList(callback){\r
 651                 Clear();\r
 652                 fs.exists($room_configure_file_name,function(exists){\r
 653                         if(exists == false)\r
 654                         {\r
 655                                 if(typeof(callback) == "function")\r
 656                                         callback();\r
 657                                 return;\r
 658                         }\r
 659                         var stream = fs.createReadStream($room_configure_file_name);\r
 660                         new lazy(stream)\r
 661                                 .lines\r
 662                                 .forEach(function(line){\r
 663                                         var token = line.toString().replace(/(\r|\n|\r\n)/gm, "").split(":");\r
 664                                         if(token.length == 1)\r
 665                                         {\r
 666                                                 Add(token[0],null,false);\r
 667                                         }\r
 668                                         else if(token.length == 2)\r
 669                                         {\r
 670                                                 var rno = token[0];\r
 671                                                 var pass = token[1];\r
 672                                                 if(pass == "")\r
 673                                                         pass = null;\r
 674                                                 Add(rno, pass,false);\r
 675                                         }\r
 676                                         else if(token.length == 3)\r
 677                                         {\r
 678                                                 var rno = token[0];\r
 679                                                 var pass = token[1];\r
 680                                                 if(pass == "")\r
 681                                                         pass = null;\r
 682                                                 var hiddenlog = false;\r
 683                                                 if(token[2] == "true")\r
 684                                                         hiddenlog = true;\r
 685                                                 Add(rno, pass,hiddenlog);\r
 686                                         }\r
 687                                 })\r
 688                                 .join(function(){\r
 689                                         if(typeof(callback) == "function")\r
 690                                                 callback();\r
 691                                 });\r
 692                 });\r
 693         }\r
 694         function Clear(){\r
 695                 collection = {};\r
 696                 for(var i = 0; i < $max_room_number; i++)\r
 697                         Add(i,null,null);\r
 698         };\r
 699         function Add(rno,pass,hiddenlogflag){\r
 700                 collection[rno] = new RoomInfomation(pass,hiddenlogflag);\r
 701                 if(pass != null)\r
 702                         collection[rno].owner = $system_name;\r
 703         };\r
 704         var $gc_interval_id = setInterval(function(){\r
 705                 for(var rno in this.rom_list)\r
 706                         collection[rno].GCRomList();\r
 707         },$gc_time_interval);\r
 708         GetRoomList();\r
 709 }\r
 710 \r
 711 //RoomInfomationクラス\r
 712 function RoomInfomation(pass,hiddenlogflag)\r
 713 {\r
 714         this.password = pass;\r
 715         this.rom_list = {};\r
 716         this.authed_list = {};\r
 717         this.owner = null;\r
 718         this.time = null;\r
 719         this.hiddenlog = hiddenlogflag;\r
 720         this.IsVolatile = function(){\r
 721                 return this.owner == null &&\r
 722                         this.password == null &&\r
 723                         this.time == null &&\r
 724                         this.hiddenlog == null;\r
 725         }\r
 726         this.GetRomCount = function(){\r
 727                 var count = 0;\r
 728                 for(var key in this.rom_list)\r
 729                         count++;\r
 730                 return count;\r
 731         };\r
 732         this.AddRom = function(ip){\r
 733                 var date = new Date();\r
 734                 this.rom_list[ip] = {time:date.getTime()};\r
 735         };\r
 736         this.RemoveRom = function(ip){\r
 737                 delete this.rom_list[ip];\r
 738         };\r
 739         this.Reset = function(owner){\r
 740                 var date = new Date();\r
 741                 var time = date.getTime();\r
 742                 this.password = null;\r
 743                 this.authed_list = {};\r
 744                 this.owner = owner;\r
 745                 this.time = time;\r
 746         };\r
 747         this.IsFirstAuth = function(){\r
 748                 return this.owner == null;\r
 749         };\r
 750         this.IsAuthed = function(name){\r
 751                 return name == this.owner ||\r
 752                         name in this.authed_list;\r
 753         };\r
 754         this.IsHiddenLogFromRom = function(){\r
 755                 return this.hiddenlog;\r
 756         };\r
 757         this.IsFixedPassword = function(){\r
 758                 return this.owner == $system_name;\r
 759         };\r
 760         this.IsOwner = function(name){\r
 761                 return this.owner == name;\r
 762         };\r
 763         this.IsTimeout = function(){\r
 764                 var date = new Date();\r
 765                 var current_time = date.getTime();\r
 766                 return !this.IsFixedPassword() &&\r
 767                         current_time - this.time >= $reset_password_diff;\r
 768         };\r
 769         this.RemoveAuth = function(name)\r
 770         {\r
 771                 delete this.authed_list[name];\r
 772         };\r
 773         this.Auth = function(name,password){\r
 774                 if(this.password != password)\r
 775                         return false;\r
 776                 var date = new Date();\r
 777                 var time = date.getTime();\r
 778                 this.time = time;\r
 779                 this.authed_list[name] = "";\r
 780                 return true;\r
 781         };\r
 782         this.SetPassword = function(owner,password){\r
 783                 if(owner == this.owner &&\r
 784                         !this.IsFixedPassword() &&\r
 785                         !this.IsHiddenLogFromRom())\r
 786                 {\r
 787                         var date = new Date();\r
 788                         this.time = date.getTime();\r
 789                         this.password = password;\r
 790                         return true;\r
 791                 }\r
 792                 return false;\r
 793         };\r
 794         this.GCRomList = function(){\r
 795                 var date = new Date();\r
 796                 var current_time = date.getTime();\r
 797                 for(var ip in this.rom_list)\r
 798                 {\r
 799                         if(current_time - this.rom_list[ip].time >= $gc_time_interval)\r
 800                                 delete this.rom_list[ip];\r
 801                 }\r
 802         };\r
 803 }\r
 804 \r
 805 //IPBANクラス\r
 806 function IpBanCollecion()\r
 807 {\r
 808         var collection = {};\r
 809         this.IsBaned = function(ip){\r
 810                 return collection[ip] == "r";\r
 811         }\r
 812         this.IsBlockedToWrite = function(ip){\r
 813                 return ip in collection;\r
 814         }\r
 815         this.GetText = function(){\r
 816                 var text = "";\r
 817                 for(var key in collection)\r
 818                 {\r
 819                         if(collection[key] == "")\r
 820                                 text += key + "\r\n";\r
 821                         else\r
 822                                 text += key + ":" + collection[key] + "\r\n";\r
 823                 }\r
 824                 return text;\r
 825         }\r
 826         this.Update = function(text,callfunc){\r
 827                 async.waterfall([\r
 828                         function(callback){\r
 829                                 fs.open($ip_ban_list_file_name,"w",callback);\r
 830                         },\r
 831                         function(fd,callback){\r
 832                                 var buf = new Buffer(text);\r
 833                                 fs.write(fd,buf,0,Buffer.byteLength(text),null,function(){\r
 834                                         callback(null,fd);\r
 835                                 });\r
 836                         },\r
 837                         function(fd,callback){\r
 838                                 fs.close(fd,function(){\r
 839                                         GetIpBanList(callfunc);\r
 840                                 });\r
 841                         }\r
 842                 ]);\r
 843         }\r
 844         function GetIpBanList(callback)\r
 845         {\r
 846                 collection = {};\r
 847                 fs.exists($ip_ban_list_file_name,function(exists){\r
 848                         if(exists == false)\r
 849                         {\r
 850                                 if(typeof(callback) == "function")\r
 851                                         callback();\r
 852                                 return;\r
 853                         }\r
 854                         var stream = fs.createReadStream($ip_ban_list_file_name);\r
 855                         new lazy(stream)\r
 856                                 .lines\r
 857                                 .forEach(function(line){\r
 858                                         var token = line.toString().replace(/(\r|\n|\r\n)/gm, "").split(":");\r
 859                                         var ip = token[0];\r
 860                                         if(token.length == 1)\r
 861                                                 collection[ip] = "";\r
 862                                         else\r
 863                                                 collection[ip] = token[1];\r
 864                                 })\r
 865                                 .join(function(){\r
 866                                         if(typeof(callback) == "function")\r
 867                                                 callback();\r
 868                                 });\r
 869                 });\r
 870         }\r
 871         GetIpBanList();\r
 872 }\r
 873 \r