Add CreateSession S3 API operation

codegen/src/v1/aws_conv.rs

@@ -291,6 +291,7 @@ fn has_unconditional_builder(name: &str) -> bool {
     matches!(
         name,
         "AnalyticsExportDestination"
+            | "CreateSessionOutput"
             | "InventoryDestination"
             | "RoutingRule"
             | "MetadataTableConfiguration"

codegen/src/v1/dto.rs

@@ -512,7 +512,7 @@ fn collect_types_needing_serde(rust_types: &RustTypes) -> BTreeSet<String> {
     types_needing_serde
 }
 
-fn collect_types_needing_custom_default(rust_types: &RustTypes) -> BTreeSet<String> {
+fn collect_types_needing_custom_default(rust_types: &RustTypes, ops: &Operations) -> BTreeSet<String> {
     let mut types_needing_custom_default = BTreeSet::new();
 
     // Start with Configuration types that can't derive Default
@@ -526,6 +526,15 @@ fn collect_types_needing_custom_default(rust_types: &RustTypes) -> BTreeSet<Stri
         }
     }
 
+    // Also include operation output types that can't derive Default
+    for op in ops.values() {
+        if let Some(rust::Type::Struct(ty)) = rust_types.get(&op.output)
+            && !can_derive_default(ty, rust_types)
+        {
+            collect_struct_dependencies(&op.output, rust_types, &mut types_needing_custom_default);
+        }
+    }
+
     types_needing_custom_default
 }
 
@@ -603,7 +612,7 @@ pub fn codegen(rust_types: &RustTypes, ops: &Operations, patch: Option<Patch>) {
     let types_needing_serde = collect_types_needing_serde(rust_types);
 
     // Collect types that need custom Default implementations
-    let types_needing_custom_default = collect_types_needing_custom_default(rust_types);
+    let types_needing_custom_default = collect_types_needing_custom_default(rust_types, ops);
 
     g([
         "#![allow(clippy::empty_structs_with_brackets)]",

codegen/src/v1/ops.rs

@@ -38,7 +38,7 @@ pub struct Operation {
 pub type Operations = BTreeMap<String, Operation>;
 
 // TODO: handle these operations
-pub const SKIPPED_OPS: &[&str] = &["CreateSession", "ListDirectoryBuckets"];
+pub const SKIPPED_OPS: &[&str] = &["ListDirectoryBuckets"];
 
 pub fn collect_operations(model: &smithy::Model) -> Operations {
     let mut operations: Operations = default();

crates/s3s-aws/src/conv/generated.rs

@@ -1314,6 +1314,58 @@ impl AwsConversion for s3s::dto::CreateMultipartUploadOutput {
     }
 }
 
+impl AwsConversion for s3s::dto::CreateSessionInput {
+    type Target = aws_sdk_s3::operation::create_session::CreateSessionInput;
+    type Error = S3Error;
+
+    fn try_from_aws(x: Self::Target) -> S3Result<Self> {
+        Ok(Self {
+            bucket: unwrap_from_aws(x.bucket, "bucket")?,
+            bucket_key_enabled: try_from_aws(x.bucket_key_enabled)?,
+            ssekms_encryption_context: try_from_aws(x.ssekms_encryption_context)?,
+            ssekms_key_id: try_from_aws(x.ssekms_key_id)?,
+            server_side_encryption: try_from_aws(x.server_side_encryption)?,
+            session_mode: try_from_aws(x.session_mode)?,
+        })
+    }
+
+    fn try_into_aws(x: Self) -> S3Result<Self::Target> {
+        let mut y = Self::Target::builder();
+        y = y.set_bucket(Some(try_into_aws(x.bucket)?));
+        y = y.set_bucket_key_enabled(try_into_aws(x.bucket_key_enabled)?);
+        y = y.set_ssekms_encryption_context(try_into_aws(x.ssekms_encryption_context)?);
+        y = y.set_ssekms_key_id(try_into_aws(x.ssekms_key_id)?);
+        y = y.set_server_side_encryption(try_into_aws(x.server_side_encryption)?);
+        y = y.set_session_mode(try_into_aws(x.session_mode)?);
+        y.build().map_err(S3Error::internal_error)
+    }
+}
+
+impl AwsConversion for s3s::dto::CreateSessionOutput {
+    type Target = aws_sdk_s3::operation::create_session::CreateSessionOutput;
+    type Error = S3Error;
+
+    fn try_from_aws(x: Self::Target) -> S3Result<Self> {
+        Ok(Self {
+            bucket_key_enabled: try_from_aws(x.bucket_key_enabled)?,
+            credentials: unwrap_from_aws(x.credentials, "credentials")?,
+            ssekms_encryption_context: try_from_aws(x.ssekms_encryption_context)?,
+            ssekms_key_id: try_from_aws(x.ssekms_key_id)?,
+            server_side_encryption: try_from_aws(x.server_side_encryption)?,
+        })
+    }
+
+    fn try_into_aws(x: Self) -> S3Result<Self::Target> {
+        let mut y = Self::Target::builder();
+        y = y.set_bucket_key_enabled(try_into_aws(x.bucket_key_enabled)?);
+        y = y.set_credentials(Some(try_into_aws(x.credentials)?));
+        y = y.set_ssekms_encryption_context(try_into_aws(x.ssekms_encryption_context)?);
+        y = y.set_ssekms_key_id(try_into_aws(x.ssekms_key_id)?);
+        y = y.set_server_side_encryption(try_into_aws(x.server_side_encryption)?);
+        Ok(y.build())
+    }
+}
+
 impl AwsConversion for s3s::dto::DataRedundancy {
     type Target = aws_sdk_s3::types::DataRedundancy;
     type Error = S3Error;

crates/s3s-aws/src/conv/generated_minio.rs

@@ -1316,6 +1316,58 @@ impl AwsConversion for s3s::dto::CreateMultipartUploadOutput {
     }
 }
 
+impl AwsConversion for s3s::dto::CreateSessionInput {
+    type Target = aws_sdk_s3::operation::create_session::CreateSessionInput;
+    type Error = S3Error;
+
+    fn try_from_aws(x: Self::Target) -> S3Result<Self> {
+        Ok(Self {
+            bucket: unwrap_from_aws(x.bucket, "bucket")?,
+            bucket_key_enabled: try_from_aws(x.bucket_key_enabled)?,
+            ssekms_encryption_context: try_from_aws(x.ssekms_encryption_context)?,
+            ssekms_key_id: try_from_aws(x.ssekms_key_id)?,
+            server_side_encryption: try_from_aws(x.server_side_encryption)?,
+            session_mode: try_from_aws(x.session_mode)?,
+        })
+    }
+
+    fn try_into_aws(x: Self) -> S3Result<Self::Target> {
+        let mut y = Self::Target::builder();
+        y = y.set_bucket(Some(try_into_aws(x.bucket)?));
+        y = y.set_bucket_key_enabled(try_into_aws(x.bucket_key_enabled)?);
+        y = y.set_ssekms_encryption_context(try_into_aws(x.ssekms_encryption_context)?);
+        y = y.set_ssekms_key_id(try_into_aws(x.ssekms_key_id)?);
+        y = y.set_server_side_encryption(try_into_aws(x.server_side_encryption)?);
+        y = y.set_session_mode(try_into_aws(x.session_mode)?);
+        y.build().map_err(S3Error::internal_error)
+    }
+}
+
+impl AwsConversion for s3s::dto::CreateSessionOutput {
+    type Target = aws_sdk_s3::operation::create_session::CreateSessionOutput;
+    type Error = S3Error;
+
+    fn try_from_aws(x: Self::Target) -> S3Result<Self> {
+        Ok(Self {
+            bucket_key_enabled: try_from_aws(x.bucket_key_enabled)?,
+            credentials: unwrap_from_aws(x.credentials, "credentials")?,
+            ssekms_encryption_context: try_from_aws(x.ssekms_encryption_context)?,
+            ssekms_key_id: try_from_aws(x.ssekms_key_id)?,
+            server_side_encryption: try_from_aws(x.server_side_encryption)?,
+        })
+    }
+
+    fn try_into_aws(x: Self) -> S3Result<Self::Target> {
+        let mut y = Self::Target::builder();
+        y = y.set_bucket_key_enabled(try_into_aws(x.bucket_key_enabled)?);
+        y = y.set_credentials(Some(try_into_aws(x.credentials)?));
+        y = y.set_ssekms_encryption_context(try_into_aws(x.ssekms_encryption_context)?);
+        y = y.set_ssekms_key_id(try_into_aws(x.ssekms_key_id)?);
+        y = y.set_server_side_encryption(try_into_aws(x.server_side_encryption)?);
+        Ok(y.build())
+    }
+}
+
 impl AwsConversion for s3s::dto::DataRedundancy {
     type Target = aws_sdk_s3::types::DataRedundancy;
     type Error = S3Error;

crates/s3s-aws/src/proxy/generated.rs

@@ -241,6 +241,32 @@ impl S3 for Proxy {
         }
     }
 
+    #[tracing::instrument(skip(self, req))]
+    async fn create_session(
+        &self,
+        req: S3Request<s3s::dto::CreateSessionInput>,
+    ) -> S3Result<S3Response<s3s::dto::CreateSessionOutput>> {
+        let input = req.input;
+        debug!(?input);
+        let mut b = self.0.create_session();
+        b = b.set_bucket(Some(try_into_aws(input.bucket)?));
+        b = b.set_bucket_key_enabled(try_into_aws(input.bucket_key_enabled)?);
+        b = b.set_ssekms_encryption_context(try_into_aws(input.ssekms_encryption_context)?);
+        b = b.set_ssekms_key_id(try_into_aws(input.ssekms_key_id)?);
+        b = b.set_server_side_encryption(try_into_aws(input.server_side_encryption)?);
+        b = b.set_session_mode(try_into_aws(input.session_mode)?);
+        let result = b.send().await;
+        match result {
+            Ok(output) => {
+                let headers = super::meta::build_headers(&output)?;
+                let output = try_from_aws(output)?;
+                debug!(?output);
+                Ok(S3Response::with_headers(output, headers))
+            }
+            Err(e) => Err(wrap_sdk_error!(e)),
+        }
+    }
+
     #[tracing::instrument(skip(self, req))]
     async fn delete_bucket(
         &self,

crates/s3s-aws/src/proxy/generated_minio.rs

@@ -241,6 +241,32 @@ impl S3 for Proxy {
         }
     }
 
+    #[tracing::instrument(skip(self, req))]
+    async fn create_session(
+        &self,
+        req: S3Request<s3s::dto::CreateSessionInput>,
+    ) -> S3Result<S3Response<s3s::dto::CreateSessionOutput>> {
+        let input = req.input;
+        debug!(?input);
+        let mut b = self.0.create_session();
+        b = b.set_bucket(Some(try_into_aws(input.bucket)?));
+        b = b.set_bucket_key_enabled(try_into_aws(input.bucket_key_enabled)?);
+        b = b.set_ssekms_encryption_context(try_into_aws(input.ssekms_encryption_context)?);
+        b = b.set_ssekms_key_id(try_into_aws(input.ssekms_key_id)?);
+        b = b.set_server_side_encryption(try_into_aws(input.server_side_encryption)?);
+        b = b.set_session_mode(try_into_aws(input.session_mode)?);
+        let result = b.send().await;
+        match result {
+            Ok(output) => {
+                let headers = super::meta::build_headers(&output)?;
+                let output = try_from_aws(output)?;
+                debug!(?output);
+                Ok(S3Response::with_headers(output, headers))
+            }
+            Err(e) => Err(wrap_sdk_error!(e)),
+        }
+    }
+
     #[tracing::instrument(skip(self, req))]
     async fn delete_bucket(
         &self,

crates/s3s/src/access/generated.rs

@@ -72,6 +72,13 @@ pub trait S3Access: Send + Sync + 'static {
         Ok(())
     }
 
+    /// Checks whether the CreateSession request has accesses to the resources.
+    ///
+    /// This method returns `Ok(())` by default.
+    async fn create_session(&self, _req: &mut S3Request<CreateSessionInput>) -> S3Result<()> {
+        Ok(())
+    }
+
     /// Checks whether the DeleteBucket request has accesses to the resources.
     ///
     /// This method returns `Ok(())` by default.

crates/s3s/src/access/generated_minio.rs

@@ -72,6 +72,13 @@ pub trait S3Access: Send + Sync + 'static {
         Ok(())
     }
 
+    /// Checks whether the CreateSession request has accesses to the resources.
+    ///
+    /// This method returns `Ok(())` by default.
+    async fn create_session(&self, _req: &mut S3Request<CreateSessionInput>) -> S3Result<()> {
+        Ok(())
+    }
+
     /// Checks whether the DeleteBucket request has accesses to the resources.
     ///
     /// This method returns `Ok(())` by default.