diff --git a/src/snek/view/rpc.py b/src/snek/view/rpc.py
index be1a743..eefc4f9 100644
--- a/src/snek/view/rpc.py
+++ b/src/snek/view/rpc.py
@@ -141,10 +141,10 @@ class RPCView(BaseView):
         
         ws = web.WebSocketResponse()
         await ws.prepare(self.request)
-        #if self.request.session.get("logged_in") is True:
-            #await self.services.socket.add(ws)
-            #async for subscription in self.services.channel_member.find(user_uid=self.request.session.get("uid"),deleted_at=None,is_banned=False):
-                #await self.services.socket.subscribe(ws,subscription["channel_uid"])
+        if self.request.session.get("logged_in") is True:
+            await self.services.socket.add(ws)
+            async for subscription in self.services.channel_member.find(user_uid=self.request.session.get("uid"),deleted_at=None,is_banned=False):
+                await self.services.socket.subscribe(ws,subscription["channel_uid"])
             #print("Subscribed for: ", subscription["label"],flush=True)
         rpc = RPCView.RPCApi(self,ws)
         async for msg in ws: