chat.js

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