[qa] Run openwisp-qa-format

Applied openwisp-qa-format only. No functional changes.

Author: Baboux98

README.rst

@@ -86,6 +86,7 @@ Documentation
 - `Usage documentation <https://openwisp.io/docs/stable/monitoring/>`_
 - `Developer documentation
   <https://openwisp.io/docs/stable/monitoring/developer/>`_
+
 ------------
 
 .. contents:: **Table of Contents**:
@@ -261,7 +262,7 @@ Run the docker container:
 Setup (integrate in an existing Django project)
 ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
 
-Follow the setup instructions of `openwisp-controller
+Follow the setup instructions of `openwisp-controller repository
 <https://github.com/openwisp/openwisp-controller>`_, then add the settings described below.
 
 .. code-block:: python
@@ -885,20 +886,21 @@ Example taken from the default configuration of the traffic chart:
 
 .. code-block:: python
 
-    'traffic': {
-        # other configurations for this chart
-
-        # traffic measured in 'B' (bytes)
-        # unit B, KB, MB, GB, TB
-        'unit': 'adaptive_prefix+B',
-    },
+    CHARTS = {
+        'traffic': {
+            # other configurations for this chart
 
-    'bandwidth': {
-        # adaptive unit for bandwidth related charts
-        # bandwidth measured in 'bps'(bits/sec)
-        # unit bps, Kbps, Mbps, Gbps, Tbps
-        'unit': 'adaptive_prefix+bps',
-    },
+            # traffic measured in 'B' (bytes)
+            # unit B, KB, MB, GB, TB
+            'unit': 'adaptive_prefix+B',
+        },
+        'bandwidth': {
+            # adaptive unit for bandwidth related charts
+            # bandwidth measured in 'bps' (bits/sec)
+            # unit bps, Kbps, Mbps, Gbps, Tbps
+            'unit': 'adaptive_prefix+bps',
+        },
+    }
 
 Monitoring WiFi Sessions
 ------------------------

openwisp_monitoring/db/__init__.py

@@ -2,4 +2,4 @@
 
 chart_query = timeseries_db.queries.chart_query
 
-__all__ = ['timeseries_db', 'chart_query']
+__all__ = ["timeseries_db", "chart_query"]

openwisp_monitoring/db/backends/__init__.py

@@ -10,16 +10,16 @@
 TIMESERIES_DB = getattr(settings, "TIMESERIES_DATABASE", None)
 if not TIMESERIES_DB:
     TIMESERIES_DB = {
-        'BACKEND': 'openwisp_monitoring.db.backends.influxdb',
-        'USER': getattr(settings, 'INFLUXDB_USER', 'openwisp'),
-        'PASSWORD': getattr(settings, 'INFLUXDB_PASSWORD', 'openwisp'),
-        'NAME': getattr(settings, 'INFLUXDB_DATABASE', 'openwisp2'),
-        'HOST': getattr(settings, 'INFLUXDB_HOST', 'localhost'),
-        'PORT': getattr(settings, 'INFLUXDB_PORT', '8086'),
+        "BACKEND": "openwisp_monitoring.db.backends.influxdb",
+        "USER": getattr(settings, "INFLUXDB_USER", "openwisp"),
+        "PASSWORD": getattr(settings, "INFLUXDB_PASSWORD", "openwisp"),
+        "NAME": getattr(settings, "INFLUXDB_DATABASE", "openwisp2"),
+        "HOST": getattr(settings, "INFLUXDB_HOST", "localhost"),
+        "PORT": getattr(settings, "INFLUXDB_PORT", "8086"),
     }
     logger.warning(
-        'The previous method to define Timeseries Database has been deprecated. Please refer to the docs:\n'
-        'https://github.com/openwisp/openwisp-monitoring#setup-integrate-in-an-existing-django-project'
+        "The previous method to define Timeseries Database has been deprecated. Please refer to the docs:\n"
+        "https://github.com/openwisp/openwisp-monitoring#setup-integrate-in-an-existing-django-project"
     )
 
 
