yuanbiao/emqx
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity
9,228 Commits 393 Branches 684 Tags 74 MiB
ee4673ee9c
Commit Graph

3591 Commits

Author SHA1 Message Date
zhongwencool
63b2501a1c
Merge pull request #7265 from DDDHuang/monitor_api_fix 
fix: monitor api query string param latest: legal & default value inf…
 2022-03-10 18:14:00 +08:00
lafirest
c8411e780f
Merge pull request #7267 from lafirest/fix/slow_subs_api 
fix(slow_subs): fix test case assert error
 2022-03-10 17:31:40 +08:00
JimMoen
93c74bd645
Merge pull request #7225 from JimMoen/authn-authz-mnesia-fuzzy-searching 
authn and authz mnesia searching by `clientid` or `username`
 2022-03-10 17:00:36 +08:00
lafirest
d66098470f fix(slow_subs): fix test case assert error 2022-03-10 16:45:43 +08:00
DDDHuang
03ca53d9b3 fix: monitor api query string param latest: legal & default value infinity 2022-03-10 16:40:40 +08:00
lafirest
2b2104851a fix(rewrite): fix config update maybe not work 2022-03-10 16:31:44 +08:00
Shawn
c673e55a47 fix(rule): add SQL test examples for user properties 
Porting from v4.4
 2022-03-10 16:01:30 +08:00
Shawn
247b14c95f fix(mqtt_bridge): refine the message format from a mqtt bridge source 2022-03-10 15:57:33 +08:00
DDDHuang
9fca6c18f6
Merge pull request #7257 from DDDHuang/re_username 
fix: users api, create illegal char username
 2022-03-10 14:46:51 +08:00
JimMoen
7274d775cb test(authz): api username fuzzy searching 2022-03-10 13:38:45 +08:00
Xinyu Liu
67e39150d0
Merge pull request #7251 from terry-xiaoyu/add_restart_bridge_api 
feat(bridge): add APIs for restart/stop bridges on one node
 2022-03-10 13:34:44 +08:00
Shawn
1d023b541f refactor(connnector): rename waiting_connect_complete -> wait_for_resource_ready 
Rename the option to wait_for_resource_ready and defaults to 5s.
 2022-03-10 10:46:57 +08:00
lafirest
8e2ff381a4 fix(slow_subs): fix response data type error 2022-03-10 10:26:16 +08:00
Shawn
a38cac0233 refactor(connector): rename list/0 -> list_raw/0 2022-03-10 10:02:06 +08:00
JimMoen
42df68ab51 test(authn): fix return type match, api fuzzy searching 2022-03-10 10:01:40 +08:00
JimMoen
990a66e1ad feat(gateway): gateway authn mnesia rows fuzzy searching by clientid or username 2022-03-10 10:01:40 +08:00
JimMoen
593e1a3efb feat(authn): authn mnesia rows fuzzy searching by clientid or username 2022-03-10 10:01:40 +08:00
JimMoen
16ec8fe289 feat(authz): authz mnesia rules searching by clientid or username 2022-03-10 10:01:40 +08:00
JimMoen
c01aa3c580 style(authz_mnesia): api spec style, rm duplicated module name 2022-03-10 10:01:40 +08:00
DDDHuang
f22f61ac66 fix: users api, create illegal char username 2022-03-10 09:58:42 +08:00
zhongwencool
f7ec74d367
Merge pull request #7248 from zhongwencool/improve-ct-coverage 
test: Improve test coverage
 2022-03-10 09:47:10 +08:00
JianBo He
0b6b2295a6
Merge pull request #7239 from HJianBo/mqttsn-alseep 
Support the client asleep mechanism for MQTT-SN gateway
 2022-03-10 09:35:45 +08:00
Zhongwen Deng
3aa7c3a8dd fix: elvis warning 2022-03-09 22:29:21 +08:00
JianBo He
98d2f80506
Merge pull request #7205 from HJianBo/redesign-event-msg 
Refactor `event_messages` with `sys_topics`
 2022-03-09 21:58:27 +08:00
Chris Hicks
7f31cd08a7
Merge pull request #7252 from mononym/mongodb-deadloop-fix 
fix: update mongodb client to latest version with deadloop fix
 2022-03-09 14:08:24 +01:00
