chore: allow passing ids to connections api create methods (#94)

integration-os · Jul 22, 2024 · a30d456 · a30d456
1 parent 9aaafca
commit a30d456
Show file tree

Hide file tree

Showing 9 changed files with 10 additions and 0 deletions.
diff --git a/integrationos-api/src/endpoints/common_model.rs b/integrationos-api/src/endpoints/common_model.rs
@@ -43,6 +43,7 @@ pub fn get_router() -> Router<Arc<AppState>> {
 #[cfg_attr(feature = "dummy", derive(fake::Dummy))]
 #[serde(rename_all = "camelCase")]
 pub struct CreateRequest {
+    pub _id: Option<Id>,
     pub name: String,
     pub version: Version,
     pub fields: Vec<Field>,

diff --git a/integrationos-api/src/endpoints/connection_definition.rs b/integrationos-api/src/endpoints/connection_definition.rs
@@ -44,6 +44,7 @@ pub fn get_router() -> Router<Arc<AppState>> {
 #[cfg_attr(feature = "dummy", derive(fake::Dummy))]
 #[serde(rename_all = "camelCase")]
 pub struct CreateRequest {
+    pub _id: Option<Id>,
     pub platform: String,
     pub platform_version: String,
     #[serde(default)]

diff --git a/integrationos-api/src/endpoints/connection_model_definition.rs b/integrationos-api/src/endpoints/connection_model_definition.rs
@@ -268,6 +268,7 @@ pub async fn test_connection_model_definition(
 #[cfg_attr(feature = "dummy", derive(fake::Dummy))]
 #[serde(rename_all = "camelCase")]
 pub struct CreateRequest {
+    pub _id: Option<Id>,
     pub connection_platform: String,
     pub connection_definition_id: Id,
     pub platform_version: String,

diff --git a/integrationos-api/src/endpoints/connection_model_schema.rs b/integrationos-api/src/endpoints/connection_model_schema.rs
@@ -152,6 +152,7 @@ pub async fn get_platform_models(
 #[cfg_attr(feature = "dummy", derive(fake::Dummy))]
 #[serde(rename_all = "camelCase")]
 pub struct CreateRequest {
+    pub _id: Option<Id>,
     pub platform_id: Id,
     pub platform_page_id: Id,
     pub connection_platform: String,

diff --git a/integrationos-api/src/endpoints/connection_oauth_definition.rs b/integrationos-api/src/endpoints/connection_oauth_definition.rs
@@ -35,6 +35,7 @@ pub fn get_router() -> Router<Arc<AppState>> {
 #[derive(Debug, Clone, PartialEq, Deserialize, Serialize)]
 #[serde(rename_all = "camelCase")]
 pub struct CreateRequest {
+    pub _id: Option<Id>,
     pub connection_platform: String,
     pub platform_redirect_uri: String,
     #[serde(skip_serializing_if = "Option::is_none")]

diff --git a/integrationos-api/tests/api_tests/get_tests.rs b/integrationos-api/tests/api_tests/get_tests.rs
@@ -44,6 +44,7 @@ async fn test_get_expanded_common_model() {
     let reference: String = Faker.fake();
 
     let base = common_model::CreateRequest {
+        _id: None,
         name: Faker.fake(),
         version: Faker.fake(),
         fields: vec![
@@ -72,6 +73,7 @@ async fn test_get_expanded_common_model() {
     };
 
     let expandable = common_model::CreateRequest {
+        _id: None,
         name: reference.clone(),
         version: Faker.fake(),
         fields: vec![],

diff --git a/integrationos-api/tests/api_tests/passthrough_tests.rs b/integrationos-api/tests/api_tests/passthrough_tests.rs
@@ -35,6 +35,7 @@ async fn test_passthrough_api() {
         .create();
 
     let create_model_definition_payload = CreateConnectionModelDefinitionRequest {
+        _id: None,
         connection_platform: connection.platform.to_string(),
         connection_definition_id: conn_def.id,
         platform_version: conn_def.record_metadata.version.to_string(),

diff --git a/integrationos-api/tests/api_tests/test_server/mod.rs b/integrationos-api/tests/api_tests/test_server/mod.rs
@@ -492,6 +492,7 @@ impl TestServer {
         assert!(!connection.secrets_service_id.is_empty());
 
         let model_def = CreateConnectionModelDefinitionRequest {
+            _id: None,
             connection_platform: connection_def.platform,
             connection_definition_id: connection_def.id,
             platform_version: connection_def.platform_version,

diff --git a/integrationos-api/tests/api_tests/unified_tests.rs b/integrationos-api/tests/api_tests/unified_tests.rs
@@ -547,6 +547,7 @@ async fn create_connection_model_definition(
         .await;
 
     let create_model_definition_payload = CreateConnectionModelDefinitionRequest {
+        _id: None,
         connection_platform: connection.platform.to_string(),
         connection_definition_id: connection.connection_definition_id,
         platform_version: connection.record_metadata.version.to_string(),