destination-s3: convert prod code to kotlin

airbyte-integrations/connectors/destination-s3/metadata.yaml

@@ -2,7 +2,7 @@ data:
   connectorSubtype: file
   connectorType: destination
   definitionId: 4816b78f-1489-44c1-9060-4b19d5fa9362
-  dockerImageTag: 0.6.2
+  dockerImageTag: 0.6.3
   dockerRepository: airbyte/destination-s3
   githubIssueLabel: destination-s3
   icon: s3.svg

airbyte-integrations/connectors/destination-s3/src/main/kotlin/io/airbyte/integrations/destination/s3/S3Destination.kt

@@ -0,0 +1,32 @@
+/*
+ * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+ */
+package io.airbyte.integrations.destination.s3
+
+import com.google.common.annotations.VisibleForTesting
+import io.airbyte.cdk.integrations.base.IntegrationRunner
+import io.airbyte.cdk.integrations.destination.s3.BaseS3Destination
+import io.airbyte.cdk.integrations.destination.s3.S3DestinationConfigFactory
+import io.airbyte.cdk.integrations.destination.s3.StorageProvider
+
+open class S3Destination : BaseS3Destination {
+    constructor()
+
+    @VisibleForTesting
+    constructor(
+        s3DestinationConfigFactory: S3DestinationConfigFactory,
+        env: Map<String, String>
+    ) : super(s3DestinationConfigFactory, env)
+
+    override fun storageProvider(): StorageProvider {
+        return StorageProvider.AWS_S3
+    }
+
+    companion object {
+        @Throws(Exception::class)
+        @JvmStatic
+        fun main(args: Array<String>) {
+            IntegrationRunner(S3Destination()).run(args)
+        }
+    }
+}

airbyte-integrations/connectors/destination-s3/src/main/kotlin/io/airbyte/integrations/destination/s3/S3DestinationRunner.kt

@@ -0,0 +1,17 @@
+/*
+ * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+ */
+package io.airbyte.integrations.destination.s3
+
+import io.airbyte.cdk.integrations.base.adaptive.AdaptiveDestinationRunner.baseOnEnv
+
+object S3DestinationRunner {
+    @Throws(Exception::class)
+    @JvmStatic
+    fun main(args: Array<String>) {
+        baseOnEnv()
+            .withOssDestination { S3Destination() }
+            .withCloudDestination { S3DestinationStrictEncrypt() }
+            .run(args)
+    }
+}

airbyte-integrations/connectors/destination-s3/src/main/kotlin/io/airbyte/integrations/destination/s3/S3DestinationStrictEncrypt.kt

@@ -0,0 +1,33 @@
+/*
+ * Copyright (c) 2023 Airbyte, Inc., all rights reserved.
+ */
+package io.airbyte.integrations.destination.s3
+
+import com.fasterxml.jackson.databind.JsonNode
+import com.google.common.annotations.VisibleForTesting
+import io.airbyte.cdk.integrations.destination.s3.S3BaseChecks.testCustomEndpointSecured
+import io.airbyte.cdk.integrations.destination.s3.S3DestinationConfigFactory
+import io.airbyte.protocol.models.v0.AirbyteConnectionStatus
+
+class S3DestinationStrictEncrypt : S3Destination {
+    constructor() : super()
+
+    @VisibleForTesting
+    constructor(
+        configFactory: S3DestinationConfigFactory,
+        environment: Map<String, String>
+    ) : super(configFactory, environment)
+
+    override fun check(config: JsonNode): AirbyteConnectionStatus? {
+        val destinationConfig =
+            configFactory.getS3DestinationConfig(config, super.storageProvider(), super.environment)
+
+        // Fails early to avoid extraneous validations checks if custom endpoint is not secure
+        if (!testCustomEndpointSecured(destinationConfig.endpoint)) {
+            return AirbyteConnectionStatus()
+                .withStatus(AirbyteConnectionStatus.Status.FAILED)
+                .withMessage("Custom endpoint does not use HTTPS")
+        }
+        return super.check(config)
+    }
+}

docs/integrations/destinations/s3.md

@@ -514,6 +514,7 @@ To see connector limitations, or troubleshoot your S3 connector, see more [in ou
 
 | Version | Date       | Pull Request                                               | Subject                                                                                                                                              |
 | :------ | :--------- | :--------------------------------------------------------- | :--------------------------------------------------------------------------------------------------------------------------------------------------- |
+| 0.6.3   | 2024-04-15 | [38204](https://github.com/airbytehq/airbyte/pull/38204)   | convert all production code to kotlin                                                                                                                                 |
 | 0.6.2   | 2024-04-15 | [38204](https://github.com/airbytehq/airbyte/pull/38204)   | add assume role auth                                                                                                                                 |
 | 0.6.1   | 2024-04-08 | [37546](https://github.com/airbytehq/airbyte/pull/37546)   | Adapt to CDK 0.30.8;                                                                                                                                 |
 | 0.6.0   | 2024-04-08 | [36869](https://github.com/airbytehq/airbyte/pull/36869)   | Adapt to CDK 0.29.8; Kotlin converted code.                                                                                                          |