(self, user_id: int, channel_id: int)
| 14 | self.fsub_cache = db["fsub_cache"] |
| 15 | |
| 16 | async def add_join_req(self, user_id: int, channel_id: int): |
| 17 | await self.join_requests.update_one( |
| 18 | {"user_id": user_id}, |
| 19 | {"$addToSet": {"channels": channel_id}, "$set": {"created_at": datetime.datetime.utcnow()}}, |
| 20 | upsert=True |
| 21 | ) |
| 22 | |
| 23 | async def has_joined_channel(self, user_id: int, channel_id: int) -> bool: |
| 24 | doc = await self.join_requests.find_one({"user_id": user_id}) |