yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Merge pull request #7670 from DDDHuang/api_required_ddd 

fix: auto sub & banned & topics rewrite, add required
This commit is contained in:
lafirest 2022-04-19 17:38:03 +08:00 committed by GitHub
parent 86e8498bce 39d3d6a3d3
commit 2cc8df24f7
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 7 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
apps/emqx_auto_subscribe/src/emqx_auto_subscribe_schema.erl
View File

@ -38,6 +38,7 @@ fields("auto_subscribe") ->
fields("topic") ->
[ {topic, sc(binary(), #{
required => true,
example => topic_example(),
desc => ?DESC("topic")})}
, {qos, sc(emqx_schema:qos(), #{

2
apps/emqx_management/src/emqx_mgmt_api_banned.erl
View File

@ -87,12 +87,14 @@ schema("/banned/:as/:who") ->
{as,
hoconsc:mk(hoconsc:enum(?BANNED_TYPES), #{
desc => ?DESC(as),
required => true,
in => path,
example => username
})},
{who,
hoconsc:mk(binary(), #{
desc => ?DESC(who),
required => true,
in => path,
example => <<"Badass">>
})}

7
apps/emqx_modules/src/emqx_modules_schema.erl
View File

@ -51,17 +51,17 @@ fields("rewrite") ->
{action,
sc(
hoconsc:enum([subscribe, publish, all]),
#{desc => ?DESC(tr_action), example => publish}
#{required => true, desc => ?DESC(tr_action), example => publish}
)},
{source_topic,
sc(
binary(),
#{desc => ?DESC(tr_source_topic), example => "x/#"}
#{required => true, desc => ?DESC(tr_source_topic), example => "x/#"}
)},
{dest_topic,
sc(
binary(),
#{desc => ?DESC(tr_dest_topic), example => "z/y/$1"}
#{required => true, desc => ?DESC(tr_dest_topic), example => "z/y/$1"}
)},
{re, fun regular_expression/1}
];
@ -80,6 +80,7 @@ desc(_) ->
undefined.
regular_expression(type) -> binary();
regular_expression(required) -> true;
regular_expression(desc) -> ?DESC(tr_re);
regular_expression(example) -> "^x/y/(.+)$";
regular_expression(validator) -> fun is_re/1;