monitor support fixes

pydle/features/ircv3/monitor.py

@@ -1,9 +1,9 @@
 ## monitor.py
 # Online status monitoring support.
-from . import cap
+from .. import isupport
 
 
-class MonitoringSupport(cap.CapabilityNegotiationSupport):
+class MonitoringSupport(isupport.ISUPPORTSupport):
     """ Support for monitoring the online/offline status of certain targets. """
 
     ## Internals.
@@ -36,19 +36,19 @@ def _destroy_user(self, nickname, channel=None, monitor_override=False):
 
     ## API.
 
-    def monitor(self, target):
+    async def monitor(self, target):
         """ Start monitoring the online status of a user. Returns whether or not the server supports monitoring. """
-        if 'monitor-notify' in self._capabilities and not self.is_monitoring(target):
-            yield from self.rawmsg('MONITOR', '+', target)
+        if 'MONITOR' in self._isupport and not self.is_monitoring(target):
+            await self.rawmsg('MONITOR', '+', target)
             self._monitoring.add(target)
             return True
         else:
             return False
 
-    def unmonitor(self, target):
+    async def unmonitor(self, target):
         """ Stop monitoring the online status of a user. Returns whether or not the server supports monitoring. """
-        if 'monitor-notify' in self._capabilities and self.is_monitoring(target):
-            yield from self.rawmsg('MONITOR', '-', target)
+        if 'MONITOR' in self._isupport and self.is_monitoring(target):
+            await self.rawmsg('MONITOR', '-', target)
             self._monitoring.remove(target)
             return True
         else:
@@ -77,23 +77,33 @@ async def on_capability_monitor_notify_available(self, value):
 
     async def on_raw_730(self, message):
         """ Someone we are monitoring just came online. """
-        for nick in message.params[1].split(','):
-            self._create_user(nick)
+        for target in message.params[1].split(','):
+            nickname, metadata = self._parse_user(target)
+            self._sync_user(nickname, metadata)
             await self.on_user_online(nickname)
 
     async def on_raw_731(self, message):
         """ Someone we are monitoring got offline. """
-        for nick in message.params[1].split(','):
-            self._destroy_user(nick, monitor_override=True)
+        for target in message.params[1].split(','):
+            nickname, metadata = self._parse_user(target)
+            # May be monitoring a user we haven't seen yet
+            if nickname in self.users:
+                self._destroy_user(nickname, monitor_override=True)
             await self.on_user_offline(nickname)
 
     async def on_raw_732(self, message):
         """ List of users we're monitoring. """
-        self._monitoring.update(message.params[1].split(','))
+        for target in message.params[1].split(','):
+            nickname, metadata = self._parse_user(target)
+            self._monitoring.add(nickname)
 
-    on_raw_733 = cap.CapabilityNegotiationSupport._ignored  # End of MONITOR list.
+    on_raw_733 = isupport.ISUPPORTSupport._ignored  # End of MONITOR list.
 
     async def on_raw_734(self, message):
         """ Monitor list is full, can't add target. """
         # Remove from monitoring list, not much else we can do.
-        self._monitoring.difference_update(message.params[1].split(','))
+        to_remove = set()
+        for target in message.params[1].split(','):
+            nickname, metadata = self._parse_user(target)
+            to_remove.add(nickname)
+        self._monitoring.difference_update(to_remove)

pydle/features/isupport.py

@@ -179,6 +179,9 @@ async def on_isupport_modes(self, value):
         """ Maximum number of variable modes to change in a single MODE command. """
         self._mode_limit = int(value)
 
+    async def on_isupport_monitor(self, value):
+        self._monitor_limit = int(value)
+
     async def on_isupport_namesx(self, value):
         """ Let the server know we do in fact support NAMESX. Effectively the same as CAP multi-prefix. """
         await self.rawmsg('PROTOCTL', 'NAMESX')