[Merged by Bors] - Bugfix: S3 endpoint protocol selection.

CHANGELOG.md

@@ -4,6 +4,14 @@ All notable changes to this project will be documented in this file.
 
 ## [Unreleased]
 
+### Changed
+
+- BREAKING: Removed commons::s3::S3ConnectionImplementation.
+            commons::s3::InlinedBucketSpec::endpoint() doesn't take arguments since the protocol
+            decision is now based on the existance of TLS configuration ([#390]).
+
+[#390]: https://github.com/stackabletech/operator-rs/issues/390
+
 ## [0.18.0] - 2022-05-04
 
 ### Added

src/commons/s3.rs

@@ -77,12 +77,15 @@ pub struct InlinedS3BucketSpec {
 
 impl InlinedS3BucketSpec {
     /// Build the endpoint URL from [S3ConnectionSpec::host] and [S3ConnectionSpec::port] and the S3 implementation to use
-    pub fn endpoint(&self, implementation: &S3ConnectionImplementation) -> Option<String> {
-        let implementation = implementation.to_string();
+    pub fn endpoint(&self) -> Option<String> {
+        let protocol = match self.connection.as_ref().and_then(|c| c.tls.as_ref()) {
+            Some(_tls) => "https",
+            _ => "http",
+        };
         self.connection.as_ref().and_then(|connection| {
             connection.host.as_ref().map(|h| match connection.port {
-                Some(p) => format!("{implementation}://{h}:{p}"),
-                None => format!("{implementation}://{h}"),
+                Some(p) => format!("{protocol}://{h}:{p}"),
+                None => format!("{protocol}://{h}"),
             })
         })
     }
@@ -96,24 +99,6 @@ impl InlinedS3BucketSpec {
     }
 }
 
-/// The implementation the product should use when interacting with S3
-/// It is sometimes called protocol as it is prepended to the connection endpoint, e.g. `s3a://<host>`
-/// but it often specifies which s3 client implemtation to use, the used protocol on the wire is always S3.
-/// Spark e.g. supports `s3a` and `cos` as S3 connectors/implementations, which are different implementations but talk to the same S3 endpoint.
-pub enum S3ConnectionImplementation {
-    S3,
-    S3a,
-}
-
-impl ToString for S3ConnectionImplementation {
-    fn to_string(&self) -> String {
-        match self {
-            S3ConnectionImplementation::S3 => "s3".to_string(),
-            S3ConnectionImplementation::S3a => "s3a".to_string(),
-        }
-    }
-}
-
 /// Operators are expected to define fields for this type in order to work with S3 buckets.
 #[derive(Clone, Debug, Deserialize, JsonSchema, PartialEq, Serialize)]
 #[serde(rename_all = "camelCase")]