Adding ChatEvent

rustplus/__init__.py

@@ -5,10 +5,10 @@
 from .api import RustSocket
 from .commands import CommandOptions, Command
 from .exceptions import *
-from .api.structures import EntityEvent, TeamEvent
+from .api.structures import EntityEvent, TeamEvent, ChatEvent
 from .utils import entity_type_to_string
 
 __name__ = "rustplus"
 __author__ = "olijefferson"
-__version__ = "5.1.1"
+__version__ = "5.1.2"
 __support__ = "Discord: https://discord.gg/nQqJe8qvP8"

rustplus/api/base_rust_api.py

@@ -118,6 +118,13 @@ def team_event(self, coro) -> None:
 
         self.remote.event_handler.register_event("team_changed", (coro, asyncio.get_event_loop()))
 
+    def chat_event(self, coro) -> None:
+        """
+        A Decorator to register an event listener for chat messages
+        """
+
+        self.remote.event_handler.register_event("chat_message", (coro, asyncio.get_event_loop()))
+
     async def hang(self) -> None:
         """This Will permanently put your script into a state of 'hanging' Cannot be Undone. Only do this in scripts using commands"""
 

rustplus/api/remote/event_handler.py

@@ -1,6 +1,6 @@
 import asyncio
 
-from ..structures import EntityEvent, TeamEvent
+from ..structures import EntityEvent, TeamEvent, ChatEvent
 
 class EventHandler:
 
@@ -29,3 +29,9 @@ def run_team_event(self, app_message) -> None:
         if hasattr(self, "team_changed"):
             coro, loop = getattr(self, "team_changed")
             self._schedule_event(loop, coro, TeamEvent(app_message))
+
+    def run_chat_event(self, app_message) -> None:
+
+        if hasattr(self, "chat_message"):
+            coro, loop = getattr(self, "chat_message")
+            self._schedule_event(loop, coro, ChatEvent(app_message))

rustplus/api/remote/rustws.py

@@ -69,7 +69,7 @@ def received_message(self, message):
             self.remote.event_handler.run_team_event(app_message)
 
         elif self.is_message(app_message):
-            return 
+            self.remote.event_handler.run_chat_event(app_message) 
 
         else:
             self.responses[app_message.response.seq] = app_message

rustplus/api/structures/__init__.py

@@ -7,4 +7,4 @@
 from .rust_entity_info import RustEntityInfo
 from .rust_contents import RustContents
 from .rust_item import RustItem
-from .event import EntityEvent, TeamEvent
+from .event import EntityEvent, TeamEvent, ChatEvent

rustplus/api/structures/event.py

@@ -1,5 +1,6 @@
 from typing import List
 from .rust_team_info import RustTeamInfo
+from .rust_chat_message import RustChatMessage
 
 class EntityEvent:
 
@@ -28,3 +29,9 @@ def __init__(self, app_message) -> None:
 
         self.playerId : int = app_message.broadcast.teamChanged.playerId
         self.teamInfo = RustTeamInfo(app_message.broadcast.teamChanged.teamInfo)
+
+class ChatEvent:
+
+    def __init__(self, app_message) -> None:
+
+        self.message = RustChatMessage(app_message.broadcast.teamMessage.message)