From 8194427cb3227fae43233da84de477c5969751b4 Mon Sep 17 00:00:00 2001
From: JianBo He <heeejianbo@gmail.com>
Date: Thu, 16 Jun 2022 10:04:07 +0800
Subject: [PATCH] chore(pgsql): mapping ssl option from 'true' to 'required'

Once the pgsql client is configured with ssl, we should force ssl to be used to
avoid fallback to tcp connection.
---
 apps/emqx_connector/src/emqx_connector_pgsql.erl | 9 +++++++--
 1 file changed, 7 insertions(+), 2 deletions(-)

diff --git a/apps/emqx_connector/src/emqx_connector_pgsql.erl b/apps/emqx_connector/src/emqx_connector_pgsql.erl
index 85d3d327e..448cbb209 100644
--- a/apps/emqx_connector/src/emqx_connector_pgsql.erl
+++ b/apps/emqx_connector/src/emqx_connector_pgsql.erl
@@ -186,8 +186,13 @@ conn_opts([], Acc) ->
     Acc;
 conn_opts([Opt = {database, _} | Opts], Acc) ->
     conn_opts(Opts, [Opt | Acc]);
-conn_opts([Opt = {ssl, _} | Opts], Acc) ->
-    conn_opts(Opts, [Opt | Acc]);
+conn_opts([{ssl, Bool} | Opts], Acc) when is_boolean(Bool) ->
+    Flag =
+        case Bool of
+            true -> required;
+            false -> false
+        end,
+    conn_opts(Opts, [{ssl, Flag} | Acc]);
 conn_opts([Opt = {port, _} | Opts], Acc) ->
     conn_opts(Opts, [Opt | Acc]);
 conn_opts([Opt = {timeout, _} | Opts], Acc) ->