Command /m [name] to mark messages as read

/m marks all messages as read, /m <name> marks all messages in group <name> as
read.

TODO.rst

@@ -7,5 +7,4 @@ TODO List
 - Colorize the output
 - Group/topic autocompletion for ``/t``
 - ``@username`` autocompletion
-- A command to mark messages in topics/groups as read
 

convoread/console.py

@@ -148,12 +148,29 @@ def cmd_t(self, topic_id=None):
             output(_format_message(message))
 
 
+    def cmd_m(self, group_slug=None):
+        try:
+            if group_slug:
+                groups = [g for g in self.convore.get_groups().values()
+                            if g.get('slug') == group_slug]
+                if not groups:
+                    error('group "{0}" not found'.format(group_slug))
+                    return
+                group = groups[0]
+                self.convore.mark_group_read(group.get('id'))
+            else:
+                self.convore.mark_all_read()
+        except NetworkError, e:
+            error(unicode(e))
+
+
     def cmd_help(self):
         output('''\
 commands:
 
   /ts [name]  list unread topics or topics in group <name>
   /t [num]    set the posting topic to <num> and list recent messages
+  /m [name]   mark messages as read (all or in group <name>)
   /help       show help on commands
   /q          quit
   <text>      post a new message to the selected topic

convoread/convore.py

@@ -119,6 +119,23 @@ def close(self):
         self._live.close()
 
 
+    @synchronized
+    def mark_all_read(self):
+        url = '/api/account/mark_read.json'
+        self._connection.request('POST', url)
+        for topic in self.get_topics().values():
+            topic['unread'] = 0
+
+
+    @synchronized
+    def mark_group_read(self, group_id):
+        url = '/api/groups/{0}/mark_read.json'.format(group_id)
+        self._connection.request('POST', url)
+        for topic in self.get_topics().values():
+            if topic.get('group') == group_id:
+                topic['unread'] = 0
+
+
     @synchronized
     def _handle_live_update(self, message):
         if message.get('kind') != 'message':