@@ -31,17 +31,17 @@ def load_backend_module(backend_name=TIMESERIES_DB["BACKEND"], module=None):
     well defined.
     """
     try:
-        assert 'BACKEND' in TIMESERIES_DB, 'BACKEND'
-        if 'BACKEND' in TIMESERIES_DB and '2' in TIMESERIES_DB['BACKEND']:
+        assert "BACKEND" in TIMESERIES_DB, "BACKEND"
+        if "BACKEND" in TIMESERIES_DB and "2" in TIMESERIES_DB["BACKEND"]:
             # InfluxDB 2.x specific checks
-            assert 'TOKEN' in TIMESERIES_DB, 'TOKEN'
-            assert 'ORG' in TIMESERIES_DB, 'ORG'
-            assert 'BUCKET' in TIMESERIES_DB, 'BUCKET'
+            assert "TOKEN" in TIMESERIES_DB, "TOKEN"
+            assert "ORG" in TIMESERIES_DB, "ORG"
+            assert "BUCKET" in TIMESERIES_DB, "BUCKET"
         else:
             # InfluxDB 1.x specific checks
-            assert 'USER' in TIMESERIES_DB, 'USER'
-            assert 'PASSWORD' in TIMESERIES_DB, 'PASSWORD'
-            assert 'NAME' in TIMESERIES_DB, 'NAME'
+            assert "USER" in TIMESERIES_DB, "USER"
+            assert "PASSWORD" in TIMESERIES_DB, "PASSWORD"
+            assert "NAME" in TIMESERIES_DB, "NAME"
         if module:
             return import_module(f"{backend_name}.{module}")
         else:
@@ -55,7 +55,7 @@ def load_backend_module(backend_name=TIMESERIES_DB["BACKEND"], module=None):
     except ImportError as e:
         # The database backend wasn't found. Display a helpful error message
         # listing all built-in database backends.
-        builtin_backends = ['influxdb', 'influxdb2']
+        builtin_backends = ["influxdb", "influxdb2"]
         if backend_name not in [
             f"openwisp_monitoring.db.backends.{b}" for b in builtin_backends
         ]:
@@ -66,5 +66,5 @@ def load_backend_module(backend_name=TIMESERIES_DB["BACKEND"], module=None):
             ) from e
 
 
-timeseries_db = load_backend_module(module='client').DatabaseClient()
-timeseries_db.queries = load_backend_module(module='queries')
+timeseries_db = load_backend_module(module="client").DatabaseClient()
+timeseries_db.queries = load_backend_module(module="queries")

openwisp_monitoring/db/backends/influxdb/client.py

@@ -66,7 +66,7 @@ class DatabaseClient(object):
     ]
 
     def __init__(self, db_name=None):
-        self.db_name = db_name or TIMESERIES_DB['NAME']
+        self.db_name = db_name or TIMESERIES_DB["NAME"]
         self.client_error = InfluxDBClientError
 
     @retry
@@ -346,7 +346,7 @@ def read(self, key, fields, tags, **kwargs):
             q = f"{q} LIMIT {limit}"
         return list(self.query(q, precision=precision).get_points())
 
-    def get_list_query(self, query, precision='s', **kwargs):
+    def get_list_query(self, query, precision="s", **kwargs):
         result = self.query(query, precision=precision)
         if not len(result.keys()) or result.keys()[0][1] is None:
             return list(result.get_points())
@@ -533,7 +533,7 @@ def _get_top_fields(
         Returns top fields if ``get_fields`` set to ``True`` (default)
         else it returns points containing the top fields.
         """
-        q = default_query.replace('{field_name}', '{fields}')
+        q = default_query.replace("{field_name}", "{fields}")
         q = self.get_query(
             query=q,
             params=params,
@@ -554,7 +554,7 @@ def _get_top_fields(
         keys = list(sorted_dict.keys())
         keys.reverse()
         top = keys[0:number]
-        top_fields = [item.replace('sum_', '') for item in top]
+        top_fields = [item.replace("sum_", "") for item in top]
         if get_fields:
             return top_fields
         query = self.get_query(
@@ -568,15 +568,15 @@ def _get_top_fields(
             timezone=timezone,
         )
         return self.get_list_query(query)
-    
+
     def default_chart_query(self, tags):
         q = "SELECT {field_name} FROM {key} WHERE time >= '{time}'"
         if tags:
             q += " AND content_type = '{content_type}' AND object_id = '{object_id}'"
         return q
 
     def _device_data(self, key, tags, rp, **kwargs):
-        """ returns last snapshot of ``device_data`` """
+        """returns last snapshot of ``device_data``"""
         query = (
             f"SELECT data FROM {rp}.{key} WHERE pk = '{tags['pk']}' "
             "ORDER BY time DESC LIMIT 1"