Commit Graph

3800 Commits

Author SHA1 Message Date
firest 114f676150 fix(limiter): make elvis happy 2022-03-18 18:04:47 +08:00
JimMoen ed021d125f fix(mongo): servers for mongo_sharded and mongo_rs 2022-03-18 17:58:27 +08:00
firest 5459e38e15 fix(retainer): don't translate config content, keep it in raw 2022-03-18 17:16:03 +08:00
EMQ-YangM 339e459589 fix(emqx_authn): disable invalid_dynamic_call
cc

aa
2022-03-18 17:07:56 +08:00
firest beba7c9692 fix(limiter): improve code style and description 2022-03-18 16:00:42 +08:00
firest d28b34f0d1 fix(limiter): improve test case and fix some bugs 2022-03-18 16:00:42 +08:00
firest 32030c8369 feat(limiter): remove the group(zone) level 2022-03-18 16:00:42 +08:00
lafirest e7dec7835f feat(limiter): change zone to group and simplify config 2022-03-18 16:00:42 +08:00
EMQ-YangM d1857ba454 feat: add authn, authz status api 2022-03-18 14:36:33 +08:00
lafirest d231b2222e
Merge pull request #7328 from lafirest/fix/delayed_lookup
fix(delayed): make it possible to lookup/delete other node's delayed …
2022-03-18 00:53:53 +08:00
Thales Macedo Garitezi 89c8ba7e1a
Merge pull request #7326 from thalesmg/bump-gen-rpc
chore: bump gen_rpc
2022-03-17 13:50:28 -03:00
JianBo He 43c01117bb fix(sn): fix typos 2022-03-17 18:40:13 +08:00
JianBo He fbc0240f26 feat(sn): introduce subs_resume option
As the mqtt-sn v1.2 spec metioned, the gateway will be able to sync the
subscriptions topic-name registry to client when the client resume
it's session

