SpamShield: Do not raise error when api is down

Avoid logging flood when CAS API is down
- Lower on_message priority of Users make sure that new user are saved before running other listener

This make sure that new user are saved before running other listener

anjani/plugins/spam_shield.py

@@ -181,14 +181,16 @@ async def cas_check(self, user: User) -> Optional[str]:
                     return None
             except (ContentTypeError, JSONDecodeError):
                 if retry == 5:
-                    raise
+                    self.log.debug("Error parsing CAS response")
+                    return None
 
                 retry += 1
                 await asyncio.sleep(1)
                 self.log.debug("Invalid data received from CAS server, retrying...")
             except ClientOSError:
                 if retry == 10:
-                    raise
+                    self.log.debug("Error connecting to CAS API")
+                    return None
 
                 retry += 1
                 await asyncio.sleep(0.5)

anjani/plugins/users.py

@@ -25,7 +25,7 @@
 from pyrogram.errors import BadRequest, ChannelInvalid, PeerIdInvalid
 from pyrogram.types import CallbackQuery, Chat, ChatPreview, Message, User
 
-from anjani import command, plugin, util
+from anjani import command, listener, plugin, util
 
 from .spam_prediction import get_trust
 
@@ -113,6 +113,7 @@ async def on_callback_query(self, query: CallbackQuery) -> None:
 
         await self.users_db.update_one({"_id": user.id}, {"$set": set_content})
 
+    @listener.priority(50)
     async def on_message(self, message: Message) -> None:
         """Incoming message handler."""
         chat = message.chat