feat(generated): Add Pipes operations and models

.changelog-pending/2026-07-02T14-59-23-e350eb0b1521b954c25625b4858b2fd14a506cd2.md

@@ -0,0 +1,27 @@
+* [#122](https://github.com/workos/workos-rust/pull/122) feat(generated): regenerate from spec (1 change)
+
+  **Features**
+  * **[pipes](https://workos.com/docs/reference/pipes)**:
+    * Added model `DataIntegrationCredentialsDto`
+    * Added model `CustomProviderDefinition`
+    * Added model `CreateDataIntegration`
+    * Added model `UpdateCustomProviderDefinition`
+    * Added model `UpdateDataIntegration`
+    * Added model `DataIntegration`
+    * Added model `DataIntegrationList`
+    * Added model `DataIntegrationListListMetadata`
+    * Added model `DataIntegrationCredential`
+    * Added model `DataIntegrationCustomProvider`
+    * Added enum `DataIntegrationCredentialsType`
+    * Added enum `CustomProviderDefinitionAuthenticateVia`
+    * Added enum `UpdateCustomProviderDefinitionAuthenticateVia`
+    * Added enum `DataIntegrationState`
+    * Added enum `DataIntegrationCredentialType`
+    * Added enum `DataIntegrationCustomProviderAuthenticateVia`
+    * Added endpoint `GET /data-integrations`
+    * Added endpoint `POST /data-integrations`
+    * Added endpoint `GET /data-integrations/{slug}`
+    * Added endpoint `PUT /data-integrations/{slug}`
+    * Added endpoint `DELETE /data-integrations/{slug}`
+    * Added endpoint `POST /user_management/users/{user_id}/connected_accounts/{slug}`
+    * Added endpoint `PUT /user_management/users/{user_id}/connected_accounts/{slug}`

.last-synced-sha

@@ -1 +1 @@
-dc04d30b352063b5c97e45de03be5c83629f5412
+4b4e0618779460dbebc1cf5e0f02197c21796d1f

.oagen-manifest.json

@@ -1,7 +1,7 @@
 {
   "version": 2,
   "language": "rust",
-  "generatedAt": "2026-07-01T18:19:09.952Z",
+  "generatedAt": "2026-07-02T14:58:53.128Z",
   "files": [
     "src/enums/audit_log_configuration_log_stream_state.rs",
     "src/enums/audit_log_configuration_log_stream_type.rs",
@@ -32,9 +32,14 @@
     "src/enums/create_user_invite_options_locale.rs",
     "src/enums/create_user_password_hash_type.rs",
     "src/enums/create_webhook_endpoint_events.rs",
+    "src/enums/custom_provider_definition_authenticate_via.rs",
     "src/enums/data_integration_access_token_response_error.rs",
+    "src/enums/data_integration_credential_type.rs",
     "src/enums/data_integration_credentials_credentials_type.rs",
     "src/enums/data_integration_credentials_response_error.rs",
+    "src/enums/data_integration_credentials_type.rs",
+    "src/enums/data_integration_custom_provider_authenticate_via.rs",
+    "src/enums/data_integration_state.rs",
     "src/enums/data_integrations_list_response_data_auth_methods.rs",
     "src/enums/data_integrations_list_response_data_connected_account_auth_method.rs",
     "src/enums/data_integrations_list_response_data_connected_account_state.rs",
@@ -105,6 +110,7 @@
     "src/enums/session_revoked_data_auth_method.rs",
     "src/enums/session_revoked_data_status.rs",
     "src/enums/sso_provider.rs",
+    "src/enums/update_custom_provider_definition_authenticate_via.rs",
     "src/enums/update_user_password_hash_type.rs",
     "src/enums/update_webhook_endpoint_events.rs",
     "src/enums/update_webhook_endpoint_status.rs",
@@ -257,6 +263,7 @@
     "src/models/connect_application_oauth_redirect_uris.rs",
     "src/models/connect_application_redirect_uri.rs",
     "src/models/connected_account.rs",
+    "src/models/connected_account_dto.rs",
     "src/models/connection.rs",
     "src/models/connection_activated.rs",
     "src/models/connection_activated_data.rs",
@@ -283,6 +290,7 @@
     "src/models/create_authorization_permission.rs",
     "src/models/create_authorization_resource.rs",
     "src/models/create_cors_origin.rs",
+    "src/models/create_data_integration.rs",
     "src/models/create_data_key_request.rs",
     "src/models/create_data_key_response.rs",
     "src/models/create_group.rs",
@@ -304,14 +312,21 @@
     "src/models/create_user_invite_options.rs",
     "src/models/create_user_organization_membership.rs",
     "src/models/create_webhook_endpoint.rs",
+    "src/models/custom_provider_definition.rs",
+    "src/models/data_integration.rs",
     "src/models/data_integration_access_token_response.rs",
     "src/models/data_integration_access_token_response_access_token.rs",
     "src/models/data_integration_authorize_url_response.rs",
     "src/models/data_integration_configuration_list_response.rs",
     "src/models/data_integration_configuration_response.rs",
+    "src/models/data_integration_credential.rs",
     "src/models/data_integration_credentials.rs",
+    "src/models/data_integration_credentials_dto.rs",
     "src/models/data_integration_credentials_response.rs",
     "src/models/data_integration_credentials_response_credential.rs",
+    "src/models/data_integration_custom_provider.rs",
+    "src/models/data_integration_list.rs",
+    "src/models/data_integration_list_list_metadata.rs",
     "src/models/data_integrations_get_data_integration_authorize_url_request.rs",
     "src/models/data_integrations_get_user_token_request.rs",
     "src/models/data_integrations_list_response.rs",
@@ -567,6 +582,8 @@
     "src/models/update_audit_logs_retention.rs",
     "src/models/update_authorization_permission.rs",
     "src/models/update_authorization_resource.rs",
+    "src/models/update_custom_provider_definition.rs",
+    "src/models/update_data_integration.rs",
     "src/models/update_group.rs",
     "src/models/update_jwt_template.rs",
     "src/models/update_oauth_application.rs",
@@ -809,6 +826,7 @@
     "tests/fixtures/connect_application_oauth.json",
     "tests/fixtures/connect_application_oauth_redirect_uris.json",
     "tests/fixtures/connected_account.json",
+    "tests/fixtures/connected_account_dto.json",
     "tests/fixtures/connection.json",
     "tests/fixtures/connection_activated.json",
     "tests/fixtures/connection_activated_data.json",
@@ -834,6 +852,7 @@
     "tests/fixtures/create_authorization_permission.json",
     "tests/fixtures/create_authorization_resource.json",
     "tests/fixtures/create_cors_origin.json",
+    "tests/fixtures/create_data_integration.json",
     "tests/fixtures/create_data_key_request.json",
     "tests/fixtures/create_data_key_response.json",
     "tests/fixtures/create_group.json",
@@ -855,14 +874,21 @@
     "tests/fixtures/create_user_invite_options.json",
     "tests/fixtures/create_user_organization_membership.json",
     "tests/fixtures/create_webhook_endpoint.json",
+    "tests/fixtures/custom_provider_definition.json",
+    "tests/fixtures/data_integration.json",
     "tests/fixtures/data_integration_access_token_response.json",
     "tests/fixtures/data_integration_access_token_response_access_token.json",
     "tests/fixtures/data_integration_authorize_url_response.json",
     "tests/fixtures/data_integration_configuration_list_response.json",
     "tests/fixtures/data_integration_configuration_response.json",
+    "tests/fixtures/data_integration_credential.json",
     "tests/fixtures/data_integration_credentials.json",
+    "tests/fixtures/data_integration_credentials_dto.json",
     "tests/fixtures/data_integration_credentials_response.json",
     "tests/fixtures/data_integration_credentials_response_credential.json",
+    "tests/fixtures/data_integration_custom_provider.json",
+    "tests/fixtures/data_integration_list.json",
+    "tests/fixtures/data_integration_list_list_metadata.json",
     "tests/fixtures/data_integrations_get_data_integration_authorize_url_request.json",
     "tests/fixtures/data_integrations_get_user_token_request.json",
     "tests/fixtures/data_integrations_list_response.json",
@@ -1117,6 +1143,8 @@
     "tests/fixtures/update_audit_logs_retention.json",
     "tests/fixtures/update_authorization_permission.json",
     "tests/fixtures/update_authorization_resource.json",
+    "tests/fixtures/update_custom_provider_definition.json",
+    "tests/fixtures/update_data_integration.json",
     "tests/fixtures/update_group.json",
     "tests/fixtures/update_jwt_template.json",
     "tests/fixtures/update_oauth_application.json",
@@ -2004,6 +2032,38 @@
     "GET /user_management/redirect_uris": {
       "sdkMethod": "list_redirect_uris",
       "service": "user_management"
+    },
+    "GET /data-integrations": {
+      "sdkMethod": "list_data_integrations",
+      "service": "pipes"
+    },
+    "POST /data-integrations": {
+      "sdkMethod": "create_data_integration",
+      "service": "pipes"
+    },
+    "GET /data-integrations/{slug}": {
+      "sdkMethod": "get_data_integration",
+      "service": "pipes"
+    },
+    "PUT /data-integrations/{slug}": {
+      "sdkMethod": "update_data_integration",
+      "service": "pipes"
+    },
+    "DELETE /data-integrations/{slug}": {
+      "sdkMethod": "delete_data_integration",
+      "service": "pipes"
+    },
+    "POST /user_management/users/{user_id}/connected_accounts/{slug}": {
+      "sdkMethod": "create_user_connected_account",
+      "service": "pipes"
+    },
+    "PUT /user_management/users/{user_id}/connected_accounts/{slug}": {
+      "sdkMethod": "update_user_connected_account",
+      "service": "pipes"
+    },
+    "POST /user_management/radar_challenges": {
+      "sdkMethod": "create_radar_challenge",
+      "service": "user_management"
     }
   }
 }

src/enums/connected_account_state.rs

@@ -9,7 +9,6 @@ use std::str::FromStr;
 pub enum ConnectedAccountState {
     Connected,
     NeedsReauthorization,
-    Disconnected,
     /// Wire value not recognized by this SDK version. The original
     /// string is preserved verbatim. WorkOS may add new enum values
     /// server-side; matching on this variant lets callers handle
@@ -25,7 +24,6 @@ impl ConnectedAccountState {
         match self {
             Self::Connected => "connected",
             Self::NeedsReauthorization => "needs_reauthorization",
-            Self::Disconnected => "disconnected",
             Self::Unknown(s) => s.as_str(),
         }
     }
@@ -50,7 +48,6 @@ impl FromStr for ConnectedAccountState {
         Ok(match s {
             "connected" => Self::Connected,
             "needs_reauthorization" => Self::NeedsReauthorization,
-            "disconnected" => Self::Disconnected,
             other => Self::Unknown(other.to_string()),
         })
     }

src/enums/custom_provider_definition_authenticate_via.rs

@@ -0,0 +1,83 @@
+// This file is auto-generated by oagen. Do not edit.
+
+use serde::{Deserialize, Serialize};
+use std::fmt;
+use std::str::FromStr;
+
+#[derive(Debug, Clone, PartialEq, Eq, Hash)]
+#[non_exhaustive]
+pub enum CustomProviderDefinitionAuthenticateVia {
+    RequestBody,
+    BasicAuthHeader,
+    /// Wire value not recognized by this SDK version. The original
+    /// string is preserved verbatim. WorkOS may add new enum values
+    /// server-side; matching on this variant lets callers handle
+    /// forward-compatible values without panicking.
+    Unknown(String),
+}
+
+impl CustomProviderDefinitionAuthenticateVia {
+    /// Canonical wire string for this value. For [`Self::Unknown`] returns the
+    /// original wire value as received from the API.
+    #[allow(deprecated)]
+    pub fn as_str(&self) -> &str {
+        match self {
+            Self::RequestBody => "request_body",
+            Self::BasicAuthHeader => "basic_auth_header",
+            Self::Unknown(s) => s.as_str(),
+        }
+    }
+}
+
+impl fmt::Display for CustomProviderDefinitionAuthenticateVia {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        f.write_str(self.as_str())
+    }
+}
+
+impl AsRef<str> for CustomProviderDefinitionAuthenticateVia {
+    fn as_ref(&self) -> &str {
+        self.as_str()
+    }
+}
+
+impl FromStr for CustomProviderDefinitionAuthenticateVia {
+    type Err = std::convert::Infallible;
+    #[allow(deprecated)]
+    fn from_str(s: &str) -> Result<Self, Self::Err> {
+        Ok(match s {
+            "request_body" => Self::RequestBody,
+            "basic_auth_header" => Self::BasicAuthHeader,
+            other => Self::Unknown(other.to_string()),
+        })
+    }
+}
+
+impl From<String> for CustomProviderDefinitionAuthenticateVia {
+    fn from(s: String) -> Self {
+        // Reuse the original `String` allocation in the fallback branch.
+        match Self::from_str(&s) {
+            Ok(Self::Unknown(_)) => Self::Unknown(s),
+            Ok(other) => other,
+        }
+    }
+}
+
+impl From<&str> for CustomProviderDefinitionAuthenticateVia {
+    fn from(s: &str) -> Self {
+        Self::from_str(s).unwrap_or_else(|_| Self::Unknown(s.to_string()))
+    }
+}
+
+impl Serialize for CustomProviderDefinitionAuthenticateVia {
+    fn serialize<S: serde::Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error> {
+        serializer.serialize_str(self.as_str())
+    }
+}
+
+impl<'de> Deserialize<'de> for CustomProviderDefinitionAuthenticateVia {
+    fn deserialize<D: serde::Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error> {
+        let s = String::deserialize(deserializer)?;
+        Ok(Self::from(s))
+    }
+}

src/enums/data_integration_credential_type.rs

@@ -0,0 +1,83 @@
+// This file is auto-generated by oagen. Do not edit.
+
+use serde::{Deserialize, Serialize};
+use std::fmt;
+use std::str::FromStr;
+
+#[derive(Debug, Clone, PartialEq, Eq, Hash)]
+#[non_exhaustive]
+pub enum DataIntegrationCredentialType {
+    Custom,
+    Organization,
+    /// Wire value not recognized by this SDK version. The original
+    /// string is preserved verbatim. WorkOS may add new enum values
+    /// server-side; matching on this variant lets callers handle
+    /// forward-compatible values without panicking.
+    Unknown(String),
+}
+
+impl DataIntegrationCredentialType {
+    /// Canonical wire string for this value. For [`Self::Unknown`] returns the
+    /// original wire value as received from the API.
+    #[allow(deprecated)]
+    pub fn as_str(&self) -> &str {
+        match self {
+            Self::Custom => "custom",
+            Self::Organization => "organization",
+            Self::Unknown(s) => s.as_str(),
+        }
+    }
+}
+
+impl fmt::Display for DataIntegrationCredentialType {
+    fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result {
+        f.write_str(self.as_str())
+    }
+}
+
+impl AsRef<str> for DataIntegrationCredentialType {
+    fn as_ref(&self) -> &str {
+        self.as_str()
+    }
+}
+
+impl FromStr for DataIntegrationCredentialType {
+    type Err = std::convert::Infallible;
+    #[allow(deprecated)]
+    fn from_str(s: &str) -> Result<Self, Self::Err> {
+        Ok(match s {
+            "custom" => Self::Custom,
+            "organization" => Self::Organization,
+            other => Self::Unknown(other.to_string()),
+        })
+    }
+}
+
+impl From<String> for DataIntegrationCredentialType {
+    fn from(s: String) -> Self {
+        // Reuse the original `String` allocation in the fallback branch.
+        match Self::from_str(&s) {
+            Ok(Self::Unknown(_)) => Self::Unknown(s),
+            Ok(other) => other,
+        }
+    }
+}
+
+impl From<&str> for DataIntegrationCredentialType {
+    fn from(s: &str) -> Self {
+        Self::from_str(s).unwrap_or_else(|_| Self::Unknown(s.to_string()))
+    }
+}
+
+impl Serialize for DataIntegrationCredentialType {
+    fn serialize<S: serde::Serializer>(&self, serializer: S) -> Result<S::Ok, S::Error> {
+        serializer.serialize_str(self.as_str())
+    }
+}
+
+impl<'de> Deserialize<'de> for DataIntegrationCredentialType {
+    fn deserialize<D: serde::Deserializer<'de>>(deserializer: D) -> Result<Self, D::Error> {
+        let s = String::deserialize(deserializer)?;
+        Ok(Self::from(s))
+    }
+}