[fix] Add transaction on commit

Author: dee077

openwisp_controller/geo/apps.py

@@ -4,6 +4,7 @@
 import swapper
 from asgiref.sync import async_to_sync
 from django.conf import settings
+from django.db import transaction
 from django.db.models import Case, Count, Sum, When
 from django.db.models.signals import post_save
 from django.utils.translation import gettext_lazy as _
@@ -131,26 +132,27 @@ def _load_receivers(self):
     def _location_post_save_websocket_receiver(
         self, sender, instance, created, **kwargs
     ):
-        """
-        Sends location updates over websockets to organization specific channel group.
-        """
         if created or not instance.geometry:
             return
-        channel_layer = channels.layers.get_channel_layer()
-        async_to_sync(channel_layer.group_send)(
-            f"loci.mobile-location.organization.{instance.organization_id}",
-            {
-                "type": "send_message",
-                "message": {
-                    "id": str(instance.pk),
-                    "geometry": json.loads(instance.geometry.geojson),
-                    "address": instance.address,
-                    "name": instance.name,
-                    "type": instance.type,
-                    "is_mobile": instance.is_mobile,
+
+        def _send():
+            channel_layer = channels.layers.get_channel_layer()
+            async_to_sync(channel_layer.group_send)(
+                f"loci.mobile-location.organization.{instance.organization_id}",
+                {
+                    "type": "send_message",
+                    "message": {
+                        "id": str(instance.pk),
+                        "geometry": json.loads(instance.geometry.geojson),
+                        "address": instance.address,
+                        "name": instance.name,
+                        "type": instance.type,
+                        "is_mobile": instance.is_mobile,
+                    },
                 },
-            },
-        )
+            )
+
+        transaction.on_commit(_send)
 
 
 del LociConfig