From a77bb994e120fe6aa8d26427a6a4c37b219da0ff Mon Sep 17 00:00:00 2001
From: Zhongwen Deng <zhongwencool@gmail.com>
Date: Sun, 24 Apr 2022 11:52:06 +0800
Subject: [PATCH] fix: add timeout for schema json gen test

---
 apps/emqx/src/emqx_schema.erl                 | 38 +++++++++----------
 .../emqx_conf/test/emqx_conf_schema_tests.erl | 24 +++++++++---
 .../emqx_enterprise_conf_schema_tests.erl     | 24 +++++++++---
 3 files changed, 55 insertions(+), 31 deletions(-)

diff --git a/apps/emqx/src/emqx_schema.erl b/apps/emqx/src/emqx_schema.erl
index ff95414f8..7e72f52df 100644
--- a/apps/emqx/src/emqx_schema.erl
+++ b/apps/emqx/src/emqx_schema.erl
@@ -841,30 +841,30 @@ fields("mqtt_quic_listener") ->
         {"enabled",
             sc(
                 boolean(),
-                #{ default => true
-                 , desc => ?DESC(fields_mqtt_quic_listener_enabled)
-                 }
+                #{
+                    default => true,
+                    desc => ?DESC(fields_mqtt_quic_listener_enabled)
+                }
             )},
         %% TODO: ensure cacertfile is configurable
         {"certfile",
             sc(
                 string(),
-                #{ desc => ?DESC(fields_mqtt_quic_listener_certfile)
-                 }
+                #{desc => ?DESC(fields_mqtt_quic_listener_certfile)}
             )},
         {"keyfile",
             sc(
                 string(),
-                #{ desc => ?DESC(fields_mqtt_quic_listener_keyfile)
-                 }
+                #{desc => ?DESC(fields_mqtt_quic_listener_keyfile)}
             )},
         {"ciphers", ciphers_schema(quic)},
         {"idle_timeout",
             sc(
                 duration(),
-                #{ default => "15s"
-                 , desc => ?DESC(fields_mqtt_quic_listener_idle_timeout)
-                 }
+                #{
+                    default => "15s",
+                    desc => ?DESC(fields_mqtt_quic_listener_idle_timeout)
+                }
             )}
     ] ++ base_listener();
 fields("ws_opts") ->
@@ -1008,20 +1008,17 @@ fields("tcp_opts") ->
         {"recbuf",
             sc(
                 bytesize(),
-                #{ desc => ?DESC(fields_tcp_opts_recbuf)
-                 }
+                #{desc => ?DESC(fields_tcp_opts_recbuf)}
             )},
         {"sndbuf",
             sc(
                 bytesize(),
-                #{ desc => ?DESC(fields_tcp_opts_sndbuf)
-                 }
+                #{desc => ?DESC(fields_tcp_opts_sndbuf)}
             )},
         {"buffer",
             sc(
                 bytesize(),
-                #{ desc => ?DESC(fields_tcp_opts_buffer)
-                 }
+                #{desc => ?DESC(fields_tcp_opts_buffer)}
             )},
         {"high_watermark",
             sc(
@@ -1075,8 +1072,7 @@ fields("deflate_opts") ->
         {"level",
             sc(
                 hoconsc:enum([none, default, best_compression, best_speed]),
-                #{ desc => ?DESC(fields_deflate_opts_level)
-                 }
+                #{desc => ?DESC(fields_deflate_opts_level)}
             )},
         {"mem_level",
             sc(
@@ -1089,8 +1085,7 @@ fields("deflate_opts") ->
         {"strategy",
             sc(
                 hoconsc:enum([default, filtered, huffman_only, rle]),
-                #{ desc => ?DESC(fields_deflate_opts_strategy)
-                 }
+                #{desc => ?DESC(fields_deflate_opts_strategy)}
             )},
         {"server_context_takeover",
             sc(
@@ -1954,7 +1949,8 @@ ciphers_schema(Default) ->
                     true -> undefined;
                     false -> fun validate_ciphers/1
                 end,
-            desc_id => "ciphers_schema_" ++ case Default of
+            desc_id => "ciphers_schema_" ++
+                case Default of
                     quic -> "quic";
                     _ -> "0"
                 end,
diff --git a/apps/emqx_conf/test/emqx_conf_schema_tests.erl b/apps/emqx_conf/test/emqx_conf_schema_tests.erl
index b222a49ae..af70d2a94 100644
--- a/apps/emqx_conf/test/emqx_conf_schema_tests.erl
+++ b/apps/emqx_conf/test/emqx_conf_schema_tests.erl
@@ -7,8 +7,22 @@
 -include_lib("eunit/include/eunit.hrl").
 
 doc_gen_test() ->
-    Dir = "tmp",
-    ok = filelib:ensure_dir(filename:join("tmp", foo)),
-    I18nFile = filename:join(["_build", "test", "lib", "emqx_dashboard", "etc", "i18n.conf.all"]),
-    _ = emqx_conf:dump_schema(Dir, emqx_conf_schema, I18nFile),
-    ok.
+    %% the json file too large to encode.
+    {
+        timeout,
+        60,
+        fun() ->
+            Dir = "tmp",
+            ok = filelib:ensure_dir(filename:join("tmp", foo)),
+            I18nFile = filename:join([
+                "_build",
+                "test",
+                "lib",
+                "emqx_dashboard",
+                "etc",
+                "i18n.conf.all"
+            ]),
+            _ = emqx_conf:dump_schema(Dir, emqx_conf_schema, I18nFile),
+            ok
+        end
+    }.
diff --git a/lib-ee/emqx_enterprise_conf/test/emqx_enterprise_conf_schema_tests.erl b/lib-ee/emqx_enterprise_conf/test/emqx_enterprise_conf_schema_tests.erl
index 10c5998db..94d180377 100644
--- a/lib-ee/emqx_enterprise_conf/test/emqx_enterprise_conf_schema_tests.erl
+++ b/lib-ee/emqx_enterprise_conf/test/emqx_enterprise_conf_schema_tests.erl
@@ -7,8 +7,22 @@
 -include_lib("eunit/include/eunit.hrl").
 
 doc_gen_test() ->
-    Dir = "tmp",
-    ok = filelib:ensure_dir(filename:join("tmp", foo)),
-    I18nFile = filename:join(["_build", "test", "lib", "emqx_dashboard", "etc", "i18n.conf.all"]),
-    _ = emqx_conf:dump_schema(Dir, emqx_enterprise_conf_schema, I18nFile),
-    ok.
+    %% the json file too large to encode.
+    {
+        timeout,
+        60,
+        fun() ->
+            Dir = "tmp",
+            ok = filelib:ensure_dir(filename:join("tmp", foo)),
+            I18nFile = filename:join([
+                "_build",
+                "test",
+                "lib",
+                "emqx_dashboard",
+                "etc",
+                "i18n.conf.all"
+            ]),
+            _ = emqx_conf:dump_schema(Dir, emqx_enterprise_conf_schema, I18nFile),
+            ok
+        end
+    }.