Thales Macedo Garitezi
b231a13794
Merge pull request #7232 from thalesmg/rlog-default-db-backend2 
feat: use rlog db backend by default
 2022-03-09 08:56:04 -03:00
Zhongwen Deng
7beaa91814 fix: schema mod error 2022-03-09 19:24:33 +08:00
Chris
b383e68c94 fix: update mongodb client to latest version with deadloop fix 2022-03-09 11:59:37 +01:00
Shawn
50d0a3271b fix(test): add testcases for enable/disbale bridges 2022-03-09 18:49:30 +08:00
Shawn
36e068d00d feat(bridge): add APIs for restart/stop bridges on one node 2022-03-09 18:42:19 +08:00
Xinyu Liu
e0557551aa
Merge pull request #7156 from EMQ-YangM/upm2 
fix(emqx_resource): remove async_create option
 2022-03-09 17:57:15 +08:00
JianBo He
724d51a024 fix(mqttsn): fix flaky test 2022-03-09 17:11:09 +08:00
JianBo He
f90b27c291 fix(exproto): filter out ssl options if it disabled 2022-03-09 16:47:45 +08:00
JianBo He
321ad09882 chore: fix elvis warnings 2022-03-09 16:46:19 +08:00
EMQ-YangM
b7674fd19f fix(emqx_authz_file_SUITE): fix config_update_crashed error 2022-03-09 16:35:30 +08:00
Zhongwen Deng
7942de53a0 chore: fix elvis warning 2022-03-09 16:07:01 +08:00
Zhongwen Deng
0ec8c528a0 test: add more test for cluster_rpc_handler/api_configs/api_trace 2022-03-09 16:03:28 +08:00
Zhongwen Deng
414d29c413 chore: add label field for schema.json. 2022-03-09 14:40:14 +08:00
EMQ-YangM
583624fb8d fix(emqx_authn): fix test suite 2022-03-09 13:53:05 +08:00
JianBo He
857bd1e12a test(exhook): remove helpless test case 2022-03-09 13:50:17 +08:00
JianBo He
0c8d739e2f test: change assert condition 2022-03-09 13:50:17 +08:00
JianBo He
6dac422c93 chore: rename sys_topic to sys_topics 2022-03-09 13:50:17 +08:00
JianBo He
ecc8d92e6c test(sys): refine prop_emqx_sys 2022-03-09 13:50:16 +08:00
JianBo He
ba6cfd595b feat(sys): support client events notification 2022-03-09 13:50:16 +08:00
JianBo He
e72e49b291 chore: fix elvis warnings 2022-03-09 13:46:58 +08:00
JianBo He
5436a3c496 chore(gw): use emqx_gateway_cm:call/4 instead ConnMod:call/3 2022-03-09 13:46:56 +08:00
JianBo He
9422ac4bc1 fix(mqttsn): fix unused variable 2022-03-09 12:57:51 +08:00
JianBo He
6ab993c3e8 test(mqttsn): uncomment asleep testcases 2022-03-09 12:57:51 +08:00
JianBo He
98b97ad217 feat(mqttsn): support asleep client 2022-03-09 12:57:51 +08:00
JianBo He
01eb3ca93a chore(mqttsn): fix frame formating crash 2022-03-09 12:57:51 +08:00
JianBo He
8ac0152af0 chore(gw): log SEND_data 2022-03-09 12:57:51 +08:00
lafirest
691588ed23
Merge pull request #7231 from lafirest/test/retainer_api_case 
test(retainer): fix the flaky case
 2022-03-09 12:33:44 +08:00
lafirest
3601d147e4 test(retainer): fix the flaky case 2022-03-09 10:12:49 +08:00
Thales Macedo Garitezi
a85d636a68
feat(rlog): use rlog as the default db backend 2022-03-08 13:34:05 -03:00
Thales Macedo Garitezi
14f7216033
style: please elvis checks 2022-03-08 13:34:03 -03:00
zhongwencool
514e374868
Merge pull request #7215 from thalesmg/fix-congestion-log 
fix(congestion): fix congestion message formatting
 2022-03-08 22:45:38 +08:00
zhongwencool
2ac5fb9223
Merge pull request #7202 from DDDHuang/routes_honc 
fix(api): routes api hocon support
 2022-03-08 22:35:37 +08:00
