add tests

tests/integration/pubsub_test.py

@@ -42,6 +42,25 @@ async def test_for_publish_mqtt_event():
     assert True
 
 
+@pytest.mark.asyncio
+async def test_for_subscribe_mqtt_event():
+    mqtt_client = get_vehicleapp_instance().pubsub_client
+    await mqtt_client.subscribe_topic("test/test_for_publish_mqtt_event", successfull_callback)
+    await mqtt_client.publish_event("test/test_for_publish_mqtt_event", "test")
+    assert True
+
+
+def successfull_callback(self, data_str: str):
+    assert data_str == "test"
+
+
+@pytest.mark.asyncio
+async def test_for_error_message():
+    mqtt_client = get_vehicleapp_instance().pubsub_client
+    await mqtt_client.subscribe_topic("test/test_for_publish_mqtt_event", None)
+    await mqtt_client.publish_event("test/test_for_publish_mqtt_event", "\xc3")
+    assert True
+
 class TestPubSubVehicleApp(VehicleApp):
     def __init__(self, vehicle_client: Vehicle):
         super().__init__()