interim commit of chatroom example

examples/chatrooms/backend/models.py

@@ -13,6 +13,10 @@
 ACCESS_PROTECTED = 20
 ACCESS_PRIVATE = 30
 
+STATUS_AVAILABLE = 10
+STATUS_AWAY = 20
+STATUS_OFFLINE = 30
+
 
 class BaseModel(Model, MongoCollectionMixin):
     _id = ObjectIdField(primary_key=True)
@@ -29,8 +33,10 @@ class User(BaseModel):
     username = StringField(required=True)
     first_name = StringField()
     last_name = StringField()
+    display_name = StringField()
     avatar = URLField()
     active = BooleanField(default=True)
+    status = IntegerField(default=STATUS_OFFLINE, choices=[STATUS_AVAILABLE, STATUS_AWAY, STATUS_OFFLINE])
 
     class Meta:
         name = 'users'
@@ -46,6 +52,7 @@ class Meta:
 class Room(BaseModel):
     name = StringField(primary_key=True)
     title = StringField()
+    default = BooleanField(default=False)  # new users will be added to this channel as they join in
     active = BooleanField(default=True)
     access = IntegerField(default=ACCESS_PUBLIC, choices=[ACCESS_PUBLIC, ACCESS_PROTECTED, ACCESS_PRIVATE])
     owner = DBRefField(User, required=True)

examples/chatrooms/backend/resources.py

@@ -21,7 +21,8 @@ async def is_authenticated(self, request):
         if 'user' in request:
             return True
         if 'Authorization' in request.headers:
-            username = request.headers['Authorization']
+            bearer, username = request.headers['Authorization'].split(' ')
+
             user = await User.find_one(request.app.db, {'username': username})
             if user:
                 request['user'] = user

examples/chatrooms/backend/routes.py

@@ -6,9 +6,10 @@
 from resources import *
 
 # create a resource router for this app
-chatrooms_router = Router(name='api/chatrooms')
+chatrooms_router = Router(name='api/team')
 chatrooms_router.register(UserResource, 'user')
-chatrooms_router.register(RoomResource, 'room')
+chatrooms_router.register(RoomResource, 'channel')
+chatrooms_router.register(RoomResource, 'entry')
 
 
 

examples/chatrooms/backend/websocket_sanic.py

@@ -26,7 +26,7 @@ def unsubscribe(request, ws):
 async def resource_event_websocket(request, ws):
     waiting = True
 
-    subscribe(request, ws)
+    # subscribe(request, ws)
     while waiting:
         # data was received from the client
         data = await ws.recv()

examples/chatrooms/web-client/.gitignore

@@ -0,0 +1,21 @@
+# See https://help.github.com/ignore-files/ for more about ignoring files.
+
+# dependencies
+/node_modules
+
+# testing
+/coverage
+
+# production
+/build
+
+# misc
+.DS_Store
+.env.local
+.env.development.local
+.env.test.local
+.env.production.local
+
+npm-debug.log*
+yarn-debug.log*
+yarn-error.log*