zhongwencool
a5b2300ce4
Merge pull request #7236 from zhongwencool/config-api 
feat(config): Filter unnecessary HTTP APIs
 2022-03-08 22:33:45 +08:00
Zhongwen Deng
512a5c3b8e fix: elvis warning 2022-03-08 14:50:10 +08:00
Zhongwen Deng
ef5fcd388b chore: delete unuse function gen_conf_schema. 2022-03-08 14:22:56 +08:00
Zhongwen Deng
1244391cb7 fix: alarm crash when safe_publish not ready. Filter out unnecessary APIs 2022-03-08 14:14:54 +08:00
EMQ-YangM
ca7a43986a fix(emqx_connector): restart with default wait_connected 2022-03-08 14:09:39 +08:00
EMQ-YangM
57adbab5ea fix(emqx_authn): fix authn suite status 2022-03-08 14:09:39 +08:00
EMQ-YangM
62d3aecc09 fix(emqx_connector): add default Opts: '#{wait_connected => 1000}' 2022-03-08 14:09:39 +08:00
EMQ-YangM
db0e9e3358 fix(emqx_resource_instance): fix dialyzer warning 2022-03-08 14:09:39 +08:00
EMQ-YangM
db97ed5163 fix(emqx_authz): add default wait_connected 2022-03-08 14:09:39 +08:00
EMQ-YangM
d99db4ebfa fix(emqx_authn): add default wait_connected 2022-03-08 14:09:39 +08:00
EMQ-YangM
f29877bb6a fix(emqx_resource): remove create_opts async_create 2022-03-08 14:09:39 +08:00
EMQ-YangM
bf57bf717c feat(emqx_resource_instance): add wait_connected Opts 2022-03-08 14:09:14 +08:00
Xinyu Liu
558441eeb7
Merge branch 'master' into improve_rule_bridge_apis 2022-03-08 11:38:42 +08:00
Xinyu Liu
591d5f02d1
Merge pull request #7227 from EMQ-YangM/upm4 
fix(emqx_bridge_api): fix aggregate_metrics
 2022-03-08 11:35:48 +08:00
Xinyu Liu
c5f92ef856
Merge branch 'master' into improve_rule_bridge_apis 2022-03-08 11:12:30 +08:00
Shawn
8a0565a53b chore(elvis): please the elvis 2022-03-08 11:11:29 +08:00
zhongwencool
2d9a086bbb
Merge pull request #7198 from zhongwencool/emqx-conf-ct-coverage 
chore: add more test for emqx_config_handler
 2022-03-08 10:04:02 +08:00
Zhongwen Deng
a7ba678463 fix: elvis warning 2022-03-08 09:05:23 +08:00
Zhongwen Deng
9b00f2756b feat: Make sure that Specify Key and ?WKEY cannot be on the same level. 2022-03-07 21:48:31 +08:00
Shawn
b20902ebfe fix: remove the Id field from response of GET, POST /connectors 2022-03-07 19:33:32 +08:00
Shawn
2897af9650 fix: update testcases for emqx_connector 2022-03-07 18:39:23 +08:00
Shawn
9a9c92ae88 fix: update testcases for emqx_bridge 2022-03-07 16:48:36 +08:00
EMQ-YangM
015027d44a fix(emqx_bridge_api): fix aggregate_metrics 2022-03-07 14:51:37 +08:00
Shawn
72409782eb fix: remove the Id field from response of GET, POST /bridges 
The response body of POST, GET /bridges should be the same as
 the request body of the POST /bridges:

```
{"type": "mqtt",
 "name": "my_mqtt_bridge"
}
```

We force the user to provide an Id of format `{type}:{name}` when GET,
DELETE, PUT a bridge:

`GET /bridges/{type}:{name}`
 2022-03-07 14:33:02 +08:00
DDDHuang
467dc7239e fix: rebase master & new code style 2022-03-07 09:41:32 +08:00
Thales Macedo Garitezi
3e08282ffb
chore: improve formatting 
Without `~0p`, had some weird indentation while printing
 2022-03-04 15:22:33 -03:00
