Method save_fsub_msg

plugins/fsub.py:31–36

(self, user_id: int, message_id: int)

        await self.fsub_cache.drop()

    async def save_fsub_msg(self, user_id: int, message_id: int):
        await self.fsub_cache.update_one(
            {"user_id": user_id},
            {"$set": {"message_id": message_id, "created_at": datetime.datetime.utcnow()}},
            upsert=True
        )

    async def get_fsub_msg(self, user_id: int):
        doc = await self.fsub_cache.find_one({"user_id": user_id})