From 919e5ff90392a1cb8233567d07ff4f45efd2b52c Mon Sep 17 00:00:00 2001
From: Luna Mendes <lnmds@protonmail.com>
Date: Thu, 11 Oct 2018 23:09:27 -0300
Subject: [PATCH] blueprints.channels: fix close_channel for dms

 - dispatcher: add sub() and unsub() alias methods
---
 litecord/blueprints/channels.py | 10 +++++++---
 litecord/dispatcher.py          |  6 ++++++
 2 files changed, 13 insertions(+), 3 deletions(-)

diff --git a/litecord/blueprints/channels.py b/litecord/blueprints/channels.py
index 3faa800..e151391 100644
--- a/litecord/blueprints/channels.py
+++ b/litecord/blueprints/channels.py
@@ -195,12 +195,16 @@ async def close_channel(channel_id):
         # the request via removing the link between them and
         # the channel on dm_channel_state
         await app.db.execute("""
-        DELETE FROM dm_channel_state (user_id, dm_id)
-        VALUES ($1, $2)
+        DELETE FROM dm_channel_state
+        WHERE user_id = $1 AND dm_id = $2
         """, user_id, channel_id)
 
+        # unsubscribe
+        await app.dispatcher.unsub('channel', channel_id, user_id)
+
         # nothing happens to the other party of the dm channel
-        await app.dispacher.dispatch_user(user_id, 'CHANNEL_DELETE', chan)
+        await app.dispatcher.dispatch_user(user_id, 'CHANNEL_DELETE', chan)
+
         return jsonify(chan)
 
     if ctype == ChannelType.GROUP_DM:
diff --git a/litecord/dispatcher.py b/litecord/dispatcher.py
index 1067df6..f821f01 100644
--- a/litecord/dispatcher.py
+++ b/litecord/dispatcher.py
@@ -46,6 +46,12 @@ class EventDispatcher:
                   backend, key, identifier, backend)
         return await self.action(backend, 'unsub', key, identifier)
 
+    async def sub(self, backend, key, identifier):
+        return await self.subscribe(backend, key, identifier)
+
+    async def unsub(self, backend, key, identifier):
+        return await self.unsubscribe(backend, key, identifier)
+
     async def dispatch(self, backend_str: str, key: Any, *args, **kwargs):
         """Dispatch an event to the backend.