fix: adding error to sanitized connection (#203)

integration-os · Dec 9, 2024 · 7e25918 · 7e25918
1 parent f0d56c7
commit 7e25918
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 0 deletions.
diff --git a/integrationos-api/src/logic/connection.rs b/integrationos-api/src/logic/connection.rs
@@ -162,6 +162,8 @@ impl PublicExt<Connection> for CreateConnectionPayload {
             settings: input.settings,
             throughput: input.throughput,
             ownership: input.ownership,
+            error: input.error,
+            has_error: input.has_error,
             oauth: input.oauth,
             record_metadata: input.record_metadata,
         }
@@ -365,6 +367,8 @@ pub async fn create_connection(
         settings: connection.settings,
         throughput: connection.throughput,
         ownership: connection.ownership,
+        has_error: connection.has_error,
+        error: connection.error,
         oauth: connection.oauth,
         record_metadata: connection.record_metadata,
     }))

diff --git a/integrationos-domain/src/domain/connection/mod.rs b/integrationos-domain/src/domain/connection/mod.rs
@@ -104,6 +104,10 @@ pub struct SanitizedConnection {
     pub ownership: Ownership,
     #[serde(default)]
     pub oauth: Option<OAuth>,
+    #[serde(default)]
+    pub has_error: bool,
+    #[serde(skip_serializing_if = "Option::is_none", default)]
+    pub error: Option<String>,
     #[serde(flatten, default)]
     pub record_metadata: RecordMetadata,
 }