tensamin/omega
Watch
6
0
Fork
You've already forked omega
 0
Code Issues Pull requests 1 Projects Releases Packages Wiki Activity Actions

Reconnection

Browse source
This commit is contained in:
Alex Emmet 2026-05-21 23:26:43 +02:00
commit 9580dbaf12
1 changed files with 7 additions and 7 deletions
Download patch file Download diff file Expand all files Collapse all files

14
src/transport/omikron_connection.rs
View file

@ -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