chore: allow passing ids to connections api create methods

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

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)]

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,

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,

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")]

integrationos-api/src/endpoints/unified.rs

@@ -11,7 +11,7 @@ use convert_case::{Case, Casing};
 use http::{HeaderMap, HeaderName};
 use integrationos_domain::{
     connection_model_definition::CrudAction, destination::Action,
-    encrypted_access_key::EncryptedAccessKey, encrypted_data::PASSWORD_LENGTH, environment,
+    encrypted_access_key::EncryptedAccessKey, encrypted_data::PASSWORD_LENGTH,
     event_access::EventAccess, AccessKey, ApplicationError, Event, InternalError,
 };
 use serde::{Deserialize, Serialize};

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![],

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(),

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,

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(),

integrationos-unified/src/unified.rs

@@ -37,7 +37,7 @@ use mongodb::{
     options::{Collation, CollationStrength, FindOneOptions},
     Client,
 };
-use serde_json::{json, Map, Number, Value};
+use serde_json::{json, Number, Value};
 use std::{cell::RefCell, collections::HashMap, str::FromStr, sync::Arc};
 use tracing::{debug, error};