Skipping tests if no config file present

Author: lewis-chambers

src/iotdevicesimulator/__assets__/configs.cfg

@@ -0,0 +1,12 @@
+oracle: {
+    dsn: "wldbase:1521/wla"
+    user: "lewcha"
+    password: "Lucid+Barrel8Valley"
+}
+iot_core: {
+    endpoint: "a10mem0twl4qxt-ats.iot.eu-west-2.amazonaws.com"
+    port: 8883
+    cert_path: "C:/Users/lewcha/OneDrive - UKCEH/Documents/FDRI/projects/iot-device-simulator/src/iotdevicesimulator/__assets__/.certs/fdri_swarm.cert.pem"
+    key_path: "C:/Users/lewcha/OneDrive - UKCEH/Documents/FDRI/projects/iot-device-simulator/src/iotdevicesimulator/__assets__/.certs/fdri_swarm.private.key"
+    ca_cert_path: "C:/Users/lewcha/OneDrive - UKCEH/Documents/FDRI/projects/iot-device-simulator/src/iotdevicesimulator/__assets__/.certs/AmazonRootCA1.pem"
+}

src/tests/test_devices.py

@@ -74,8 +74,6 @@ def test_sleep_time_bad_value_gives_error(self, sleep_time):
 CONFIG_PATH = pathlib.Path(
     pathlib.Path(__file__).parents[1], "iotdevicesimulator", "__assets__", "config.cfg"
 )
-
-
 config_exists = pytest.mark.skipif(
     not CONFIG_PATH.exists(),
     reason="Config file `config.cfg` not found in root directory.",
@@ -85,6 +83,9 @@ def test_sleep_time_bad_value_gives_error(self, sleep_time):
 class TestSensorSiteOperation(unittest.IsolatedAsyncioTestCase):
     """Tests the active behaviour of SensorSite objects."""
 
+    @pytest.mark.oracle
+    @pytest.mark.asyncio
+    @config_exists
     async def asyncSetUp(self):
         cred_path = str(CONFIG_PATH)
         creds = config.Config(cred_path)["oracle"]
@@ -97,11 +98,15 @@ async def asyncSetUp(self):
 
         self.message_connection = MockMessageConnection()
 
+    @pytest.mark.oracle
+    @pytest.mark.asyncio
+    @config_exists
     async def asyncTearDown(self) -> None:
         await self.oracle.connection.close()
 
     @pytest.mark.asyncio
     @pytest.mark.oracle
+    @config_exists
     async def test_run_stops_after_max_cycles(self):
         """Ensures .run() method breaks after max_cycles"""
 
@@ -114,6 +119,7 @@ async def test_run_stops_after_max_cycles(self):
 
     @pytest.mark.asyncio
     @pytest.mark.oracle
+    @config_exists
     async def test_multi_instances_stop_at_max_cycles(self):
         """Ensures .run() method breaks after max_cycles for multiple instances"""
 

src/tests/test_messaging.py

@@ -10,6 +10,14 @@
 import awscrt.io
 from parameterized import parameterized
 
+CONFIG_PATH = Path(
+    Path(__file__).parents[1], "iotdevicesimulator", "__assets__", "config.cfg"
+)
+config_exists = pytest.mark.skipif(
+    not CONFIG_PATH.exists(),
+    reason="Config file `config.cfg` not found in root directory.",
+)
+
 
 class TestBaseClass(unittest.TestCase):
 
@@ -35,20 +43,13 @@ def test_instantiation(self):
 
 class TestIoTCoreMQTTConnection(unittest.TestCase):
 
+    @config_exists
     def setUp(self) -> None:
-        config = Config(
-            str(
-                Path(
-                    Path(__file__).parents[1],
-                    "iotdevicesimulator",
-                    "__assets__",
-                    "config.cfg",
-                )
-            )
-        )
+        config = Config(str(CONFIG_PATH))
 
         self.config = config["iot_core"]
 
+    @config_exists
     def test_instantiation(self):
 
         instance = IotCoreMQTTConnection(**self.config, client_id="test_id")
@@ -57,6 +58,7 @@ def test_instantiation(self):
 
         self.assertIsInstance(instance.connection, awscrt.mqtt.Connection)
 
+    @config_exists
     def test_non_string_arguments(self):
 
         with self.assertRaises(TypeError):
@@ -104,6 +106,7 @@ def test_non_string_arguments(self):
                 1,
             )
 
+    @config_exists
     def test_port(self):
 
         # Expect one of defaults if no port given
@@ -124,6 +127,7 @@ def test_port(self):
         self.assertEqual(instance.connection.port, 420)
 
     @parameterized.expand([-4, {"f": 4}, "FOUR"])
+    @config_exists
     def test_bad_port_type(self, port):
 
         with self.assertRaises((TypeError, ValueError)):
@@ -136,6 +140,7 @@ def test_bad_port_type(self, port):
                 port=port,
             )
 
+    @config_exists
     def test_clean_session_set(self):
         expected = False
 
@@ -151,13 +156,15 @@ def test_clean_session_set(self):
         self.assertEqual(instance.connection.clean_session, expected)
 
     @parameterized.expand([0, -1, "true", None])
+    @config_exists
     def test_bad_clean_session_type(self, clean_session):
 
         with self.assertRaises(TypeError):
             IotCoreMQTTConnection(
                 **self.config, client_id="test_id", clean_session=clean_session
             )
 
+    @config_exists
     def test_keep_alive_secs_set(self):
         # Test defualt is not none
         instance = IotCoreMQTTConnection(**self.config, client_id="test_id")
@@ -171,6 +178,7 @@ def test_keep_alive_secs_set(self):
         self.assertEqual(instance.connection.keep_alive_secs, expected)
 
     @parameterized.expand(["FOURTY", "True", None])
+    @config_exists
     def test_bad_keep_alive_secs_type(self, secs):
         with self.assertRaises(TypeError):
             IotCoreMQTTConnection(