|
|
@@ -215,9 +215,6 @@ class IRCClientProtocol(asyncio.Protocol): |
|
|
|
nickb = self.config.irc.nick.encode('utf-8') |
|
|
|
self.send(b'NICK ' + nickb) |
|
|
|
self.send(b'USER ' + nickb + b' ' + nickb + b' ' + nickb + b' :' + self.config.irc.real.encode('utf-8')) |
|
|
|
self.send(b'JOIN ' + ','.join(self.channels).encode('utf-8')) #TODO: Split if too long |
|
|
|
asyncio.create_task(self.send_messages()) |
|
|
|
asyncio.create_task(self.confirm_messages()) |
|
|
|
|
|
|
|
def update_channels(self, channels: set): |
|
|
|
channelsToPart = self.channels - channels |
|
|
@@ -310,6 +307,11 @@ class IRCClientProtocol(asyncio.Protocol): |
|
|
|
self.send(b'PONG ' + message[5:]) |
|
|
|
elif message.startswith(b'PONG '): |
|
|
|
self.pongReceivedEvent.set() |
|
|
|
elif message.startswith(b'001 '): |
|
|
|
# Connection registered |
|
|
|
self.send(b'JOIN ' + ','.join(self.channels).encode('utf-8')) #TODO: Split if too long |
|
|
|
asyncio.create_task(self.send_messages()) |
|
|
|
asyncio.create_task(self.confirm_messages()) |
|
|
|
|
|
|
|
def connection_lost(self, exc): |
|
|
|
logging.info('The server closed the connection') |
|
|
|