Channel support.

src/snek/app.py

@@ -56,6 +56,7 @@ from snek.view.upload import UploadView
 from snek.view.user import UserView
 from snek.view.web import WebView
 from snek.view.channel import ChannelAttachmentView
+from snek.view.channel import ChannelView
 from snek.view.settings.containers import ContainersIndexView, ContainersCreateView, ContainersUpdateView, ContainersDeleteView
 from snek.webdav import WebdavApplication
 from snek.sgit import GitApplication
@@ -221,6 +222,7 @@ class Application(BaseApplication):
         self.router.add_get("/http-get", self.handle_http_get)
         self.router.add_get("/http-photo", self.handle_http_photo)
         self.router.add_get("/rpc.ws", RPCView)
+        self.router.add_get("/c/{channel:.*}", ChannelView)
         self.router.add_view("/channel/{channel_uid}/attachment.bin",ChannelAttachmentView)
         self.router.add_view("/channel/attachment/{relative_url:.*}",ChannelAttachmentView)
         self.router.add_view("/channel/{channel}.html", WebView)
@@ -277,11 +279,14 @@ class Application(BaseApplication):
             async for subscribed_channel in self.services.channel_member.find(
                 user_uid=request.session.get("uid"), deleted_at=None, is_banned=False
             ):
+                
+                parent_object = await subscribed_channel.get_channel()
+                
                 item = {}
                 other_user = await self.services.channel_member.get_other_dm_user(
                     subscribed_channel["channel_uid"], request.session.get("uid")
                 )
-                parent_object = await subscribed_channel.get_channel()
+
                 last_message = await parent_object.get_last_message()
                 color = None
                 if last_message:

src/snek/view/channel.py

@@ -137,3 +137,24 @@ class ChannelAttachmentView(BaseView):
                 "channel_uid": channel_uid,
             }
         )
+
+class ChannelView(BaseView):
+    async def get(self):
+        channel_name = self.request.match_info.get("channel")
+        if(channel_name is None):
+            return web.HTTPNotFound()
+        channel = await self.services.channel.get(label="#" + channel_name)
+        if(channel is None):
+            channel = await self.services.channel.get(label=channel_name)
+        channel = await self.services.channel.get(channel_name)
+        if(channel is None):
+            channel = await self.services.channel.get(label=channel_name)
+        if(channel is None):
+            user = await self.services.user.get(uid=self.session.get("uid")) 
+            is_listed = self.request.query.get("listed", False) == "true"
+            is_private = self.request.query.get("private", False) == "true"
+            channel = await self.services.channel.create(label=channel_name,created_by_uid=user['uid'],description="No description provided.",tag="user",is_private=is_private,is_listed=is_listed)
+            channel_member = await self.services.channel_member.create(channel_uid=channel['uid'],user_uid=user['uid'],is_moderator=True,is_read_only=False,is_muted=False,is_banned=False)
+   
+        return web.HTTPFound("/channel/{}.html".format(channel["uid"]))
+