feat/xr_driver_ipm_error_subscription_and_reporting

Improved XR Device Driver IPM error reporting

IPM reports many of the errors asynchronously due to advanced micro services architecture. This PR adds background thread to XR driver that subscribes error feed and correlates relevant errors to ongoing transactions. This prevents timing out many of the error situations and provides high quality error reports on failures.

src/device/service/drivers/xr/cm/tests/test_cm_connection.py

@@ -37,30 +37,30 @@ def test_cmc_connect():
     # Valid access token
     with requests_mock.Mocker() as m:
         m.post('https://127.0.0.1:9999/realms/xr-cm/protocol/openid-connect/token', text=access_token)
-        cm = CmConnection("127.0.0.1", 9999, "xr-user", "xr-password", tls_verify=False)
+        cm = CmConnection("127.0.0.1", 9999, "xr-user", "xr-password", tls_verify=False, monitor_error_stream=False)
         assert cm.Connect()
 
     # Valid JSON but no access token
     with requests_mock.Mocker() as m:
         m.post('https://127.0.0.1:9999/realms/xr-cm/protocol/openid-connect/token', text=r'{"a": "b"}')
-        cm = CmConnection("127.0.0.1", 9999, "xr-user", "xr-password", tls_verify=False)
+        cm = CmConnection("127.0.0.1", 9999, "xr-user", "xr-password", tls_verify=False, monitor_error_stream=False)
         assert not cm.Connect()
 
     # Invalid JSON
     with requests_mock.Mocker() as m:
         m.post('https://127.0.0.1:9999/realms/xr-cm/protocol/openid-connect/token', text=r'}}}')
-        cm = CmConnection("127.0.0.1", 9999, "xr-user", "xr-password", tls_verify=False)
+        cm = CmConnection("127.0.0.1", 9999, "xr-user", "xr-password", tls_verify=False, monitor_error_stream=False)
         assert not cm.Connect()
 
     with requests_mock.Mocker() as m:
         # No mock present for the destination
-        cm = CmConnection("127.0.0.1", 9999, "xr-user", "xr-password", tls_verify=False)
+        cm = CmConnection("127.0.0.1", 9999, "xr-user", "xr-password", tls_verify=False, monitor_error_stream=False)
         assert not cm.Connect()
 
 def test_cmc_get_constellations():
     with mock_cm_connectivity() as m:
         m.get("https://127.0.0.1:9999/api/v1/xr-networks?content=expanded", text=res_constellations)
-        cm = CmConnection("127.0.0.1", 9999, "xr-user", "xr-password", tls_verify=False)
+        cm = CmConnection("127.0.0.1", 9999, "xr-user", "xr-password", tls_verify=False, monitor_error_stream=False)
         assert cm.Connect()
 
         # List all constellations