From fa2ff487ffb8488407c38268c7275aae997032a0 Mon Sep 17 00:00:00 2001 From: Alex Emmet <111742636+Alex-Emmet@users.noreply.github.com> Date: Thu, 21 May 2026 23:26:43 +0200 Subject: [PATCH] Reconnection --- src/transport/omikron_connection.rs | 14 +++++++------- 1 file changed, 7 insertions(+), 7 deletions(-) diff --git a/src/transport/omikron_connection.rs b/src/transport/omikron_connection.rs index 8205775..a3dd099 100644 --- a/src/transport/omikron_connection.rs +++ b/src/transport/omikron_connection.rs @@ -734,7 +734,7 @@ impl OmikronConnection { self.send(&response).await } Err(e) => { - let response = CommunicationValue::new(CommunicationType::error) + let response = CommunicationValue::new(CommunicationType::error_internal) .with_id(cv.get_id()) .add_data(DataTypes::error_type, DataValue::Str(e.to_string())); self.send(&response).await @@ -751,7 +751,7 @@ impl OmikronConnection { self.send(&response).await } Err(e) => { - let response = CommunicationValue::new(CommunicationType::error) + let response = CommunicationValue::new(CommunicationType::error_internal) .with_id(cv.get_id()) .add_data(DataTypes::error_type, DataValue::Str(e.to_string())); self.send(&response).await @@ -796,7 +796,7 @@ impl OmikronConnection { self.send(&response).await } Err(e) => { - let response = CommunicationValue::new(CommunicationType::error) + let response = CommunicationValue::new(CommunicationType::error_internal) .with_id(cv.get_id()) .add_data(DataTypes::error_type, DataValue::Str(e.to_string())); self.send(&response).await @@ -864,7 +864,7 @@ impl OmikronConnection { let response = CommunicationValue::new(CommunicationType::success).with_id(cv.get_id()); self.send(&response).await } else { - let response = CommunicationValue::new(CommunicationType::error) + let response = CommunicationValue::new(CommunicationType::error_internal) .with_id(cv.get_id()) .add_data(DataTypes::error_type, DataValue::Str(error_message)); self.send(&response).await @@ -903,7 +903,7 @@ impl OmikronConnection { .with_id(cv.get_id()); self.send(&response).await } else { - let response = CommunicationValue::new(CommunicationType::error) + let response = CommunicationValue::new(CommunicationType::error_internal) .with_id(cv.get_id()) .add_data(DataTypes::error_type, DataValue::Str(error_message)); self.send(&response).await @@ -936,7 +936,7 @@ impl OmikronConnection { self.send(&response).await } Err(e) => { - let response = CommunicationValue::new(CommunicationType::error) + let response = CommunicationValue::new(CommunicationType::error_internal) .with_id(cv.get_id()) .add_data(DataTypes::error_type, DataValue::Str(e.to_string())); self.send(&response).await @@ -953,7 +953,7 @@ impl OmikronConnection { self.send(&response).await } Err(e) => { - let response = CommunicationValue::new(CommunicationType::error) + let response = CommunicationValue::new(CommunicationType::error_internal) .with_id(cv.get_id()) .add_data(DataTypes::error_type, DataValue::Str(e.to_string())); self.send(&response).await