converted all send_mule calls to omq_global.send_mule calls

Author: dr7ana

sogs/model/bot.py

@@ -5,7 +5,7 @@
 from ..web import app
 from .exc import BadPermission, PostRateLimited
 from .. import utils
-from ..omq import send_mule
+from ..omq import omq_global
 from .user import User
 from .room import Room
 from .message import Message
@@ -263,5 +263,5 @@ def receive_message(
                 if whisper_to:
                     msg['whisper_to'] = whisper_to.session_id
 
-        send_mule("message_posted", msg["id"])
+        omq_global.send_mule("message_posted", msg["id"])
         return msg

sogs/model/manager.py

@@ -5,8 +5,8 @@
 from ..web import app
 from .exc import BadPermission, PostRateLimited
 from .. import utils
-from ..omq import send_mule
 from .user import User
+from ..omq import omq_global
 from .bot import Bot
 from .room import Room
 from .message import Message
@@ -296,5 +296,5 @@ def receive_message(
                 priority,
             """
 
-        send_mule("message_posted", msg["id"])
+        omq_global.send_mule("message_posted", msg["id"])
         return msg

sogs/model/room.py

@@ -1,7 +1,7 @@
 from .. import config, crypto, db, utils, session_pb2 as protobuf
 from ..db import query
 from ..hashing import blake2b
-from ..omq import send_mule
+from ..omq import omq_global
 from ..web import app
 from .user import User
 from .file import File
@@ -727,7 +727,7 @@ def edit_post(self, user: User, msg_id: int, data: bytes, sig: bytes, *, files:
                 # If the edit includes new attachments then own them:
                 self._own_files(msg_id, files, user)
 
-        send_mule("message_edited", msg_id)
+        omq_global.send_mule("message_edited", msg_id)
 
     def delete_posts(self, message_ids: List[int], deleter: User):
         """