jprdonnelly/airbyte
1
0
Fork 0
mirror of synced 2025-12-25 02:09:19 -05:00
Code Issues Packages Projects Releases Wiki Activity

Make error more descriptive in case of no encryption state (#17299)

Browse Source 
* Make error more descriptive in case of no encryption state

* Fix failing test

* Change error message on strict-encrypt postgres destination as well. Fix failing test

* update versions and changelogs

* auto-bump connector version [ci skip]

* auto-bump connector version [ci skip]

* auto-bump connector version [ci skip]

Co-authored-by: Octavia Squidington III <octavia-squidington-iii@users.noreply.github.com>
This commit is contained in:
Rodi Reich Zilberman
2022-09-28 15:26:09 -07:00
committed by GitHub
parent 42800f7b37
commit 248da78ba7
18 changed files with 85 additions and 80 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
airbyte-integrations/connectors/destination-postgres-strict-encrypt/Dockerfile
View File

@@ -16,5 +16,5 @@ ENV APPLICATION destination-postgres-strict-encrypt
COPY --from=build /airbyte /airbyte
LABEL io.airbyte.version=0.3.25
LABEL io.airbyte.version=0.3.26
LABEL io.airbyte.name=airbyte/destination-postgres-strict-encrypt

2
airbyte-integrations/connectors/destination-postgres-strict-encrypt/src/main/java/io/airbyte/integrations/destination/postgres/PostgresDestinationStrictEncrypt.java
View File

@@ -54,7 +54,7 @@ public class PostgresDestinationStrictEncrypt extends SpecModifyingDestination i
//Fail in case SSL mode is disable, allow or prefer
return new AirbyteConnectionStatus()
.withStatus(Status.FAILED)
.withMessage("Unsecured connection not allowed");
.withMessage("Unsecured connection not allowed. If no SSH Tunnel set up, please use one of the following SSL modes: require, verify-ca, verify-full");
}
}
}

3
airbyte-integrations/connectors/destination-postgres-strict-encrypt/src/test-integration/java/io/airbyte/integrations/destination/postgres/PostgresDestinationStrictEncryptAcceptanceTest.java
View File

@@ -7,6 +7,7 @@ package io.airbyte.integrations.destination.postgres;
import static io.airbyte.db.PostgresUtils.getCertificate;
import static org.junit.jupiter.api.Assertions.assertEquals;
import static org.junit.jupiter.api.Assertions.assertNull;
import static org.junit.jupiter.api.Assertions.assertTrue;
import com.fasterxml.jackson.databind.JsonNode;
import com.google.common.collect.ImmutableMap;
@@ -181,7 +182,7 @@ public class PostgresDestinationStrictEncryptAcceptanceTest extends DestinationA
final var actual = runCheck(config);
assertEquals(Status.FAILED, actual.getStatus());
assertEquals("Unsecured connection not allowed", actual.getMessage());
assertTrue(actual.getMessage().contains("Unsecured connection not allowed"));
}
@Test