socket_server.js
2.41 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
const config = require('./config/config')
const app = require('express')();
const http = require('http').Server(app);
const io = require('socket.io')(http);
const papago = require('./openAPIs/papago_api');
const tmi = require('tmi.js');
// Define configuration options
var opts = {
identity: {
username: process.env.BOT_USERNAME,
password: process.env.OAUTH_TOKEN
},
channels: [
'nnonuu'
]
};
// Create a client with our options
const client = new tmi.client(opts); //twitch chatbot client
app.set('view engine', 'ejs');
app.set('views', './testviews');
let room = ['nnonuu', 'bachelorchuckchuck'];
// client.opts.channels;
let a = 0;
app.get('/', (req, res) => {
res.render('chat');
});
app.get('/list',(req,res) => {
res.send(room);
})
app.post('/add',(req,res)=>{
room.append(req.body.streamer);
res.send(req.body.streamer);
})
io.on('connection', (socket) => {
socket.on('disconnect', () => {
console.log('user disconnected');
});
socket.on('leaveRoom', (streamer,name) => {
socket.leave(streamer, () => {
console.log('Someone leave a ' + streamer);
io.to(streamer).emit('leaveRoom', streamer ,name);
});
});
socket.on('joinRoom', (streamer,name) => {
socket.join(streamer, () => {
console.log('Someone join a ' + streamer);
io.to(streamer).emit('joinRoom', streamer ,name);
console.log(streamer,io)
});
});
socket.on('chat message', (streamer, name, msg) => {
io.to(streamer).emit('chat message', name, msg);
});
});
http.listen(process.env.SOCKET_PORT, () => {
console.log(`Connect at ${process.env.SOCKET_PORT}`);
});
/////////////////////Twitch Bot//////////////////////////
// Register our event handlers (defined below)
client.on('message', onMessageHandler);
client.on('connected', onConnectedHandler);
// Connect to Twitch:
client.connect();
// Called every time a message comes in
function onMessageHandler (target, context, msg, self) {
if (self) { return; } // Ignore messages from the bot
if (msg.startsWith('!')){
}
else{
io.to(target.replace('#','')).emit('chat message',context["display-name"],msg)
papago.detectchat(msg, client, io, target);
}
}
// Called every time the bot connects to Twitch chat
function onConnectedHandler (addr, port) {
console.log(`*KwitchBot Connected to ${addr}:${port}`);
}