knotteye
/
satyr
Archived
1
0
Fork 0
Code Issues Pull Requests Releases 5 Wiki Activity

Move SIGINT listener to connect function to avoid socket does not exist errors 

Add conditional to disconnect peering
merge-requests/1/head
knotteye 2019-11-05 17:48:12 -06:00
parent 9076b1817b
commit 297aeb3d4a
2 changed files with 5 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/http.ts
View File

@ -157,7 +157,7 @@ async function init(satyr: any, port: number, ircconf: any){
if(ircconf.enable) irc.part(socket.nick, rooms[i]); if(ircconf.enable) irc.part(socket.nick, rooms[i]);
io.to(rooms[i]).emit('ALERT', socket.nick+' disconnected'); io.to(rooms[i]).emit('ALERT', socket.nick+' disconnected');
} }
irc.unregisterUser(socket.nick); if(ircconf.enable) irc.unregisterUser(socket.nick);
store.rm(socket.nick); store.rm(socket.nick);
}); });
socket.on('NICK', async (data) => { socket.on('NICK', async (data) => {

9
src/irc.js
View File

@ -141,15 +141,14 @@ socket.on('data', data => {
}) })
}) })
process.on('SIGINT', () => {
socket.write('QUIT\r\n')
process.exit()
})
module.exports.connect = conf => new Promise((resolve, reject) => { module.exports.connect = conf => new Promise((resolve, reject) => {
emitter.once('ping', resolve) emitter.once('ping', resolve)
config = conf config = conf
socket.connect(config.port) socket.connect(config.port)
process.on('SIGINT', () => {
socket.write('QUIT\r\n')
process.exit()
})
}) })
module.exports.events = emitter module.exports.events = emitter