[change] Added celerybeat task for creating mesh topology

README.rst

@@ -478,6 +478,28 @@ In order to use this module simply add
         'rest_framework',
     ]
 
+If you have enabled WiFI Mesh integration, you will also need to update the
+``CELERY_BEAT_SCHEDULE`` as follow:
+
+.. code-block:: python
+
+    CELERY_BEAT_SCHEDULE = {
+        'create_mesh_topology': {
+            # This task generates the mesh topology from monitoring data
+            'task': 'openwisp_network_topology.integrations.device.tasks.create_mesh_topology',
+            # Execute this task every 5 minutes
+            'schedule': timedelta(minutes=5),
+            # List of organization UUIDs. The mesh topology will be
+            # created only for devices belonging these organizations.
+            'args': (
+                [
+                    '4e002f97-eb01-4371-a4a8-857faa22fe5c',
+                    'be88d4c4-599a-4ca2-a1c0-3839b4fdc315'
+                ],
+            ),
+        },
+    }
+
 If you are enabling this integration on a pre-existing system, use the
 `create_device_nodes <#create-device-nodes>`_ management command to create
 the relationship between devices and nodes.

openwisp_network_topology/integrations/device/apps.py

@@ -5,10 +5,8 @@
 from django.db import transaction
 from django.db.models.signals import post_save
 from django.utils.translation import gettext_lazy as _
-from openwisp_monitoring.device.signals import device_metrics_received
 
 from ...utils import link_status_changed
-from . import settings as app_settings
 from .tasks import create_device_node_relation, trigger_device_updates
 
 
@@ -33,14 +31,6 @@ def connect_signals(self):
             sender=Link,
             dispatch_uid='controller_integration_link_status_chaged',
         )
-        if app_settings.WIFI_MESH_INTEGRATION:
-            WifiMesh = swapper.load_model('topology_device', 'WifiMesh')
-            DeviceData = swapper.load_model('device_monitoring', 'DeviceData')
-            device_metrics_received.connect(
-                WifiMesh.create_wifi_mesh_topology_receiver,
-                sender=DeviceData,
-                dispatch_uid='create_wifi_mesh_topology',
-            )
 
     @classmethod
     def create_device_rel(cls, instance, created, **kwargs):