port from: https://github.com/emqx/emqx/pull/7300
2022-03-17 18:38:54 +08:00
firest 3fc4236565 fix(delayed): make it possible to lookup/delete other node's delayed message 2022-03-17 14:36:55 +08:00
lafirest 6453479f44
Merge pull request #7324 from lafirest/fix/delayed_terminate_v5
fix(delayed): cancel the publish timer when terminate
2022-03-17 10:55:56 +08:00
Thales Macedo Garitezi c45578c130
chore: bump gen_rpc 2022-03-16 15:20:13 -03:00
firest 43a935286a fix(delayed): cancel the publish timer when terminate 2022-03-16 17:51:29 +08:00
Zhongwen Deng 9c355994e9 fix: add apps error code. 2022-03-16 17:20:26 +08:00
Yang Miao e6fcef16ba
Merge pull request #7319 from EMQ-YangM/ignore_authz_authn_metrics_status
Ignore authz, authn metrics status
2022-03-16 14:41:37 +08:00
Xinyu Liu ef8ad9b1f0
Merge pull request #7314 from terry-xiaoyu/demo0315
Fix some issues in rule engine found in the demo session
2022-03-16 13:52:05 +08:00
EMQ-YangM 37c4d68f40 fix: ignore authn, authz status and metrics 2022-03-16 11:14:21 +08:00
EMQ-YangM eb5570dd07 fix: disable authn_api, authz_api_sources swagger spec 2022-03-16 10:16:50 +08:00
Shawn a892ff9006 fix(dialyzer): update the specs for the rule() 2022-03-16 10:13:16 +08:00
Zaiming (Stone) Shi 4fce9d4cc3
Merge pull request #7305 from zmstone/chore-split-ct-jobs
ci: run ct in concurrent jobs
2022-03-15 21:15:19 +01:00
Zaiming (Stone) Shi d9ebca3294 test: fix emqx_retainer_api_SUITE infinity wait for table 2022-03-15 20:40:28 +01:00
Zaiming (Stone) Shi 9d96d3d10a test: fix auto_subscribe test case 2022-03-15 20:40:28 +01:00
Zaiming (Stone) Shi 4a35aaa50e
Merge pull request #7304 from zmstone/update-emqtt-to-1.4.8
chore: update emqtt to 1.4.8
2022-03-15 17:50:38 +01:00
Shawn 93c5fa60b4 fix(rules): store rule configs to cluster config files 2022-03-16 00:39:01 +08:00
Shawn 869dc1a081 fix(rules): ensure create_at unchanged after rule is updated 2022-03-16 00:38:42 +08:00
Zaiming (Stone) Shi d7d0525733
Merge pull request #7313 from zmstone/chore-pin-ekka-0.12.2
chore: pin ekka 0.12.2
2022-03-15 14:30:18 +01:00
Ilya Averyanov 402cb9190f
Merge pull request #7312 from savonarola/fix-retainer-tests
chore(retainer): fix mqtt_v5 test suite
2022-03-15 16:26:43 +03:00
Thales Macedo Garitezi 58705a1383
Merge pull request #7289 from thalesmg/fix-ekka-monitor-cleanups
fix(ekka): run cleanups on node down events
2022-03-15 09:39:37 -03:00
Zaiming (Stone) Shi f8d8bcb8bc chore: pin ekka 0.12.2
with mnesia_down vs node_down fix
and fast rocksdb build
2022-03-15 12:16:47 +01:00
Zaiming (Stone) Shi 420ad32aa7 chore: update emqtt to 1.4.8 2022-03-15 12:11:44 +01:00
Ilya Averyanov b3193181b2 chore(retainer): fix mqtt_v5 test suite 2022-03-15 12:55:02 +03:00
JimMoen a04bb57c19
Merge pull request #7310 from JimMoen/enhanced-authn-mnesia-fuzzy-query
feat(authn): enhanced authn users fuzzy searching
2022-03-15 17:18:08 +08:00
Dmitrii 7dfdeb7136
Merge pull request #7302 from ieQu1/spellcheck
ci: Run spellcheck in CI
2022-03-15 09:32:01 +01:00
JimMoen a084376f3d feat(authn): enhanced authn users fuzzy searching 2022-03-15 15:14:14 +08:00
JimMoen e83357895c refactor(exhook): move command use macro 2022-03-15 11:14:49 +08:00
JimMoen 02ed2148d7 refactor: move api `top` -> `front`, `bottom` -> `rear` 2022-03-15 10:28:46 +08:00
JimMoen 2a866e7c91 test(authn_api): move authn resource position 2022-03-15 10:28:46 +08:00
JimMoen e96bbf5c8b refactor(authn_api): add 'after related' for move api 2022-03-15 10:28:46 +08:00
JimMoen dd1168d98a test(exhook_api): move exhook position 2022-03-15 10:28:46 +08:00
JimMoen 7f595f3988 refactor(exhook_api): unified move position style 2022-03-15 10:28:46 +08:00
JimMoen f6ee45b2e6 test(authz_api): authz sources move api style 2022-03-15 10:28:46 +08:00
JimMoen 68c473c7cc refactor(authz_api): authz sources move api style 2022-03-15 10:28:46 +08:00
ieQu1 960c5ad0d5 ci: Run spellcheck 2022-03-14 22:27:46 +01:00
Thales Macedo Garitezi 2748c22b0c
fix(ekka): run cleanups on node down events
When using the RLOG DB Backend with Mria, replicant nodes do not
generate `mnesia down` events.  Therefore, cleanup procedures that
some modules do when a node goes down do not work for replicants.

