From da87abd9c847c7872f95dc0cdf58223b16552c9b Mon Sep 17 00:00:00 2001 From: Kjell Winblad Date: Tue, 12 Mar 2024 11:01:15 +0100 Subject: [PATCH] fix(HStreamDB bridge/action): restrict configuration parameters This commit restricts a few HStreamDB bridge/action parameters from being any integer to being integers greater than 0. Lower values than 1 for these parameters resulted in runtime errors. Fixes: https://emqx.atlassian.net/browse/EMQX-11939 --- .../src/emqx_bridge_hstreamdb.erl | 10 ++++++---- 1 file changed, 6 insertions(+), 4 deletions(-) diff --git a/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb.erl b/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb.erl index d66077171..e4b5c9ed7 100644 --- a/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb.erl +++ b/apps/emqx_bridge_hstreamdb/src/emqx_bridge_hstreamdb.erl @@ -173,14 +173,16 @@ fields(action_parameters) -> {record_template, mk(binary(), #{default => <<"${payload}">>, desc => ?DESC("record_template")})}, {aggregation_pool_size, - mk(integer(), #{ + mk(pos_integer(), #{ default => ?DEFAULT_AGG_POOL_SIZE, desc => ?DESC("aggregation_pool_size") })}, {max_batches, - mk(integer(), #{default => ?DEFAULT_MAX_BATCHES, desc => ?DESC("max_batches")})}, + mk(pos_integer(), #{default => ?DEFAULT_MAX_BATCHES, desc => ?DESC("max_batches")})}, {writer_pool_size, - mk(integer(), #{default => ?DEFAULT_WRITER_POOL_SIZE, desc => ?DESC("writer_pool_size")})}, - {batch_size, mk(integer(), #{default => 100, desc => ?DESC("batch_size")})}, + mk(pos_integer(), #{ + default => ?DEFAULT_WRITER_POOL_SIZE, desc => ?DESC("writer_pool_size") + })}, + {batch_size, mk(pos_integer(), #{default => 100, desc => ?DESC("batch_size")})}, {batch_interval, mk(emqx_schema:timeout_duration_ms(), #{ default => ?DEFAULT_BATCH_INTERVAL_RAW, desc => ?DESC("batch_interval")