var express = require('express');
var app = express();
var http = require('http').Server(app);
var io = require('socket.io')(http);
// var xss = require('xss');
var defaultMsgs = [
    '保持队形666',
    'awsl',
    '前方高能预警',
    '果然是名场面！！！',
    '正片开始',
    '妙啊~~~',
    '还是这位童鞋霸气V5',
    '福利要来了，大家冲鸭~~~~~~',
    '这声音，我耳朵怀孕了！',
    'hhhhhhhhhhhhhh',
    '哇哦~这画面太美',
    '我要看节目，我要吃瓜',
    '红包来一波~',
    '灯光给我，我要秀啊',
    '掌声来啦，吧唧吧唧吧唧吧唧吧唧吧唧',
    '谁给我私发个红包呢？',
    '鼠年大吉大利，大家加油努力',
    '别拦我，叫我今天喝个够~~',
    '你好，你有一个新bug等待处理',
    '新年一起许个愿吧！'
];
var timer = null;

io.on('connection', function(socket) {
    // 接收弹幕消息
    socket.on('barrage', function(msg) {
        // console.log('message:' + msg);
        // 过滤 xss
        // var msg = xss(msg);
        io.emit('barrage', msg);
        clearTimeout(timer);
    });

    // 断开连接
    socket.on('disconnect', function() {
        console.log('user disconnected');
        timer = setTimeout(function() {
            var msg = defaultMsgs[Math.floor(Math.random() * (19 - 0 + 1))];
            io.emit('barrage', msg);
        }, 15000);
    });
});

http.listen(3000, function() {
    console.log('listening on *:3000');
});