Implemented mongodb schema for messaging #48

[HlibSokol]

• installed mongoengine and configured docker-compose.yml and settings.py for mongoDB usage
• modified routing.py for better use and added path for rooms; updated requirements.txt
• added specific models_mongo.py with Room and Message models
• created consumers.py with configured ChatConsumer to manage WebSocket connections and messages
• created middleware.py with JwtAuthMiddleware to manage if users that are connecting to rooms via WebSocket are authenticated (registered and logged in==obtained token)
• updated asgi.py with JwtAuthMiddleware to validate ?token= on connect

tested in postman:

checking history using mongoDB extension in VisualStudio:

[VovaD199]

Please check if Docker is working properly.
Replacement: $$ is only escaped in bash, but here it is necessary for Docker to interpret environment variables correctly. That is, leave one $.

[VovaD199]

Add healthcheck for MongoDB (optional)
healthcheck:
test: echo 'db.runCommand("ping").ok' | mongosh localhost:27017/test --quiet
interval: 10s
retries: 5

[VovaD199]

Missing await in room.save() and Message(...).save()
MongoEngine .save() is not an asynchronous function. In asynchronous code, this can block the event loop.

Solution: move from async def to a separate sync_to_async block:

from asgiref.sync import sync_to_async

@sync_to_async
def save_room_and_message(room, user_pk, text):
room.save()
Message(
room=room,
sender_id=user_pk,
text=text,
timestamp=timezone.now()
).save()

[VovaD199]

And in receive():
await save_room_and_message(room, user_pk, text)

[VovaD199]

No channel_layer check
Although rare, self.channel_layer can be None if Redis (or another backend) is not configured.
if not self.channel_layer:
await self.send(text_data="No channel layer configured.")
return

[VovaD199]

Repetitive code in Room logic can be moved to a helper function for cleanliness:
@sync_to_async
def get_or_update_room(room_id, user_pk):
room = Room.objects(room_id=room_id).first()
if not room:
room = Room(room_id=room_id, participants=[user_pk])
else:
if user_pk not in room.participants:
room.participants.append(user_pk)
room.updated_at = timezone.now()
room.save()
return room

[VovaD199]

Adding auto_now for updated_at makes your logic store updated_at manually, but it's easy to forget. It's worth creating a "hook" to make this happen automatically.
def save(self, *args, **kwargs):
self.updated_at = timezone.now()
return super().save(*args, **kwargs)

[VovaD199]

Use ReferenceField for sender_id if users are stored in Mongo — it's worth:
sender = me.ReferenceField(User, required=True)

[VovaD199]

This is good, but you can also add something "-" to quickly sort backwards in time:
{"fields": ["room", "-timestamp"]}

[VovaD199]

If there is default=timezone.now, then required=True is not required.

[VovaD199]

AuthMiddlewareStack already tries to authenticate via session or cookie, but if you are working exclusively with JWT via query param, then AuthMiddlewareStack may be unnecessary.

If you are definitely not using cookie-based login:

"websocket": JwtAuthMiddleware(
URLRouter(websocket_urlpatterns)
)
This will speed up the authorization of WebSocket requests and reduce unnecessary load.