However, replicant do generate `node down` events, so that may be a
safer way to handle cleanup to take into account that type of node.
2022-03-14 15:55:58 -03:00
Chris e35796abb0 refactor: refactor mongo connector test suite 2022-03-14 16:21:16 +01:00
DDDHuang 910a0b9a77
Merge pull request #7301 from DDDHuang/bad_map_key
fix: dashboard monitor bad key spell
2022-03-14 22:04:05 +08:00
Xinyu Liu 2a2d63aa21
Merge pull request #7292 from EMQ-YangM/remove_metrics_and_status
fix: reduce status_and_metrics
2022-03-14 21:51:56 +08:00
ieQu1 4116d01bfb chore(schema): Fix code style 2022-03-14 14:38:37 +01:00
DDDHuang a6b7f51d96 fix: dashboard monitor bad key spell 2022-03-14 17:57:56 +08:00
ieQu1 a36a494373 docs(cluster): Fix some definitions 2022-03-14 10:36:09 +01:00
ieQu1 b79ef3f0d9 docs: Add documentation for the cluster 2022-03-14 10:36:09 +01:00
DDDHuang e67138a6a7 fix: trace data dir suffix 2022-03-14 16:15:53 +08:00
EMQ-YangM 258d2e9e03 fix(emqx_authz_api_sources): use merge replace foldl 2022-03-14 14:43:17 +08:00
EMQ-YangM 740b3870bf fix(elvis): nesting_level shouldn't exceed 6 2022-03-14 13:36:35 +08:00
EMQ-YangM b33b3f6eee fix: reduce status_and_metrics 2022-03-14 10:21:51 +08:00
Yang Miao 4c93a71446
Merge pull request #7290 from EMQ-YangM/add_metrics_and_status_to_authz
feat(emqx_authz): add metrics and status to authz
2022-03-14 09:34:11 +08:00
zhongwencool f0f03d8a96
Merge pull request #6566 from zhongwencool/plugin-http-api
Plugin http api
2022-03-14 09:17:11 +08:00
EMQ-YangM afc92798a5 fix(emqx_authz_api_sources): fix resource status 2022-03-13 16:01:33 +08:00
Zhongwen Deng 4cde1274c7 test: fix build demo plugins crash. 2022-03-13 16:00:58 +08:00
EMQ-YangM f287547251 feat(emqx_authz): add metrics and status to authz 2022-03-13 12:41:03 +08:00
Zhongwen Deng 141c3adc76 fix: ct failed 2022-03-12 09:23:38 +08:00
Xinyu Liu 24251aea5d
Merge pull request #7285 from JimMoen/fix-authz-test
test(authz): make sure `emqx_resource` and `emqx_connector` stoped
2022-03-12 00:37:26 +08:00
Zhongwen Deng 704d1b20c6 fix: add bpapi.versions 2022-03-12 00:29:18 +08:00
Zaiming (Stone) Shi acd9aaff4d
Merge pull request #7282 from zmstone/build-refine-systemd-service-unit
Start EMQX in foreground mode in systemd
2022-03-11 14:46:33 +01:00
Zhongwen Deng f195808691 fix: rpc call use emqx_bpapi behavior 2022-03-11 21:28:33 +08:00
Zaiming (Stone) Shi 4bc8f0d44b feat: allow enable/disable an existing logger file handler 2022-03-11 13:34:54 +01:00
Xinyu Liu 4025e79d1b
Merge pull request #7283 from terry-xiaoyu/default_value_for_rates
Fix HTTP APIs for getting rule events and testing rule SQLs
2022-03-11 20:17:58 +08:00
Shawn 92a9fe46ea fix(bridges): validate empty topics for mqtt bridge 2022-03-11 20:16:03 +08:00
Xinyu Liu 3cf18a293d
Merge pull request #7271 from EMQ-YangM/add_metrics_and_status_to_authn
feat(emqx_authn_api): add metrics and status to authn
2022-03-11 19:21:44 +08:00
JimMoen b41e396ed2 test(authz): make sure `emqx_resource` and `emqx_connector` stoped 2022-03-11 19:11:07 +08:00
Zhongwen Deng fd7f91b5a6 chore: fix dialyzer warning. 2022-03-11 18:41:20 +08:00
Shawn 0b4b3a7cf0 fix(dialyzer): some bad type specs 2022-03-11 18:33:08 +08:00
Shawn 590fa1b375 fix(rule): check request body for /rule_test crashes 2022-03-11 18:13:12 +08:00
zhongwencool 59b10fc80b
Merge pull request #7279 from zhongwencool/hot-conf-global-zone
feat: Hot conf global zone
2022-03-11 18:03:35 +08:00
EMQ-YangM 81f9482fac fix(bpapi): add authn bpapi version 2022-03-11 17:41:39 +08:00
JianBo He 97e1d249ad
Merge pull request #7264 from lafirest/fix/delayed_api
fix(delayed): fix that the query is not a cluster query
2022-03-11 16:07:53 +08:00
EMQ-YangM b7a9f1e087 fix(emqx_map_lib): fix static checks errors 2022-03-11 15:56:14 +08:00
zhongwencool 0f681f6a08 feat(plugin): add plugin http api test case 2022-03-11 15:55:02 +08:00
zhongwencool 7160bc06b3 feat(plugin): add plugin http api 2022-03-11 15:55:02 +08:00
zhongwencool dcc0ff673f fix(plugin): can't delete extra package 2022-03-11 15:55:02 +08:00
zhongwencool 1ef2b8d06c chore(test): delete plugin_template from plugins_SUITE 2022-03-11 15:55:02 +08:00
zhongwencool 3414e0b601 feat(plugin): http api 2022-03-11 15:55:02 +08:00
Zhongwen Deng ab10163abf chore: redefined qos 2022-03-11 15:27:40 +08:00
Zhongwen Deng 3938aa127b feat: add /configs/global_zones API to aggregate emqx_zone_schema 2022-03-11 15:27:40 +08:00
JianBo He 81ffa87354
Merge pull request #7276 from lafirest/test/mgmt_api_subs_cover
test(mgmt): improve test coverage of emqx_mgmt_api_subscription to 96%
2022-03-11 15:15:22 +08:00
JianBo He 85d1a4f9bf
Merge pull request #7263 from HJianBo/fix-auth-jwt
fix(authn-jwt): accept the pem conntet to create jwk authenticator
2022-03-11 15:06:43 +08:00
EMQ-YangM 8af7131a49 fix(emqx_autn_api): wo do not need fixpoint 2022-03-11 14:18:50 +08:00
EMQ-YangM 7165fbc5ca fix(emqx_authn_api): fix elvis error 2022-03-11 14:18:50 +08:00
EMQ-YangM 48b167bf46 test(emqx_authn): add status and metrics test to emqx_authn_api 2022-03-11 14:18:50 +08:00
EMQ-YangM dce602c251 fix(emqx_authn_api): format metrics and status 2022-03-11 14:18:15 +08:00
EMQ-YangM a03f324010 feat(emqx_authn_api): add metrics and status to authn 2022-03-11 14:18:15 +08:00
Shawn f924b9389d fix(rule): add swagger schema for events from bridge sources 2022-03-11 14:13:14 +08:00
lafirest 1a8288de75 fix(delayed): fix code style error 2022-03-11 11:32:25 +08:00
Shawn 2a17798320 fix(metrics): add default value for the rates 2022-03-11 11:08:01 +08:00
JimMoen f5caf66253 refactor(api): unified api name style 2022-03-11 11:07:55 +08:00
JimMoen bde7e51d8e test(authz): add `DELETE` method test, change request method for all 2022-03-11 11:07:55 +08:00
JimMoen 5e81a1ae95 fix(authz): `POST` method for creating or updating rules for all 2022-03-11 11:07:55 +08:00
JimMoen ba05cdc412 fix(authz): `DELETE` method return codes 2022-03-11 11:07:55 +08:00
lafirest eeb92dae23 fix(delayed): fix that the query is not a cluster query 2022-03-11 10:54:11 +08:00
lafirest d909ae9f32 test(mgmt): improve test coverage of emqx_mgmt_api_subscription to 96% 2022-03-11 10:46:21 +08:00
Xinyu Liu 09404c555f
Merge pull request #7273 from terry-xiaoyu/rule_test_columns
Add more test columns for events received from MQTT bridge
2022-03-11 09:24:27 +08:00
JianBo He 333f170a30 fix(authn-jwt): accept the pem conntet to create jwk authenticator 2022-03-11 09:19:24 +08:00
Shawn 5ca0d4f856 fix(rule): rename the eventname of bridge sources to $bridges/mqtt:* 2022-03-10 23:03:35 +08:00
Shawn 3ca3470844 fix(rule_events): add descs for test columns 2022-03-10 22:49:29 +08:00
lafirest 40f0f61744
Merge pull request #7266 from lafirest/fix/topic_rewrite
fix(rewrite): fix config update maybe not work
2022-03-10 18:41:54 +08:00
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