8201e4c820
feat(emqx.erl): Add a help function to load debug secret
2021-03-19 21:46:03 +01:00
e06b54ff71
chore(boot-log): print a warning at boot when running on old otp
2021-03-19 15:39:11 +01:00
2d150127d4
feat(listeners): Ensure no tlsv1.3 for otp 22 or earlier
2021-03-19 15:39:11 +01:00
72c1ee264c
chore(elvis): fix elvis error
2021-03-19 16:11:23 +08:00
568f4de6e5
fix(channel): fix the wrong acl check order
...
when subscribe, check the acl rule before run 'client.subscribe' hooks
2021-03-19 16:11:23 +08:00
81602c973c
fix(emqx): deny pingreq when mqtt not connected #4370
2021-03-19 14:17:49 +08:00
c7b44caa1d
feat(acl): Add possibility to remove all acl cache
2021-03-17 19:48:42 +01:00
d5886c0c66
chore(build): Get rel vsn fallback ( #4339 )
2021-03-16 09:49:11 +01:00
e9180b9ce8
chore(emqx_messages): fix elvis
2021-03-11 16:01:35 +09:00
9087f0c138
feat(emqx_message): add from_map
2021-03-11 16:01:30 +09:00
b400571dbb
fix(emqx): validate mqtt malformed varible byte integer
2021-03-10 10:41:57 +01:00
582dea10f5
style(emqx_sys): make elvis happy
2021-03-09 20:22:48 +01:00
e1979bf488
chore(build): Single source of EMQX_DESCRIPTION
2021-03-09 20:22:48 +01:00
00a2daba19
chore(build): add more enterprise build support
2021-03-06 10:56:07 +01:00
1af1dd17b5
chore(build): use 'EMQ X test' as app description for test runs
2021-03-06 08:41:50 +01:00
73500a0983
chore(build): inject product description from makefile
2021-03-06 08:41:50 +01:00
c752f3bec5
Refactor http lib add uri parse ( #4292 )
...
* feat(http_lib): Add uri parse to emqx_http_lib
* fix(webhook): call emqx_http_lib to parse uri
* fix(auth-http): Call emqx_http_lib to parse uri
* fix(rule-engine): call emqx_http_lib to parse uri
2021-03-06 13:35:02 +08:00
9b3ab169ce
chore(versioning): detach package version from emqx app version
2021-03-04 20:24:58 +01:00
42098b497f
Merge pull request #4283 from zmstone/add-emqx-http-lib
...
refactor(http-lib): Add emqx_http_lib
2021-03-04 07:14:02 +01:00
67c8b2eed7
chore: update emqx.app.src version
2021-03-04 08:10:48 +08:00
63c001a7aa
refactor(http-lib): Add emqx_http_lib
...
So far only uri_encode and uri_decode APIs
2021-03-03 21:38:10 +01:00
3daefe954b
chore(src): fix elvis
2021-03-03 20:06:31 +09:00
a8558bc7b5
chore(emqx_channel): ignore peer_cert_as/5 from dialyzer
2021-03-03 20:06:31 +09:00
e1b915b91c
chore(emqx_tracer): pass proper map
2021-03-03 20:06:31 +09:00
cae0849152
fix(emqx_channel): fix bug when publish deny
...
fix the bug of replying to puback when the publish message with Qos equal to 2 is deny
2021-03-02 17:54:22 +08:00
dd06d70bce
refactor(build): Move parse_transform module to root app
...
So we do not have to workaround the compile order issue
2021-03-02 08:40:19 +08:00
6e0b53fbb9
fix(eunit): fix emqx_tls_lib_tests
2021-03-01 21:00:17 +08:00
0a51bd4c2f
fix(webhook): Call common lib for ssl options
2021-03-01 21:00:17 +08:00
700fa71754
refactor(tls): abstract lib for tls options parsing
2021-03-01 21:00:17 +08:00
64ac20eec5
chore(emqx_listeners): fix clauses for dialyzer
2021-03-01 16:56:21 +08:00
6ea4501de4
chore(emqx_listeners): fix type
2021-03-01 16:56:21 +08:00
3dfa9f45c4
Merge pull request #4183 from zmstone/merge-e4.2.4-to-dev-4.3.0
...
Merge e4.2.4 to dev 4.3.0
2021-02-19 10:26:47 +01:00
71d02e8011
chore(emqx_connection): delete stale code
2021-02-19 10:20:16 +01:00
ca1d24a98d
feature(mgmt): restart a listener
...
example:
```
emqx_ctl listener restart mqtt:ssl:external
```
or
```
PUT /api/v4/listeners/mqtt:ssl:external/restart
```
thank you @zmstone for providing the listener-identifier apis :)
2021-02-19 09:22:47 +01:00
98b319a0c0
Merge pull request #4190 from zmstone/refactor-assing-names-to-listeners
...
feat(listeners): Add identifier to listeners
2021-02-19 07:50:27 +01:00
64cfaf4385
improve(print): io:format error message without indentation
...
Avoid squeezing lines to the right.
2021-02-19 07:45:37 +01:00
28f9b4d519
feat(peer_cert_as_clientid): peer_cert_as_clientid = cn | dn | crt | pem | md5
...
pem is base64 encoded instead of binary crt
peer_cert_as_username=crt breaks exhook proto utf8 parsing of username
crt cannot be used in a topic name due to being invalid utf8
pem cannot be used in a topic name due to having slashes
peer_cert_as_clientid = md5 allows to e.g. subscribe to "t/%c" with ACL
existing peer_cert_as_username combinations are unaffected.
2021-02-19 10:53:11 +08:00
d2bd9b4078
Merge pull request #4197 from zmstone/improve-shared-sup-random-start-point-for-roundrobin
...
improve(shared-sub): Randomise the startpoint for round-robin
2021-02-18 13:26:01 +01:00
db461179c5
improve(shared-sub): Randomise the startpoint for round-robin
2021-02-17 19:10:37 +01:00
eec64e440d
fix(tracer): create short handler-id if clientid is too long ( #4164 )
...
* fix(tracer): create short handler-id if clientid is too long
No need to support lists and atoms for when tracing clients/topics.
2021-02-16 14:45:33 +08:00
a93d62ace6
refactor(cli): Print listener ID as table head
2021-02-15 10:34:47 +01:00
f9465dda16
Merge branch 'dev/v4.3.0' into merge-e4.2.4-to-dev-4.3.0
2021-02-14 21:41:23 +01:00
c5a02c729a
feat(listeners): Add an api to ensure all listeners are started
2021-02-14 21:30:50 +01:00
dfa9bbc0c2
refactor(listeners): use emqx_ctl to print cli messages
...
It's better to keep cli print behaviour consistent.
It also makes tests easier as they can meck emqx_ctl:print to
validate the output.
2021-02-14 20:40:01 +01:00
153977609e
feat(listeners): Add identifier to listeners
...
Listeners are internally identifiered by the listen-on tuple
which is not UI friendly when we have to find a listener by this
'signature'.
The listeners are actually named in configs, but the names are
discarded in the parsing functions.
This commit is to keep the name and provide an API to find
listener by name (identifier).
2021-02-14 18:12:40 +01:00
dc184574a3
chore(style): fix elvis check for emqx_access_rule
2021-02-13 11:54:09 +01:00
406a7d60c7
chore(style): fix elvis check for emqx_connection
2021-02-13 11:50:17 +01:00
9b82112b7c
Merge remote-tracking branch 'origin/dev/e4.3.0' into merge-e4.2.4-to-dev-4.3.0
2021-02-13 11:10:08 +01:00
f000b6583c
fix(tls): Ensure tls config integrity
...
For default tsl version and ciphers, we try to use otp release number
to determin if we want to use tlsv1.3
For default configs, we try to porivde both tlsv1.3 and
ciphers in config (even for commented out configs)
2021-02-09 22:56:28 +01:00
2852ac79d4
feat(tls): Add a tls lib module
...
emqx_tls_lib is added to help ensure integrity of tls version
and cipher options.
2021-02-09 21:20:26 +01:00
7aff861f9b
refactor(emqx_modules): Move emqx_modules to lib-opensource
...
emqx_moduels for enterprise is refactored as a lib/plugin
in order to avoid merge conflicts, we make sure they can
co-exist in the same branch, because lib-opensource is compiled
in opensource project and lib-enterprise (to be added) is
compiled in enterprise project
2021-02-08 21:35:44 +01:00
6c1129dc6a
Auto-pull-request-on-2021-01-29 ( #4114 )
...
* fix(share sub): fix the issue that the number of subscriptions dropped to 0 during the picking subscriber and caused a crash
* Connection Busy Alarms (#3992 )
feat(emqx_connection): improve port_busy alarm
* fix(emqx_connection): tune the congestion alarm params
* chore(deps): upgrade esockd to 5.7.5
* fix(appup): correct the appup file
2021-01-30 10:30:18 +08:00
d78b2b23c1
chore(build): update pkg version
2021-01-29 19:29:41 +08:00
5878950dc3
feat(websocket): support for checking subprotocols ( #4099 )
2021-01-28 20:42:57 +08:00
02cb8d0211
chore(style): set warnings_as_errors compile option
2021-01-27 18:02:12 +08:00
de972b3d84
fix(emqx_vm): Call recon_alloc:allocators/0 to get allocators
2021-01-23 11:42:28 +01:00
23b2f4fa72
Merge pull request #4050 from zmstone/chore-delete-stale-code
...
chore(emqx_vm): delete stale code
2021-01-23 11:13:22 +01:00
7c3cd26589
chore(elvis): fix elvis wanrings
2021-01-23 18:07:58 +08:00
f59377adf5
fix(logs): print the correct username and clientid
2021-01-23 18:07:58 +08:00
33c35915ca
refactor(emqx_vm): make elvis happy
2021-01-22 09:23:20 +01:00
4680ba574c
chore(emqx_vm): Delete get_ets_object, not used
2021-01-22 09:21:45 +01:00
47df29ae49
chore(emqx_vm): delete stale code
...
The port binary format is no longer compatible in OTP 23
2021-01-22 07:50:00 +01:00
0087303b25
feat(shared_sub): Support hashing from source topic.
2021-01-21 21:05:56 +01:00
5aa63ed203
fix(shared_sub): align default value and default config
...
Shared subscription default dispatch strategy is 'random' in config
but 'round_robin' in code. This commit is to make sure they are the
same: both are 'random'.
2021-01-21 21:05:56 +01:00
598207e308
fix(ws_connection): proplists:get_bool for boolean flags
2021-01-15 14:28:22 +01:00
5794a708ed
feat(emqx_ws_connection): Prevent EMQX from CSWSH Cross-Site Web-Socket Hijack
2021-01-15 14:28:22 +01:00
32b23b9181
Revert "feat(auth_http): support for getting websocket cookies"
...
This reverts commit 5427057c2c
2021-01-14 15:10:48 +01:00
d437f9f228
chore(elvis): fix elvis warnings
2021-01-14 15:46:16 +08:00
f2190dd5b5
chore(mnesia): explicitly specify the copy type for table
2021-01-14 15:46:16 +08:00
76fc6225d3
fix(elvis): fix elvis checking
2021-01-14 15:46:16 +08:00
2a029b71c9
perf(mnesia): unify the copy types of all nodes
2021-01-14 15:46:16 +08:00
5427057c2c
feat(auth_http): support for getting websocket cookies
...
see: https://github.com/emqx/emqx-auth-http/pull/225
2021-01-11 09:21:16 +08:00
2b481dabe7
Fix some dialyzer warnings ( #3988 )
2021-01-05 20:49:50 +01:00
b9bb88d9eb
fix(emqx): fix dialyzer warnings
2021-01-04 14:14:55 +01:00
fbf8d3e111
fix(share sub): fix the issue that the number of subscriptions dropped to 0 during the picking subscriber and caused a crash
2020-12-31 14:03:55 +08:00
4f82c77e7a
fix(log): improve the error log message on hook failure ( #3973 )
2020-12-31 13:55:09 +08:00
ac0f51fec3
fix(max topic len): use the maximum length limit by default
2020-12-28 14:48:32 +08:00
739e49218f
fix(cm): fix the problem of registering a channel twice ( #3831 )
2020-12-28 11:03:29 +08:00
b68a0b3730
fix(emqx_lua_hook): fix dialyzer warnings.
2020-12-25 07:42:01 +08:00
7bdd093ef5
Merge remote-tracking branch 'origin/dev/v4.3.0' into umbrella-fix-build
2020-12-11 08:55:57 +01:00
6973837829
fix(emqx_plugins): Dialyzer warnings
2020-12-10 23:34:36 +01:00
56d7b3deb1
Umbrella fix build ( #8 )
2020-12-10 11:25:25 +01:00
59d69b730b
fix(emqx_logger): Dialyzer warnings
2020-12-10 11:22:38 +01:00
b9b20ba268
fix(emqx.erl): Dialyzer warnings
2020-12-10 11:22:38 +01:00
62e0a21ad0
fix(emqx_auth_sys, emqx_ws_connection): Dialyzer warnings
2020-12-10 11:22:38 +01:00
18ae158f45
fix(emqx_plugins, emqx_sys, emqx_sys_mon, emqx_ws_connection): Dialyzer warnings
2020-12-10 11:22:38 +01:00
baaa4e847d
fix(emqx_sn_gateway): Dialyzer warnings
2020-12-10 09:49:24 +01:00
eecd2b5f35
fix(emqx_types): Non mandatory map fields
2020-12-10 09:38:07 +01:00
adc9cc30f6
refactor(emqx_modules): Swallow errors when write modules
2020-12-10 09:35:36 +01:00
d47a2294ca
fix(emqx_mod_topic_metrics): Dialyzer warnings
2020-12-10 09:35:36 +01:00
0f0ca1e9fd
fix(emqx_mod_rewrite): Dialyzer warnings
2020-12-10 09:35:36 +01:00
ab5599b3ec
refactor(hook): Add emqx_hooks:put to hide already_exists error
...
This also fixes dialyzer warnings in emqx_mod_presence
2020-12-10 09:35:36 +01:00
5793ef6640
fix(emqx_mod_sup): Dialyzer warning
...
All the callers of start_child API are discarding the return value.
2020-12-10 09:35:36 +01:00
f3d973689b
fix(emqx_listeners): Dialyzer warnings
2020-12-10 09:35:36 +01:00
7a39470200
fix(emqx_connection): Dialyzer warnings
2020-12-10 09:35:36 +01:00
7dd67a6caf
fix(emqx_channel): Dialyzer warning
2020-12-10 09:35:36 +01:00
cfe52cbb8d
fix(emqx_broker): Dialyzer warning
2020-12-10 09:35:36 +01:00
0eb697fa6f
fix(emqx_app): Dialyzer warnings
2020-12-10 09:35:35 +01:00
3fb69cc407
fix(emqx_alarm): Dialyzer warnings
2020-12-10 09:35:35 +01:00
0d90d5c66b
fix(emqx_acl_cache): Dialyzer warnings
2020-12-10 09:35:35 +01:00
d4aa5ebf55
fix(emqx): Fix dialyzer warnings
2020-12-10 09:35:35 +01:00
7f556d36d1
Merge branch 'dev/v4.3.0' into e422_to_v430
2020-12-09 11:28:36 +08:00
6d1cd6b7ea
refactor(emqx_password): move the module to emqx application
...
Future plugins will require emqx as a dependency.
This commit also brings back bcrypt to the system which was temporary
removed when converting to umbrella project
2020-12-08 22:09:59 +01:00
0ee489a9be
fix(congestion): change the conn congestion alarm msg body
2020-12-07 15:05:20 +08:00
d00ea48752
feature(tcp): alarm when tcp connection congested
2020-12-07 14:35:38 +08:00
505257b25b
chore(appup): remeove the code_change codes
2020-12-05 17:22:44 +08:00
ae9449a004
chore: eliminate diaylzer warnings
2020-12-05 17:20:50 +08:00
f1b3bbd7bc
chore: supply the code_change logic
2020-12-05 17:20:50 +08:00
3b1074d11f
refactor(conn): not saving anonymous func
2020-12-05 17:11:58 +08:00
3f924631e4
refactor(limiter): not saving anonymous function
2020-12-05 17:03:57 +08:00
2e7ec25ae2
chore(appup): suspend esockd_acceptor
2020-12-05 15:04:14 +08:00
73d02beace
refactor(apps): Merge emqx_libs back to emqx
...
And move emqx app back to root level
After realising the challenges of developing plugins in standalone
rebar projects. it is perhaps more smooth to keep using emqx as
a rebar dependency
2020-12-04 19:58:58 +01:00
7462ed92ba
chore: eliminate diaylzer warnings
2020-12-04 22:33:29 +08:00
ca0f6b69a4
chore: supply the code_change logic
2020-12-04 22:33:29 +08:00
80c503fd64
refactor(conn): not saving anonymous func
2020-12-04 22:33:29 +08:00
40d272815a
refactor(limiter): not saving anonymous function
2020-12-04 22:33:29 +08:00
f5162562a4
chore(appup): update appup
2020-11-26 10:42:35 +08:00
aa7124f3c9
chore(appup): use binding var 'VSN'
2020-11-25 14:40:25 +08:00
3ca39cb9cb
chore(appup): update version
2020-11-25 10:27:56 +08:00
3f41adc3bd
chore(appup): update version
2020-11-25 01:07:19 +08:00
cf7c3b4f0c
fix(appup): fix syntax error
2020-11-13 17:40:36 +08:00
253c43e405
feat(emqx_metrics): add new functions to count message received
2020-11-13 16:42:48 +08:00
41a8f2f811
Merge branch 'stable/e4.2.0' of https://github.com/emqx/emqx into stable/e4.2.0
2020-11-13 10:40:28 +08:00
77d777fd11
chore(acl): rollback emqx_access_rule module
2020-11-13 10:40:14 +08:00
8cc69e639f
fix(congestion): change the conn congestion alarm msg body
2020-11-11 17:33:38 +08:00
26c03aaa43
feat(connection): update alarm info
2020-11-11 09:37:39 +08:00
e100b0a5e9
feat(emqx_metrics): add new functions to count message received
2020-11-10 23:36:11 +08:00
cc69225b6d
feature(tcp): alarm when tcp connection congested ( #3818 )
2020-11-10 23:36:11 +08:00
139306b61c
fix(json): fix decoding/encoding empty object error
2020-11-10 23:36:11 +08:00
b883e238bf
fix(ws): take ws_cookie to clientinfo
...
see: https://github.com/emqx/emqx/issues/3747#issuecomment-702268570
2020-11-10 23:36:11 +08:00
5a8efd9d20
feature(project): move src to apps/emqx/src
2020-10-31 09:19:28 +08:00
b373c0cf1b
fix(json): fix decoding/encoding empty object error
2020-10-24 15:49:15 +08:00
8462da9652
fix(topic metrics): add appup.src
2020-10-24 11:21:39 +08:00
b927bb7af6
fix(topic metrics): calculate the rate correctly
2020-10-24 11:21:39 +08:00
2feeb4d91f
fix(ws): take ws_cookie to clientinfo
...
see: https://github.com/emqx/emqx/issues/3747#issuecomment-702268570
2020-10-24 11:21:39 +08:00
87ef4e4dd9
chore(types): Add the disconnected_at field definition in conninfo ( #3764 )
2020-10-24 11:21:39 +08:00
eb4b9936dc
fix(modules): fix conflicts
2020-10-11 11:12:39 +08:00
7b98f62f7a
fix(config): enable force_shutdown_policy by default
2020-09-30 11:36:30 +08:00
da4d71917f
fix(ignore-loop-deliver): fix issue#3738 ( #3741 )
2020-09-29 15:35:16 +08:00
76ec65830c
fix: fix session_locking_strategy enum typos
2020-09-29 15:35:16 +08:00
fa31062a5e
chore(topic rewrite): export more functions
2020-09-11 12:37:47 +08:00
3d4eac7e7a
fix(json): fix safe_encode for utf8 string
2020-09-11 12:26:13 +08:00
edcbdcce87
improve: module_acl_internal load/unload api ( #3706 )
2020-09-05 17:23:22 +08:00
90b33b044d
feature(ratelimit): support to set ratelimit & quota policy
2020-09-05 17:23:22 +08:00
4233ef4e85
fix(xref): correct the type spec of logger_handler_info()
2020-08-28 17:10:26 +08:00
9985e2675c
fix(logger): resolve issues when starting and stopping log handlers
2020-08-28 17:10:26 +08:00
faf0b5289c
feature(logger): support starting and stopping log handlers
2020-08-28 17:10:26 +08:00
e411b4bad3
fix(cm): fix never matching clause
2020-08-28 17:10:26 +08:00
261bd66a3d
refactor(alarm): refactor resource down alarm
2020-08-22 15:27:11 +08:00
7a2a01a4de
fix(mqtt piggyback): bad data type
2020-08-22 15:27:11 +08:00
ec12acc4ef
feature(mqtt piggyback): transporting mutli MQTT packets at once or single
2020-08-22 15:27:11 +08:00
cfcbc53a8b
refactor(alarm): remove excess case
2020-08-22 15:27:11 +08:00
c2cc8ab218
feature(resource-down-alarm): add resource down alarm
2020-08-22 15:27:11 +08:00
901573c6a5
fix(topic-metrics): fix the issue that the corresponding data is not properly cleaned up when unregistering ( #3679 )
2020-08-22 15:27:11 +08:00
f47e10e08a
feature(emqx_mod_rewrite): separate rewrite rules for pub and sub ( #3676 )
2020-08-22 15:27:11 +08:00
dbeabf3de0
refactor(telemetry): remove telemetry code from emqx core
2020-08-22 15:27:11 +08:00
9e5e6f2e98
fix(guid): compatible with OTP 23
2020-08-22 15:27:11 +08:00
a76be8e0fa
chore: fix the compilation error when there is "/" in the branch name
2020-08-22 15:27:11 +08:00
e37a70509b
feature(telemetry): support for collecting telemetry data and disable it by default ( #3653 )
2020-08-14 16:58:08 +08:00
98faa698f3
feature(quota): add quota confs to limit the number of message forwards
2020-08-14 16:58:08 +08:00
89377aeaa2
improve(type): refine the message header types
2020-08-14 16:58:08 +08:00
87780c1c1b
fix(static-cluster): fix the issue that static cluster failure caused by the wrong way of creating tables
2020-08-14 16:58:08 +08:00
aaf29ee164
fix(alarm): fix the issue that memory watermark were not set correctly
2020-07-31 18:07:20 +08:00
1ba4743213
refactor(alarm): new data structure and support regular cleaning of deactivated alarms
2020-07-31 18:07:20 +08:00
5676026e2a
fix(alarm): missing partition alarm
2020-07-31 18:07:20 +08:00
43b49edd28
feature(alarm): new design for alarm
2020-07-31 18:07:20 +08:00
0817761aee
fix(emqx_channel): EMQ X replaces MQTT properties when node connects using "topic-alias-maximum" property
2020-07-31 18:07:20 +08:00
00bc525d8e
refactor(add-log): log when subscription fails
2020-07-31 18:07:20 +08:00
83a2af812f
feat(ratelimit): refactor ratelimit
2020-07-31 18:07:20 +08:00
961e7b9818
chore: update app.src.script
2020-07-20 10:08:47 +08:00
492d224728
Auto-pull-request-on-2020-07-17 ( #3600 )
...
* refactor(channel): skip the ACL checking for inner subscribe
* fix(props): fix the prop_emqx_sys results of judgment
* Update esockd to 5.7.1
* test(topic-metrics): add test cases for topic metrics
* perf(emqx_vm): make emqx_vm:get_memory/0 more efficiency
2020-07-17 18:25:46 +08:00
211c800e24
fix(properties): downlink will msg contains non-publish properties
...
The paho test failed because the client received a will message
that has an `Will-Delay-Interval` property.
All the 7 allowed PUBLISH properties are listed as follows:
```
'Payload-Format-Indicator',
'Message-Expiry-Interval',
'Response-Topic',
'Correlation-Data',
'User-Property',
'Subscription-Identifier',
'Content-Type'
```
2020-06-21 11:27:22 +08:00
600b1055f3
fix(json): convert a proplists to ejson instead of map
2020-06-20 15:42:07 +08:00
1b6a586948
feature(mqtt): support response information ( #3533 )
2020-06-20 15:07:37 +08:00
8707afa54c
fix(enhanced_auth): fix bug when "conn_props = undefined"
2020-06-20 14:29:20 +08:00
9a8859a44c
refactor(topic): move triples/1 func into emqx_trie module
2020-06-18 17:38:34 +08:00
e3489b9d46
refactor(style): improve all types declaration
...
- Add dialyzer for code analysis
- Correct all the module type declarations
- Use `-type()` to declaration a type instead of `-opaque`
(It is advantageous to the code dialyzer)
BROKEN CHANGES:
- Add a ?DEFAULT_SUBOPTS for emqx_broker:subscribe/1,2,3
- Remove the needless internal function `emqx_vm:port_info(PortTerm, Keys)`
2020-06-18 17:38:34 +08:00
6ad65d587e
feature(properties): add properties in message header
...
1. Add MQTT5.0 properties when invoking the hooks.
- Add a new key `properties` into the message header:
We used to put all of the properties into the `#message.headers`:
```erlang
#message{headers = #{'User-Property' => {<<"reason">>,<<"normal">>},
'Message-Expiry-Interval' => 60,
allow_publish => true}
```
I put them instead under a single key:
```erlang
#message{headers = #{properties =>
#{'User-Property' => {<<"reason">>,<<"normal">>},
'Message-Expiry-Interval' => 60},
allow_publish => true}
```
Note that the column `properties` may contain all the properties for
Publish and Will messages.
- Add `disconn_props` into the `Channel.conninfo`
- Add `puback_props` also into the message header:
```erlang
#message{headers = #{puback_props =>
#{'User-Property' => {<<"reason">>,<<"normal">>}},
allow_publish => true}
```
2. Change the data type of `#message.headers` and `#message.flags` to map.
It used to support `undefined`.
2020-06-17 18:46:26 +08:00
ea2a424ce2
Add ensure/2 funcs to avoid needless logs ( #3483 )
2020-06-04 10:46:53 +08:00
f456f40c59
Subscribe or unsubscribe via HTTP API skip ACL checking
2020-06-04 10:45:58 +08:00
42fc81338c
Fix(modules): correct the bad return value for emqx_modules:load/0
2020-06-04 10:38:28 +08:00
3fb82f7234
Fix(connect): fix the race condition for openning session
...
- Remove the register_channel/1,2 functions
2020-06-02 17:21:06 +08:00
59f95f8421
Helpful message when no commands available
2020-05-23 09:41:25 +08:00
83b1f3e6c8
Fix unexpected packet before connected
2020-05-22 18:18:52 +08:00
18ae15ef9a
Fix typos
2020-05-21 17:51:22 +08:00
1f07700930
Print helpful messages when no commands available
2020-05-16 08:48:05 +08:00
80e2bd19b9
Fix case_clause in issue#3455
2020-05-12 10:39:22 +08:00
48d6acdb25
Replace peercert with cn/dn feilds in ClientInfo
2020-04-30 16:35:15 +08:00
c35a40a6b6
Fix some error for reauthentication
2020-04-28 11:48:07 +08:00
7ba801c8d4
Fix reload acl module and clean acl caches ( #3409 )
2020-04-26 15:45:55 +08:00
7cf97acddd
Delete expiried client
2020-04-26 15:38:29 +08:00
021520315a
Update enhanced auth hooks
2020-04-24 10:21:22 +08:00
b37c61fdb5
Merge pull request #3392 from emqx/print
...
Optimize cli print
2020-04-17 18:05:37 +08:00
5922f5358e
Merge pull request #3396 from emqx/add_hook_to_auth_packet
...
Add hook to auth packet
2020-04-17 18:05:25 +08:00
6cab60b6ab
Export emqx_modules:find_module/1
2020-04-17 11:02:40 +08:00
dccf3560f0
Add hook to auth packet
2020-04-16 16:07:01 +08:00
fb661b1d92
Support return all registered topics
2020-04-16 10:35:35 +08:00
eebc5e4b0a
Optimize cli print
2020-04-15 18:05:30 +08:00
e806a96031
Change timestamps to millisecond
2020-04-15 09:03:52 +08:00
9ba938b9d9
EMQX failed to start when the listening port was occupied ( #3354 )
2020-04-11 10:18:35 +08:00
Zaiming Shi