Thales Macedo Garitezi
e76f67e985
style: please elvis checks 2022-03-04 11:14:13 -03:00
Thales Macedo Garitezi
0c76b6cf4d
fix(congestion): fix congestion message formatting 
It seems that the `~ts` in the format string does not handle maps,
which results in a crash when trying to format the congestion message.

```erlang
28> io_lib:format("~ts", [#{}]).
** exception error: bad argument
     in function  io_lib:format/2
        called as io_lib:format("~ts",[#{}])
```

Example:

```
2022-03-04T12:43:26.900609+00:00 [warning] '$kind': unclean_terminate, clientid: 192.168.2.116_bench_sub_11412_1782328074, context: badarg, exception: error, line: 582, mfa: emqx_connection:terminate/2, peername: 192.168.2.116:47358, stacktrace: [{io_lib,format,["connection congested: ~ts",[#{buffer => 4096,clientid => <<"192.168.2.116_bench_sub_11412_1782328074">>,conn_state => disconnected,connected_at => 1646397524470,high_msgq_watermark => 8192,high_watermark => 1048576,memory => 57064,message_queue_len => 20,peername => <<"192.168.2.116:47358">>,pid => <<"<0.259.28>">>,proto_name => <<"MQTT">>,proto_ver => 5,recbuf => 4096,recv_cnt => 2,recv_oct => 81,reductions => 267523,send_cnt => 333,send_oct => 149869,send_pend => 128,sndbuf => 332800,sockname => <<"10.10.1.13:1883">>,socktype => tcp,username => undefined}]],[{file,"io_lib.erl"},{line,187}]},{emqx_congestion,do_cancel_alarm_congestion,4,[{file,"/emqx/apps/emqx/src/emqx_congestion.erl"},{line,88}]},{lists,foreach,2,[{file,"lists.erl"},{line,1342}]},{emqx_connection,terminate,2,[{file,"/emqx/apps/emqx/src/emqx_connection.erl"},{line,576}]},{proc_lib,wake_up,3,[{file,"proc_lib.erl"},{line,236}]}]
```
 2022-03-04 11:00:49 -03:00
lafirest
e298ff9dca
Merge pull request #7206 from lafirest/coverage/retainer 
test(retainer): improve test coverage from 63% to 92%
 2022-03-04 16:34:20 +08:00
lafirest
c6385762c6 test(retainer): improve test coverage from 63% to 92% 2022-03-04 15:24:08 +08:00
Zhongwen Deng
6ff2db6180 fix: elvis warning 2022-03-04 15:10:10 +08:00
Zhongwen Deng
153e1bcb91 fix: pre_update_config is executed one more time than expected 2022-03-04 14:43:51 +08:00
JimMoen
f25da61f39 refactor(mgmt): Params => QString, QsScheam => QSchema 2022-03-04 11:14:03 +08:00
JimMoen
f8073002b6 fix(mgmt): better desc for fuzzy field 2022-03-04 10:06:36 +08:00
JimMoen
fab9ad91de fix(schema): nullable => required 2022-03-04 10:06:36 +08:00
Zhongwen Deng
e2f386383d fix: replace local ref by remote ref 2022-03-04 09:13:56 +08:00
Zhongwen Deng
71d20d153b fix: replace deep_merge with merge. 2022-03-03 22:52:46 +08:00
Zhongwen Deng
4dfcb90b16 fix: get_roots broken 2022-03-03 20:31:30 +08:00
Thales Macedo Garitezi
f3e7ec43dd
Merge pull request #7190 from thalesmg/fix-typos 
docs: fix a few typos
 2022-03-03 08:57:51 -03:00
Zhongwen Deng
a862eb0252 chore: add more test for emqx_config_handler 2022-03-03 17:39:32 +08:00
Ilya Averyanov
4b19fb575a
Merge pull request #7187 from savonarola/mongo-no-double-pooling 
chore(mongodb): do not use mongodb internal pool
 2022-03-03 11:47:41 +03:00
lafirest
c0df5cd80f
Merge pull request #7193 from lafirest/fix/retainer_api 
fix(retainer): fix config lookup error
 2022-03-03 10:58:35 +08:00
JianBo He
7ba1db759e
Merge pull request #7182 from HJianBo/mqttsn-replay-register 2022-03-03 10:55:45 +08:00