Add reconnection end to end test

Signed-off-by: Simone Orru <simone.orru@secomind.com>

.github/workflows/e2e-test.yaml

@@ -61,6 +61,12 @@ jobs:
           echo "E2E_DEVICE_2_ID=$DEVICE_2_ID" >> $GITHUB_ENV
           CREDENTIALS_SECRET_2=$(astartectl pairing agent register --compact-output -- "$DEVICE_2_ID")
           echo "E2E_CREDENTIALS_SECRET_2=$CREDENTIALS_SECRET_2" >> $GITHUB_ENV
+      - name: Setup env variables for device 3
+        run: |
+          DEVICE_3_ID=$(astartectl utils device-id generate-random)
+          echo "E2E_DEVICE_3_ID=$DEVICE_3_ID" >> $GITHUB_ENV
+          CREDENTIALS_SECRET_3=$(astartectl pairing agent register --compact-output -- "$DEVICE_3_ID")
+          echo "E2E_CREDENTIALS_SECRET_3=$CREDENTIALS_SECRET_3" >> $GITHUB_ENV
       - name: Install the astarte device Python module
         run: |
           python3 -m pip install -e .[e2e]
@@ -81,3 +87,11 @@ jobs:
           command: |
             export REQUESTS_CA_BUNDLE=/etc/ssl/certs/ca-certificates.crt
             python3 e2etest/persistency/main.py
+      - name: Run test for reconnection
+        uses: nick-fields/retry@v2
+        with:
+          timeout_seconds: 30
+          max_attempts: 2
+          command: |
+            export REQUESTS_CA_BUNDLE=/etc/ssl/certs/ca-certificates.crt
+            python3 e2etest/reconnection/main.py

e2etest/base/main.py

@@ -109,6 +109,10 @@ def main(cb_loop: asyncio.AbstractEventLoop, test_cfg: TestCfg):
 
     time.sleep(1)
 
+    if not device.is_connected():
+        print("Connection failed.", flush=True)
+        sys.exit(1)
+
     test_datastream_from_device_to_server(device, test_cfg)
 
     time.sleep(1)

e2etest/persistency/main.py

@@ -197,8 +197,13 @@ def main(cb_loop: asyncio.AbstractEventLoop, test_cfg: TestCfg):
     device.on_data_received = on_data_received_cbk
     device.on_disconnected = on_disconnected_cbk
     device.connect()
+
     time.sleep(1)
 
+    if not device.is_connected():
+        print("Connection failed.", flush=True)
+        sys.exit(1)
+
     assert peek_database(persistency_dir, test_cfg.device_id) == list()
     assert peek_astarte(test_cfg) == {
         test_cfg.interface_device_prop: {},