73643e932f
fix: bulk subscribe topics failed in the client.connected hook
2023-01-10 16:43:24 +08:00
52343e58c7
Merge pull request #9703 from emqx/subscribe-api-function-clause
...
fix: missing default value for qos field of API /clients/:clientid/subscribe
2023-01-10 10:13:58 +08:00
724015af47
fix: remove the default value of webhook body field
2023-01-10 09:45:25 +08:00
67f2159a27
Merge pull request #9653 from zmstone/0101-authz-schema-union-member-selection
...
0101 authz schema union member selection
2023-01-09 22:17:51 +01:00
0bd5bec982
chore: upgrade mongodb-erlang to v3.0.19
...
This upgrades mongodb-erlang from v3.0.18 to v3.0.19. This fixes a bug
that occurred when one issued a command specified as a map*. This fix
should not affect present EMQX as this functionality is currently not
used by EMQX. However, I think it is good to do the upgrade anyway in
case we will use the fixed functionality in the future. There is no need
to update the changelog.
* https://github.com/emqx/mongodb-erlang/pull/36
2023-01-09 18:14:11 +01:00
f1ebfe40a5
Merge pull request #9697 from lafirest/fix/ldap_i18n
...
chore: add i18n file for ldap connector
2023-01-09 22:54:09 +08:00
7f5150b2e9
Merge pull request #9689 from thalesmg/fix-http-authz-failure-v50
...
fix(authz_http): handle `ignore` results (request failures)
2023-01-09 11:07:52 -03:00
c3635f537a
ci: wait for redis in emqx_ee_bridge_redis_SUITE
2023-01-09 14:39:56 +01:00
0697c692ed
refactor: mongo_type and redis_type are not mandatory
...
the connector schemas are shared between authn, auth and bridges,
the difference is that authn and authz configs are unions like:
[
{mongo_type = rs,
...
}
{another backend config}
]
however the brdige types are maps like, for example:
mongodb_rs.$name {
mongo_type = rs
...
}
in which case, the mongo_type is not required.
in order to keep the schema static as much as possible,
this field is chanegd to 'required => false' with a default value.
However, for authn and authz, the union selector will still raise
exception if the there is no type provided.
2023-01-09 14:26:16 +01:00
e52f9d5920
refactor: use union member type selector for authz sources
2023-01-09 14:26:16 +01:00
ba8c304723
Merge pull request #9691 from kjellwinblad/kjell/mongodb_upgrade_in_emqx_5_master
...
feat: upgrade MongoDB library to support MongoDB 5.1+
2023-01-09 14:15:48 +01:00
692c1f0d1b
Merge pull request #9678 from kjellwinblad/kjell/fix/jira/EMQX-8648
...
fix: no feedback when deleting non-existing configuration
2023-01-09 13:52:40 +01:00
c85a988a43
fix: split 'server' param into host and port for mqtt bridge
2023-01-09 13:27:42 +01:00
0db31f30a1
Merge pull request #9675 from keynslug/chore/otp-25-compat-deps
...
chore: bump deps versions with full OTP-25 compat
2023-01-09 14:54:14 +04:00
50717a5567
fix: set the topic field of API /clients/:clientid/subscribe as requried
2023-01-09 17:57:39 +08:00
c42c99f94f
fix: set a timeout for tcp connect
2023-01-09 10:01:35 +01:00
96ca0d9f49
feat(emqx_bridge): add /bridges_probe API endpoint
2023-01-09 10:01:33 +01:00
903ae9a644
style: fix typo in fun name
2023-01-09 09:59:42 +01:00
3319a8d28e
fix(mgmt_api): remove possibility to set clientid in /publish API
...
To avoid security confusion, we remove the possibility to specify the
client ID in the request body for /publish and /publish/bulk.
2023-01-09 09:30:34 +01:00
8d53d154d9
refactor: remove license from configs API
...
license has its own config APIs
2023-01-09 09:16:19 +01:00
7ed1384623
fix: missing default value for qos field of API /clients/:clientid/subscribe
2023-01-09 16:02:10 +08:00
3859878985
Merge pull request #9684 from zmstone/0105-do-not-use-testcase-skip
...
test: do not use tc_user_skip for test cases
2023-01-09 09:02:06 +01:00
6f5057b9dd
Merge pull request #9637 from HJianBo/fix-clients-api
...
fix(clients): fix expiry_interval unit error
2023-01-09 09:49:16 +08:00
336b310d56
Merge pull request #9687 from emqx/function_clause_when_send_msg_to_bridges
...
fix: function_clause when sending messages to bridges
2023-01-09 09:23:17 +08:00
1336a57b3b
chore: bump to emqx/eredis_cluster 0.7.5
...
* Full OTP-25 compat.
* Password censoring in status and crash reports.
* No more crashes on query timeout.
2023-01-08 13:13:31 +03:00
5653d113ac
Merge pull request #9663 from zmstone/0102-fix-stopped-nodes-detection
...
0102 fix stopped nodes detection
2023-01-08 10:03:48 +01:00
d2456f9fbe
chore: add i18n file for ldap connector
2023-01-06 17:28:06 +08:00
f7b50c56da
feat(bridges): integrate PostgreSQL into bridges
...
support both simple and batch query
2023-01-06 11:47:22 +08:00
5d55e3a7b3
chore: updage mgmt app vsn
2023-01-06 10:31:27 +08:00
65729cd640
fix(clients): fix expiry_interval unit error
...
It should be second not millisecond
2023-01-06 10:31:27 +08:00
13b2f45405
fix: function_clause when sending messages to bridges
2023-01-06 09:24:38 +08:00
7a4e7a6de9
test: wait for redis
2023-01-05 22:47:08 +01:00
5f12cdff6c
ci: should not skip tests in github actions
2023-01-05 22:47:08 +01:00
22707495ac
Merge pull request #9690 from thalesmg/fix-flaky-jwt-test
...
test(flaky): fix flaky jwt worker test
2023-01-05 14:00:39 -03:00
5266722e51
feat: upgrade MongoDB library to support MongoDB 5.1+
2023-01-05 16:40:45 +01:00
b59c4c34c5
fix(Bridge REST API): no feedback when deleting bridge
...
This fixes https://emqx.atlassian.net/browse/EMQX-8648 . The issue
described in `EMQX-8648` is that when deleting a non-existing bridge the
server gives a success response. See below:
```
curl --head -u admin:public2 -X 'DELETE' 'http://localhost:18083/api/v5/bridges/webhook:i_do_not_exist '
HTTP/1.1 204 No Content
date: Tue, 03 Jan 2023 16:59:01 GMT
server: Cowboy
```
After the fix, deleting a non existing bridge will give the following
response:
```
HTTP/1.1 404 Not Found
content-length: 49
content-type: application/json
date: Thu, 05 Jan 2023 12:40:35 GMT
server: Cowboy
```
Closes: EMQX-8648
2023-01-05 16:19:46 +01:00
c6b8e614df
fix(authz_http): handle `ignore` results (request failures)
...
Related issue: https://github.com/emqx/emqx/issues/9683
When the HTTP request for authz fails (e.g.: resource is down or
server is down), then the HTTP authorizer returns `ignore`, which was
not handled correctly by the authorization callback.
2023-01-05 11:34:23 -03:00
cf6996cbea
test(flaky): fix flaky jwt worker test
2023-01-05 11:19:43 -03:00
70eb5ffb58
refactor: remove unused function
2023-01-05 10:16:01 -03:00
56437228dc
docs: improve descriptions
...
Thanks to @qzhuyan for the corrections.
2023-01-05 10:16:01 -03:00
fd360ac6c0
feat(buffer_worker): refactor buffer/resource workers to always use queue
...
This makes the buffer/resource workers always use `replayq` for
queuing, along with collecting multiple requests in a single call.
This is done to avoid long message queues for the buffer workers and
rely on `replayq`'s capabilities of offloading to disk and detecting
overflow.
Also, this deprecates the `enable_batch` and `enable_queue` resource
creation options, as: i) queuing is now always enables; ii) batch_size
> 1 <=> batch_enabled. The corresponding metric
`dropped.queue_not_enabled` is dropped, along with `batching`. The
batching is too ephemeral, especially considering a default batch time
of 20 ms, and is not shown in the dashboard, so it was removed.
2023-01-05 10:15:09 -03:00
bf3983e7c4
feat(buffer_worker): use offload mode for `replayq`
...
To avoid confusion for the users as to what persistence guarantees we
offer when buffering bridges/resources, we will always enable offload
mode for `replayq`. With this, when the buffer size is above the max
segment size, it'll flush the queue to disk, but on recovery after a
restart it'll clean the existing segments rather than resuming from
them.
2023-01-05 10:11:59 -03:00
5d9f9671e9
feat(emqx_metrics): Sliding window samples
2023-01-05 13:55:52 +01:00
fa4f90d43e
Merge pull request #9676 from thalesmg/fix-change-retainer-storage-type-v50
...
fix(retainer): change mnesia table storage types during update
2023-01-05 09:07:10 -03:00
93c205db7c
fix(router_helper): Reduce log verbosity of expected events
2023-01-05 12:17:27 +01:00
51ad27cb4b
test(retainer): assert that retained messages are not lost when changing storage type
2023-01-04 13:52:52 -03:00
2f13bfd452
fix(retainer): change mnesia table storage types during update
...
https://emqx.atlassian.net/browse/EMQX-8650
2023-01-04 13:52:52 -03:00
86a4ac87a7
Merge pull request #9674 from thalesmg/reset-rule-metrics-on-disable-v50
...
chore(rule_engine): reset metrics when disabling a rule
2023-01-04 13:30:39 -03:00
00b91d8a60
Merge pull request #9664 from thalesmg/fix-mongo-duration-field-descs-v50
...
docs(mongodb_connector): fix duration field descriptions
2023-01-04 10:03:38 -03:00
eb7dca3691
chore(rule_engine): reset metrics when disabling a rule
...
https://emqx.atlassian.net/browse/EMQX-8502
When a bridge is disabled, its metrics are reset. With this change,
we make rule actions behave like that: disabling a rule will reset its
metrics.
2023-01-04 09:30:47 -03:00
f767db4d8f
Merge pull request #9660 from olcai/refactor-ingress-bridge-counter
...
refactor(emqx_resource): ingress bridge counter
2023-01-04 10:43:07 +01:00
c3cfbae3c2
docs: improve descriptions
...
Thanks to @qzhuyan for the corrections
2023-01-03 11:38:09 -03:00
b43be50a98
test: add the `redacted` test case for bridges api
2023-01-03 22:16:34 +08:00
b016695cb1
fix(bridges): obfuscate the password in bridges API responses
2023-01-03 22:09:29 +08:00
7bbdc20993
docs(mongodb_connector): fix duration field descriptions
...
https://emqx.atlassian.net/browse/EMQX-8642
Adds different descriptions for the different fields of type duration
for MongoDB.
Based off: https://www.mongodb.com/docs/manual/reference/connection-string/
2023-01-03 10:01:56 -03:00
ced5a27053
test: fix emqx_conf test cases
2023-01-02 21:30:40 +01:00
2f208c3ab9
fix(cluster_rpc): Detect stopped replicant nodes
2023-01-02 21:30:40 +01:00
7985cd3536
Merge pull request #9638 from lafirest/fix/mysql_dup
...
fix(mysql): fix the problem of data loss and bad match when mysql is disconnected
2023-01-02 23:15:44 +08:00
b9d012e072
refactor(emqx_resource): ingress bridge counter
...
Unify code paths for resource metrics by removing
emqx_resource:inc_received/1 and adding
emqx_resource_metrics:received_inc/1 & friends.
2023-01-02 15:11:52 +01:00
7e02eac3bc
Merge pull request #9619 from thalesmg/refactor-gauges-v50
...
refactor(metrics): use absolute gauge values rather than deltas (v5.0)
2023-01-02 10:56:47 -03:00
bc37556963
fix(mysql): fix the problem of data loss and bad match when mysql is disconnected
2023-01-02 21:46:24 +08:00
dbc10c2eed
chore: update copyright year 2023
2023-01-02 09:22:27 +01:00
231d6da4dc
Merge pull request #9644 from id/fix-kafka-bridge-connectivity-detection
...
fix(kafka): detect connectivity in on_get_status
2022-12-30 21:54:56 +01:00
305ed68916
chore: bump app vsns
2022-12-30 16:51:24 -03:00
8b060a75f1
refactor(metrics): use absolute gauge values rather than deltas
...
https://emqx.atlassian.net/browse/EMQX-8548
Currently, we face several issues trying to keep resource metrics
reasonable. For example, when a resource is re-created and has its
metrics reset, but then its durable queue resumes its previous work
and leads to strange (often negative) metrics.
Instead using `counters` that are shared by more than one worker to
manage gauges, we introduce an ETS table whose key is not only scoped
by the Resource ID as before, but also by the worker ID. This way,
when a worker starts/terminates, they should set their own gauges to
their values (often 0 or `replayq:count` when resuming off a queue).
With this scoping and initialization procedure, we'll hopefully avoid
hitting those strange metrics scenarios and have better control over
the gauges.
2022-12-30 16:51:24 -03:00
b30f2ea58b
fix(statsd schema): a field is not 'required' when it has 'default'
2022-12-30 14:20:24 +01:00
981f75dc73
test(emqx_modules): do not expect badmatch in test cases!!!
2022-12-30 14:20:24 +01:00
0ce1ca89b7
refactor: use string type for server and servers
2022-12-30 14:20:23 +01:00
cac7e0c5f0
refactor: move version prefix string detection to a static fun
...
this is to make dialyzer happy
2022-12-30 14:19:03 +01:00
a612eacf3a
Merge pull request #9641 from thalesmg/fix-gcp-pubsub-jwt-refresh-v50
...
fix(gcp_pubsub): fix potential jwt accumulation and lack of refresh (v5.0)
2022-12-30 09:33:41 -03:00
f410201dc3
chore: fix flaky test case in emqx_connector_jwt_worker_SUITE
2022-12-30 11:45:13 +01:00
f92b1fb8f4
Merge pull request #9633 from zhongwencool/fix-json-fmt
...
fix: bad best fmt json []
2022-12-30 09:08:13 +08:00
446a4c74d0
fix(gcp_pubsub): fix potential jwt accumulation and lack of refresh (v5.0)
...
https://emqx.atlassian.net/browse/EMQX-8653
Related:
- https://emqx.atlassian.net/browse/EEC-737
- https://emqx.atlassian.net/browse/EMQX-8652
Since the rule resource testing mechanism creates a new resource to
test the configuration, a new JWT associated with an unique temporary
resource was being created and left in the JWT table, leaking it.
Also, a wrong case clause when setting the new refresh timer for the
JWT worker was preventing it from refreshing from the 2nd refresh
onward.
2022-12-29 16:30:36 -03:00
0b43ae621d
ci: dump docker-compose log if failed to run ct
2022-12-29 09:23:11 +01:00
4e62aff3ab
fix: bad best fmt json []
2022-12-29 14:53:00 +08:00
2790d5697d
test: add a 2 seconds sleep between listener sotp and restart
...
to lower the chance of eaddrinuse
2022-12-28 18:48:53 +01:00
4819794401
test(refactor): decrease test teardown noise
2022-12-27 10:30:14 -03:00
6fdcba641e
test(refactor): no need for monitor
...
the janitor is already linked to the parent
2022-12-27 10:30:14 -03:00
a777bac38c
build: prepare for v5.0.13 release
2022-12-27 11:54:09 +01:00
15bd797b36
ci: bump to v5.0.13-rc.3
2022-12-27 11:24:47 +01:00
580137de0d
Merge remote-tracking branch 'origin/master' into release-50
2022-12-27 11:06:17 +01:00
2ff6ef01f1
Merge pull request #9599 from lafirest/fix/blacklist_default_exp
...
fix(banned): ensure the default expiration time of `banned` is large enough
2022-12-27 17:30:10 +08:00
0517541f34
ci: bump to v5.0.13-rc.2
2022-12-27 09:54:34 +01:00
18246442aa
chore: prepare v5.0.13-rc.1
...
bump dashboard version to v1.1.4
2022-12-26 21:45:48 +01:00
81b226a801
Merge pull request #9608 from zmstone/1123-pin-hocon-0.33.0
...
1123 pin hocon 0.33.0
2022-12-26 19:22:21 +08:00
af3f0c9bb0
fix(banned): ensure the default timeout of `banned` is large enough
2022-12-26 10:17:31 +08:00
f93c22045d
fix: non-empty field should not be undefined
2022-12-24 11:41:45 +01:00
269a40a9ea
fix: format psk user lookup fun back to string
2022-12-23 19:22:15 +01:00
d3efb0c0ba
chore: bump app versions
2022-12-23 15:10:16 +01:00
350023e757
fix(config): option only_fill_defaults renamed to make_serializable
2022-12-23 14:27:04 +01:00
35dc75b7ed
feat(mqtt): add option to customize clientid prefix for egress bridges
...
https://emqx.atlassian.net/browse/EMQX-8445
Currently the bridge client’s client ID is prefixed with the resource
ID.
Sometimes it’s useful for users to have control of this prefix,
e.g. prefix based ACL rules in the target broker.
2022-12-23 09:50:26 -03:00
fa7433628c
fix(logs): set password field sensitive for connectors
2022-12-23 12:46:03 +01:00
59970272ff
chore: pin hocon 0.33.0
2022-12-23 12:07:36 +01:00
6292d7ec68
refactor: remove dead code
2022-12-23 12:07:36 +01:00
13942f5c49
refactor: rename error return in mysql connector
2022-12-22 10:29:12 +01:00
7df24000a0
test: add more EE mysql bridge test cases
2022-12-22 10:27:38 +01:00
23ac426608
fix(emqx_connector): check for key among prepared statements on query
...
An infinite loop was triggered in the mysql connector when a query
used a prepared statement key that was not among the defined prepared
statements on start. We now check that the key is defined among the
prepared statements before recursing. It seems that this bug was never
triggered in any production code flow and simply found while writing
tests.
An error return spell fix is also included as well as a FIXME comment
regarding running mysql:prepare and not distinguishing between
transient failures and syntax errors. Syntax errors should not be
retried.
2022-12-22 10:27:38 +01:00
f660724bf7
Merge pull request #9582 from lafirest/fix/fix_field_name
...
fix(limiter): change limiter `cache` to `buffer`
2022-12-21 18:12:40 +08:00
a8e020af58
fix(limiter): change limiter `cache` to `buffer`
2022-12-20 22:30:52 +08:00
516147ad00
Merge pull request #9581 from zmstone/1219-fix-mqtt-bridge-config
...
1219 fix mqtt bridge config
2022-12-20 14:47:02 +01:00
479e191dcf
refactor: refine worker pool config and doc
...
worker pool is a buffer pool
the description hinted connection pool which is wrong.
2022-12-20 09:02:51 +01:00
da51433dc3
refactor: add default value for eggress remote 'qos' and 'retain'
...
otherwise when updating from dashboard, there is no way to set
'false' for 'retain' because it's a checkbox,
it's either 'true' or 'undefined'
2022-12-20 00:00:31 +01:00
c085ffa0fe
refactor: default mqtt bridgge buffer pool size down to 4
2022-12-19 23:59:46 +01:00
f611cbab45
chore: cap replayq seg size under total size
2022-12-19 23:16:05 +01:00
e932569f34
refactor: delete stale code
...
'hash' strategy has been removed from config schema
hence no need to keep the compatibility code
2022-12-19 20:20:58 +01:00
ad3a793910
fix(shared_sub): insert alive pid table at mnesia table event
2022-12-19 20:12:38 +01:00
4f1fb0b629
refactor(shared_sub): improve sticky strategy performance
...
* avoid calling ets:select twice for sticky strategy
* when the calling process is terminating, no loop-back dispatch
2022-12-19 20:04:33 +01:00
29f394aa70
fix(shared): handle unsubscribe for sticky strategy
...
prior to this change, the message is dispatched to a shared subscriber
even after unsubscribed
2022-12-19 19:12:38 +01:00
67718ef84f
docs: prepare to deprecate broker.shared_dispatch_ack_enabled
2022-12-19 17:07:52 +01:00
7aee1a08aa
Merge pull request #9531 from sstrigler/EMQX-7982-put-authentication-id-should-return-204
...
refactor: return `204` instead of `200` for `PUT /authenticator/:id`
2022-12-19 14:46:31 +01:00
cbe54c001c
Merge pull request #9510 from keynslug/chore/otp-25-compat
...
chore: enable OTP-25 compatibility
2022-12-19 15:12:19 +04:00
9d97775567
refactor: return `204` instead of `200` for `PUT /authenticator/:id`
2022-12-19 10:02:08 +01:00
4906da9796
test(rule-funcs): test compression funcs
2022-12-19 15:43:50 +08:00
5151242583
feat(rule-engine): `zip`, `gzip`, `zip_compress` funcs in rule-sql
2022-12-19 15:43:50 +08:00
ed2d5aa48a
fix: handle status in `format_status/1` callback
...
Which is expected argument type for this callback. Also try to
make sure that random maps won't pass through this callback unnoticed.
2022-12-16 13:45:06 +03:00
41a4e41d0c
fix(ct): prevent testcase flapping
...
Testcase `t_log_file` was flapping when run happened to pass through
boundary of a second. Archive files' `ctime`s could differ between
consecutive archive downloads.
2022-12-16 13:45:06 +03:00
4f00f0968d
ci: update to emqx-plugin-template 5.0.0
2022-12-16 13:45:06 +03:00
fed7c80a9a
fix(ci): spec function with explicit exception
2022-12-16 13:45:05 +03:00
8a0ca38a77
fix: drop no longer supported dialyzer option
2022-12-16 13:45:05 +03:00
c301c8e992
chore: drop few unused macros / includes
2022-12-16 13:45:04 +03:00
a614e3065a
chore(tls): drop OTP-22-related workaround
2022-12-16 13:45:04 +03:00
23d5d5329e
test(session): ensure 'message.dropped' hook ran with named reason
2022-12-15 16:16:27 +08:00
b88398c3c6
fix: run `message.dropped` hook, inc `messages.dropped` metrics
...
- when awaiting_rel full
- packet identifier in use (QoS2 packet resend)
2022-12-15 16:16:26 +08:00
9e3da5b661
chore: bump app versions
2022-12-14 20:07:41 +01:00
56066a03b5
Merge remote-tracking branch 'origin/release-50' into 1214-sync-master-upstreams
2022-12-14 20:04:20 +01:00
82db73c3f7
chore: bump version to v5.0.12
2022-12-14 20:02:42 +01:00
7137a422df
refactor(emqx_authn): make error messages more readable
2022-12-14 15:53:42 +01:00
abef881a73
refactor(config): no need to explicitly remove env metadata
...
after upgraded to honcon 0.32.0, the env meta is removed
by default.
2022-12-14 15:53:42 +01:00
34f7fff97d
chore: pin hocon 0.32.0
2022-12-14 15:53:42 +01:00
2d7099e3ae
refactor(emqx_bridge_resource): rename a variable
2022-12-14 15:53:42 +01:00
42c58e2a91
Merge remote-tracking branch 'origin/release-50' into 1214-sync-master-upstreams
2022-12-14 15:29:13 +01:00
f827062f0b
Merge pull request #9449 from thalesmg/gcp-pubsub-ee50
...
feat(gcp_pubsub): implement GCP PubSub bridge (ee5.0)
2022-12-14 10:31:12 -03:00
0412826dd5
refactor: change ce | ee to v | prefix for shell prompt
...
reason: 'ce' (Community Edition) is only for internal use,
when it comes to user/customer facing descriptions,
we should use Opensource edition and Enterprise edition.
Similary, for user/customer facing shell prompt,
use `v` for Opensource edition and `e` for Enterprise
2022-12-14 13:05:44 +01:00
7bdb029745
refactor: use POST not PUT for `/users/{name}/change_pwd`
2022-12-13 11:08:54 +01:00
464d0a5057
refactor(test): use a linked janitor for test teardown
2022-12-12 17:18:19 -03:00
b9bc82f87a
feat(gcp_pubsub): add `local_topic` config
...
Given the implicit convention that an egress bridge containing the
`local_topic` config will forward messages without the need for a rule
action, this was added to avoid needing a rule action.
2022-12-12 17:18:19 -03:00
a095867358
test(refactor): add ids to namespace `on_exit` callbacks
2022-12-12 17:18:19 -03:00
697b3ecf2d
docs: improve descriptions
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2022-12-12 17:18:19 -03:00
1cd91a24e9
feat(gcp_pubsub): implement GCP PubSub bridge (ee5.0)
2022-12-12 17:18:19 -03:00
fffce9316c
test(fix): avoid trying to connect to system_monitor db in tests
...
When `system_monitor`'s application is loaded, it sets a default
hostname:
```erlang
1> application:get_env(system_monitor, db_hostname).
undefined
2> application:load(system_monitor).
ok
3> application:get_env(system_monitor, db_hostname).
{ok,"localhost"}
```
And that makes tests crash when somehow it gets loaded.
By having a semantic `enable` field, we could avoid starting this
application by checking if the hostname is filled or not.
```
=ERROR REPORT==== 1-Dec-2022::13:57:20.855070 ===
** Generic server <0.7646.3> terminating
** Last message in was {command,epgsql_cmd_connect,
#{codecs => [],database => "postgres",
host => [],
password =>
#Fun<epgsql_cmd_connect.0.29916615>,
port => 5432,timeout => 5000,
username => "system_monitor"}}
** When Server state == {state,undefined,undefined,<<>>,undefined,on_message,
undefined,
{[],[]},
undefined,undefined,undefined,undefined,[],
information_redacted,[],undefined,undefined,
undefined,undefined,undefined,#{}}
** Reason for termination ==
** {badarg,
[{gen_tcp,connect_0,4,[{file,"gen_tcp.erl"},{line,207}]},
{epgsql_cmd_connect,open_socket,2,
[{file,
"/emqx/_build/default/lib/epgsql/src/commands/epgsql_cmd_connect.erl"},
{line,94}]},
{epgsql_cmd_connect,execute,2,
[{file,
"/emqx/_build/default/lib/epgsql/src/commands/epgsql_cmd_connect.erl"},
{line,54}]},
{epgsql_sock,command_exec,4,
[{file,"/emqx/_build/default/lib/epgsql/src/epgsql_sock.erl"},
{line,338}]},
{gen_server,try_handle_call,4,[{file,"gen_server.erl"},{line,721}]},
{gen_server,handle_msg,6,[{file,"gen_server.erl"},{line,750}]},
{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,226}]}]}
** Client system_monitor_pg stacktrace
** [{gen,do_call,4,[{file,"gen.erl"},{line,214}]},
{gen_server,call,3,[{file,"gen_server.erl"},{line,243}]},
{epgsql,call_connect,2,
[{file,"/emqx/_build/default/lib/epgsql/src/epgsql.erl"},
{line,203}]},
{system_monitor_pg,connect,0,
[{file,"/emqx/_build/default/lib/system_monitor/src/system_monitor_pg.erl"},
{line,151}]},
{system_monitor_pg,initialize,0,
[{file,"/emqx/_build/default/lib/system_monitor/src/system_monitor_pg.erl"},
{line,142}]},
{system_monitor_pg,handle_info,2,
[{file,"/emqx/_build/default/lib/system_monitor/src/system_monitor_pg.erl"},
{line,92}]},
{gen_server,try_dispatch,4,[{file,"gen_server.erl"},{line,695}]},
{gen_server,handle_msg,6,[{file,"gen_server.erl"},{line,771}]},
{proc_lib,init_p_do_apply,3,[{file,"proc_lib.erl"},{line,226}]}]
=CRASH REPORT==== 1-Dec-2022::13:57:20.855697 ===
crasher:
initial call: epgsql_sock:init/1
pid: <0.7646.3>
registered_name: []
exception exit: badarg
in function gen_tcp:connect_0/4 (gen_tcp.erl, line 207)
in call from epgsql_cmd_connect:open_socket/2 (/emqx/_build/default/lib/epgsql/src/commands/epgsql_cmd_connect.erl, line 94)
in call from epgsql_cmd_connect:execute/2 (/emqx/_build/default/lib/epgsql/src/commands/epgsql_cmd_connect.erl, line 54)
in call from epgsql_sock:command_exec/4 (/emqx/_build/default/lib/epgsql/src/epgsql_sock.erl, line 338)
in call from gen_server:try_handle_call/4 (gen_server.erl, line 721)
in call from gen_server:handle_msg/6 (gen_server.erl, line 750)
ancestors: [system_monitor_pg,system_monitor2_sup,system_monitor_sup,
<0.4297.3>]
message_queue_len: 0
messages: []
links: [<0.4303.3>]
dictionary: []
trap_exit: false
status: running
heap_size: 1598
stack_size: 29
reductions: 734
neighbours:
```
2022-12-12 17:18:19 -03:00
c69022f3c4
test(ci): clean config after test
...
Trying to fix this error for profile `emqx`:
```
=CRASH REPORT==== 30-Nov-2022::13:25:46.763989 ===
crasher:
initial call: application_master:init/4
pid: <0.9682.1>
registered_name: []
exception exit: {bad_return,
{{emqx_conf_app,start,[normal,[]]},
{emqx_conf_schema,
[#{kind => validation_error,path => "bridges",
reason => unknown_fields,
unknown => <<"influxdb_api_v1">>,
unmatched => <<"mqtt,webhook">>}]}}}
in function application_master:init/4 (application_master.erl, line 142)
ancestors: [<0.9681.1>]
message_queue_len: 1
messages: [{'EXIT',<0.9683.1>,normal}]
links: [<0.9681.1>,<0.44.0>]
dictionary: []
trap_exit: true
status: running
heap_size: 610
stack_size: 29
reductions: 195
neighbours:
=INFO REPORT==== 30-Nov-2022::13:25:46.777895 ===
application: emqx_conf
exited: {bad_return,
{{emqx_conf_app,start,[normal,[]]},
{emqx_conf_schema,
[#{kind => validation_error,path => "bridges",
reason => unknown_fields,
unknown => <<"influxdb_api_v1">>,
unmatched => <<"mqtt,webhook">>}]}}}
type: temporary
%%% emqx_plugins_SUITE ==> init_per_suite: FAILED
%%% emqx_plugins_SUITE ==> {{failed_to_start_app,emqx_conf,
{emqx_conf,
{bad_return,
{{emqx_conf_app,start,[normal,[]]},
{emqx_conf_schema,
[#{kind => validation_error,path => "bridges",
reason => unknown_fields,
unknown => <<"influxdb_api_v1">>,
unmatched => <<"mqtt,webhook">>}]}}}}},
[{emqx_common_test_helpers,start_app,4,
[{file,
"/__w/emqx/emqx/source/apps/emqx/test/emqx_common_test_helpers.erl"},
{line,227}]},
{lists,foreach,2,[{file,"lists.erl"},{line,1342}]},
{emqx_plugins_SUITE,init_per_suite,1,
[{file,
"/__w/emqx/emqx/source/apps/emqx_plugins/test/emqx_plugins_SUITE.erl"},
{line,34}]},
{test_server,ts_tc,3,[{file,"test_server.erl"},{line,1783}]},
{test_server,run_test_case_eval1,6,[{file,"test_server.erl"},{line,1380}]},
{test_server,run_test_case_eval,9,[{file,"test_server.erl"},{line,1224}]}]}
%%% emqx_plugins_SUITE ==> t_bad_info_json: SKIPPED
%%% emqx_plugins_SUITE ==> {tc_auto_skip,
{failed,
{emqx_plugins_SUITE,init_per_suite,
{'EXIT',
{{failed_to_start_app,emqx_conf,
{emqx_conf,
{bad_return,
{{emqx_conf_app,start,[normal,[]]},
{emqx_conf_schema,
[#{kind => validation_error,
path => "bridges",
reason => unknown_fields,
unknown => <<"influxdb_api_v1">>,
unmatched => <<"mqtt,webhook">>}]}}}}},
[{emqx_common_test_helpers,start_app,4,
[{file,
"/__w/emqx/emqx/source/apps/emqx/test/emqx_common_test_helpers.erl"},
{line,227}]},
{lists,foreach,2,[{file,"lists.erl"},{line,1342}]},
{emqx_plugins_SUITE,init_per_suite,1,
[{file,
"/__w/emqx/emqx/source/apps/emqx_plugins/test/emqx_plugins_SUITE.erl"},
{line,34}]},
{test_server,ts_tc,3,[{file,"test_server.erl"},{line,1783}]},
{test_server,run_test_case_eval1,6,
[{file,"test_server.erl"},{line,1380}]},
{test_server,run_test_case_eval,9,
[{file,"test_server.erl"},{line,1224}]}]}}}}}
```
2022-12-12 17:18:13 -03:00
34e9056779
refactor: fix typo in variable name
...
Might confuse people to think it's related to `replayq`.
2022-12-12 17:17:51 -03:00
f8685e3a58
Merge pull request #9437 from zhongwencool/authn-env-failed
...
fix: set authentication array from ENV failed
2022-12-12 19:12:27 +01:00
e57a1f2c8b
fix: set authentication array from ENV failed
2022-12-12 14:18:30 +01:00
0242d5f360
test: rename return_body to return_all in emqx_mgmt api test util
2022-12-12 13:29:11 +01:00
8009f0a3a8
test: api returns for lwm2m client posts
...
Add test coverage for HTTP 204 returns from lwm2m client API
posts. This includes a small refactoring of the request functionality
in emqx_mgmt_api_test_util.
2022-12-12 13:28:24 +01:00
a8c9d02871
fix(emqx_gateway): return 204 for lwm2m client posts
...
Change the return for lwm2m client API posts from 200 to 204 since
they contain no content.
2022-12-12 13:28:24 +01:00
6b22a074f0
refactor: move `/mqtt/sys_topics` to generic `/configs/sys_topics`
2022-12-12 13:25:42 +01:00
c2eabfe5f7
Merge pull request #9523 from qzhuyan/fix/william/bridges-ingress-and-egress
...
Fix/william/bridges ingress and egress
2022-12-12 09:36:08 +01:00
61da68ff40
fix(emqx_schema): handshake_timeout is common for all listeners
2022-12-09 16:47:19 +01:00
6b6bb09d4a
fix: ingress only bridge causes egress bridge traffic stop
2022-12-09 15:36:20 +01:00
85f54220b0
Merge pull request #9494 from sstrigler/EMQX-7992-post-trace-must-respond-with-409-on-duplicate-entry
...
fix: return 409 in case of duplicate
2022-12-09 15:10:23 +01:00
3084d1263b
Merge pull request #9519 from zmstone/1209-chore-merge-dev/ee5.0-to-release-50
...
1209 chore merge dev/ee5.0 to release 50
2022-12-09 14:29:13 +01:00
2a27d2e781
fix: return 409 in case of duplicate
2022-12-09 13:33:34 +01:00
6a4fb1241b
Merge remote-tracking branch 'origin/release-50' into 1209-chore-merge-dev/ee5.0-to-release-50
2022-12-09 12:54:16 +01:00
1472cfefd0
fix: flip order of checks to return 404 before 400
2022-12-09 12:53:04 +01:00
1f7c02ecf5
fix: return 400 if node in query doesn't look like a known node
2022-12-09 12:53:02 +01:00
a26964291d
Merge pull request #9496 from savonarola/fix-auth-chain
...
Fix `emqx_authentication` hook cooperation with other hooks
2022-12-09 14:48:18 +03:00
7ae3ecfccb
chore(retainer): optimize index writes
2022-12-09 14:42:43 +03:00
cd0ae62995
fix(auth): fix emqx_authenticator cooperation with other 'client.authenticate' hooks
2022-12-09 13:57:48 +03:00
40809b2ad0
Merge remote-tracking branch 'origin/dev/ee5.0' into release-50
2022-12-09 11:45:52 +01:00
3705d5bc73
Merge pull request #9505 from lafirest/fix/psk_r50
...
fix(psk): Add more PSK ciphers support
2022-12-09 00:00:52 +08:00
e1f09d9899
Merge remote-tracking branch 'origin/release-50' into 1208-merge-release-50-back-to-master
2022-12-08 14:27:01 +01:00
dac8845b5d
test(psk): add PSK ciphers test case
2022-12-08 11:41:57 +08:00
21a908167d
fix(psk): Add more PSK ciphers support
2022-12-08 11:41:42 +08:00
dc14cd450d
test: render config for emqx_conf only for ee bridge tests
2022-12-07 18:27:06 +01:00
c9d84b2fda
test: do not load emqx_conf app when it's not found
...
also remove stale code in emqx_common_test_helpers
2022-12-07 16:49:54 +01:00
d89dbb7caa
Merge remote-tracking branch 'origin/release-50' into 1206-chore-merge-ee50-to-release-50
2022-12-07 16:24:13 +01:00
f3b069a0d9
test: fix config load for lib-ee tests
2022-12-07 15:50:50 +01:00
b897d64b75
test: fix emqx_frame_SUITE
2022-12-07 12:20:03 +01:00
6692b0c895
feat(bridge): add Redis bridge
2022-12-06 23:15:42 +03:00
31098d6c67
test: fix bridge api tests, metrics is now a separate api
2022-12-06 19:03:32 +01:00
bd65e8aad6
Merge remote-tracking branch 'origin/release-50' into 1206-chore-merge-ee50-to-release-50
2022-12-06 16:42:50 +01:00
1c2fc4b6c3
Merge remote-tracking branch 'origin/release-50' into 1206-chore-merge-ee50-to-release-50
2022-12-06 16:35:56 +01:00
0b324da7cb
refactor: move metrics out of /rules(/:id) to /rules/:id/metrics
2022-12-06 15:23:28 +01:00
380b75d4a9
Merge pull request #9422 from emqx/1124-refactor-avoid-creating-atom-at-run
...
refactor: use static function references
2022-12-06 14:24:05 +01:00
cca3421308
refactor: use static function references
2022-12-06 09:40:03 +01:00
3e29e37691
Merge pull request #9477 from lafirest/fix/fuzzing_errors_v50
...
Fix/fuzzing errors v50
2022-12-06 08:22:46 +08:00
817554c7d7
refactor(emqx_frame): better error handling
2022-12-06 01:48:52 +08:00
16aeba24b7
Merge pull request #9472 from zmstone/1203-merge-release-50-to-master
...
1203 merge release 50 to master
2022-12-05 16:39:51 +01:00
72669080a1
fix(frame): fix potential parse errors found by fuzzing test
2022-12-05 23:16:07 +08:00
0be5c8e84b
fix: Revert "refactor: return `204` instead of `200` for `PUT /authenticator/:id`"
...
This reverts commit 3bda905e92
2022-12-05 15:52:16 +01:00
2443500884
fix: return 404 for /telemetry/data in case it's disabled
2022-12-05 12:41:27 +01:00
1ba66fc722
docs: /trace returns list not single trace
2022-12-05 11:50:52 +01:00
f8dd8d652d
docs: add swagger error codes for /trace/:name/[log|download]
2022-12-05 11:50:52 +01:00
9100b13db6
docs: fix schema for /trace/:name/log
2022-12-05 11:50:52 +01:00
64ab4ca025
test: add copy data dir test case
2022-12-05 16:25:28 +08:00
3bda905e92
refactor: return `204` instead of `200` for `PUT /authenticator/:id`
2022-12-05 09:19:55 +01:00
9b37837c9c
fix: don't save cert/authz zip on disk when emqx start
2022-12-05 16:12:21 +08:00
9fd1864d17
Merge remote-tracking branch 'origin/release-50'
2022-12-03 12:58:42 +01:00
5b4feca3cb
Merge pull request #9419 from sstrigler/EMQX-7863-post-authentication-id
...
refactor: use PUT on `/position` to move authenticator
2022-12-02 14:07:59 +01:00
485c4ddcab
Merge pull request #9393 from olcai/add-mysql-bridge-test
...
test: add basic mysql bridge test (ee5.0)
2022-12-02 09:43:22 +01:00
4cc13c4aa5
Merge pull request #9133 from lafirest/fix/limiter_api
...
fix(limiter): add `limiter` back to the configs API
2022-12-02 10:06:03 +08:00
eb017ab034
test: add test case to cover mqtt bridge config upgrade
2022-12-01 16:50:10 +01:00
9ea22d062d
refactor: make all bridges optional (required = false)
2022-12-01 16:50:10 +01:00
7adb539ae1
chore: pin hocon 0.31.2
2022-12-01 16:50:10 +01:00
28fc2b9ee9
fix(mgmt_api): add missing error codes in schema
2022-12-01 12:20:11 +01:00
5461311edc
test: more EE mysql bridge tests
2022-12-01 10:27:51 +01:00
96bff1d32e
test: improve basic tests for EE mysql bridge
2022-12-01 10:27:51 +01:00
88a0c77707
fix(limiter): add `limiter` back to the configs API
2022-12-01 15:07:15 +08:00
9a6901987f
feat: add mqtt bridge config upgrade converter
2022-11-30 21:01:59 +01:00
983e904858
fix(connector): fix ssl clear
2022-11-30 17:03:41 +01:00
81586a4c8d
chore: bump connector version
2022-11-30 23:14:54 +08:00
51ace31f30
fix(connector): fix previous incorrectly fixes
...
There was an error in the try_clear_certs2/3 clause that the argument isn't the ssl field but including it.
2022-11-30 22:14:44 +08:00
5a2265a286
Merge pull request #9407 from v-zhuravlev/master
...
Update grafana dashboards
2022-11-30 17:03:39 +08:00
b124e64399
refactor: use PUT on `/position` to move authenticator
2022-11-29 17:28:37 +01:00
e6e559710b
Merge pull request #9432 from lafirest/fix/exhook_ssl_management
...
fix(exhook): fix obsolete SSL files aren't deleted after the Exhook config update
2022-11-29 22:32:10 +08:00
311e4cd583
Merge pull request #9440 from zmstone/1128-chore-sync-release-branch-back-to-master
...
1128 chore sync release branch back to master
2022-11-29 11:47:01 +01:00
606389edd2
chore: update changes && bump version
2022-11-29 10:41:21 +08:00
f9bc700498
fix(exhook): fix obsolete SSL files aren't deleted after the Exhook config update
2022-11-29 10:40:08 +08:00
b398617614
chore: bump app versions
2022-11-28 21:12:43 +01:00
77341e7a3c
chore: bump app versions
2022-11-28 21:06:33 +01:00
9f3a9efbad
Merge remote-tracking branch 'origin/release-v50'
2022-11-28 21:02:39 +01:00
7ee53e5319
Merge tag 'v5.0.11' into dev/ee5.0
2022-11-28 21:02:21 +01:00
2582c1713e
fix: emqx_topic:join/1 instead of filename:join/1
...
filename:join/1 doesn't work on Windows for joining a topic. We now use
emqx_topic:join/1 instead.
2022-11-28 11:00:18 +01:00
95faf56077
feat: remove $queue in favor of $shared
...
This commit removes support for setting shared subscriptions with the
non-standard $queue feature. Shared subscriptions is now part of the MQTT
spec (using $shared) and we will only support that from now on.
2022-11-28 11:00:18 +01:00
05719daff2
chore: bump version to v5.0.11
2022-11-27 11:15:28 +01:00
970b3eb1a0
chore: bump to version v5.0.11-rc.1
2022-11-26 15:51:38 +01:00
5c9fff43a2
chore: add proper units for rates on the dashboard
2022-11-25 19:12:36 +03:00
5af1d6662f
chore: update grafana dashboards
2022-11-25 19:12:25 +03:00
65a1f90f58
Merge branch 'global-gc-interval' of https://github.com/zhongwencool/emqx into global-gc-interval
2022-11-25 16:39:02 +08:00
28bede0377
chore: update i18n en description
2022-11-25 16:38:40 +08:00
2fbd6c9690
Merge branch 'master' into global-gc-interval
2022-11-25 12:06:16 +08:00
345fa65241
Merge pull request #9416 from lafirest/fix/emqx_ctl
...
fix(ctl): fix unsafe `list_to_atom`
2022-11-25 09:58:07 +08:00
59ac5320b1
chore: update emqx_conf/emqx_machine version
2022-11-25 07:33:08 +08:00
6ee475d9b1
fix(emqx_authz_api_mnesia): return the right matchers
2022-11-24 20:32:00 +01:00
dbdb78d38a
chore: clarify the case when count returns zero
2022-11-24 20:28:50 +01:00
edb35c08a8
chore: refactor ms2qs function type
2022-11-24 20:14:33 +01:00
9786a6c267
refactor(mgmt): convert fuzzy filter func to named func
2022-11-24 20:14:33 +01:00
ffb3f2d2d2
chore: change emqx_live_connection tab type to ordered_set
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2022-11-24 20:14:33 +01:00
6d9e1e0d7a
test(mgmt): cover emqx_mgmt_api:cluster_query
2022-11-24 20:14:33 +01:00
36de83a50a
feat(cm): change emqx_channel_info to ordered_set table
2022-11-24 20:14:33 +01:00
b9c5a5f822
fix(delayed): return correct node name
2022-11-24 20:14:33 +01:00
0c1412315c
chore(bpapi): ignore emqx_mgmt_api:collect_total_from_tail_nodes/3
2022-11-24 20:14:33 +01:00
79a2682fd3
chore: improve the no-conditions query
2022-11-24 20:14:33 +01:00
8a0c468b01
test: refine tests for lots of List HTTP API
2022-11-24 20:14:33 +01:00
09958d9a33
chore: fix diaylzer warnings
2022-11-24 20:14:33 +01:00
9c7bf9d601
chore: update app.src
2022-11-24 20:14:33 +01:00
8f7337c9d2
chore: return undefined fuzzy searching func
2022-11-24 20:14:33 +01:00
28d391f26c
fix(mgmt): collect total number in node_query/cluster_query
2022-11-24 20:14:33 +01:00
1fe9c105aa
refactor(mgmt): smplify the node_query/cluster_query implementation
2022-11-24 20:14:33 +01:00
08121e7df6
fix(mgmt): optimize the speed of query tail pages
...
In the previous, when you query the tail pages, all the front of rows
will be queried out and formatted. It greatly hurts the speed of query.
Currently, we only format the final result rows. i.e, the query for the
last page of data will be 10x faster.
2022-11-24 20:14:33 +01:00
6837af2308
Merge branch 'release-v50' into 0720-feat-direct-deny-when-anonymous-is-not-allowed
2022-11-24 16:07:58 +01:00
08163feed7
Merge pull request #9401 from sstrigler/EMQX-7751-support-message-properties
...
EMQX 7751 support message properties
2022-11-24 14:04:25 +01:00
70b6397ada
feat: support node.global_gc_interval=disabled
2022-11-24 20:35:41 +08:00
03fb543ba8
fix(ctl): fix unsafe `list_to_atom`
...
A command can be called only when it is exists
2022-11-24 17:28:53 +08:00
2bc8b00419
feat(authn): support quick deny anonymous
2022-11-24 09:44:19 +01:00
b879c935eb
Merge pull request #9404 from JimMoen/fix-typo-50
...
fix(typo): typo in code
2022-11-24 09:39:43 +01:00
fc2793c300
fix: fix upside down function clause
2022-11-24 10:37:52 +08:00
282e6ff218
chore: set channel info once
2022-11-24 09:59:39 +08:00
67cef65fdb
refactor(emqx_connector_ssl): simplify implementation
2022-11-23 23:49:43 +01:00
6f67e3b333
feat(emqx_map_lib): add a binary_key_map help function
2022-11-23 23:49:43 +01:00
6dc5078a96
fix: fix obsolete SSL files aren't deleted after the bridge configuration update
2022-11-23 23:49:43 +01:00
afcb33aa20
feat: support publish with properties
2022-11-23 17:04:35 +01:00
acef85e11a
test: initialize clients in test setup, teardown after test
2022-11-23 17:03:43 +01:00
cded5fc6cf
Merge pull request #9398 from emqx/1121-rule-bridge-properties
...
1121 rule bridge properties
2022-11-23 15:12:24 +01:00
1719414c04
chore: update app versions
2022-11-23 11:42:49 +08:00
19405114e2
fix: fix newly found unsafe `binary_to_atom`
2022-11-23 11:07:20 +08:00
f3df2c80d8
feat: add user_properties arg for republish action
2022-11-22 20:09:59 +01:00
00c57de4c3
feat: do not drop MQTTv5 properties in rule/bridge
2022-11-22 20:09:59 +01:00
118a97a0d8
fix: change the defualt value of `max_topic_levels` to 128
2022-11-22 18:45:44 +08:00
c21fa3c339
fix(typo): typo in code
2022-11-22 09:51:30 +08:00
fcbf1bc890
fix(will-msg): fix mountpoint not working for will-msg.
2022-11-21 21:41:00 +08:00
966e6ddeeb
Merge pull request #9363 from zhongwencool/statsd-update-api
...
refactor: emqx_statsd hot update
2022-11-21 17:26:26 +08:00
0dbeab88a2
chore: update emqx_statsd.app.src descriptions
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2022-11-21 14:38:59 +08:00
1845e472e0
fix: create trace sometime failed by end_at time has already passed
2022-11-21 09:54:36 +08:00
4ed0e9e2a5
Merge branch 'master' into statsd-update-api
2022-11-21 09:31:05 +08:00
458d23ebc4
chore: bump version to v5.0.0-beta.5
2022-11-20 09:11:53 +01:00
83fe35b148
Merge remote-tracking branch 'origin/dev/ee5.0' into 1116-sync-v5.0.10-to-ee50
2022-11-18 19:23:31 +01:00
65820eb943
fix: can't get default raw config
2022-11-18 15:07:23 +08:00
d36de9ac50
refactor: emqx_statsd hot update
2022-11-18 10:43:22 +08:00
4ce3d43446
Merge pull request #9386 from lafirest/fix/flaky_banned_case
...
test: fix flaky banned case
2022-11-17 21:29:45 +08:00
e301ca09d5
Merge pull request #9373 from savonarola/fix-access-test
...
chore(acl): fix acl test
2022-11-17 18:06:43 +05:00
7b93b166dc
test: fix flaky banned case
...
since this suite has changed its start method to the `emqx_common_test_helpers:start_apps/1`, the `emqx_banned` server will never stop (its restart type is permanent), thus there is no need to manually start or stops it.
2022-11-17 14:48:25 +08:00
e5ced07665
fix: add no_return function spec to make dialyzer happy
2022-11-16 19:07:51 +01:00
7305923d12
fix: bridge name parser should not leak atom
2022-11-16 18:25:42 +01:00
c940b901f5
chore: fix app versions
2022-11-16 16:26:43 +01:00
09455edae8
Merge tag 'v5.0.10' into dev/ee5.0
2022-11-16 16:20:30 +01:00
9cc5920b0d
refactor: only PUT, no POST for '/gateways'
2022-11-16 15:58:59 +01:00
2914523117
style: remove unused import
2022-11-16 15:57:16 +01:00
07347e3f9e
style: fix typo in comment
2022-11-16 15:57:15 +01:00
2ae0125562
test(refactor): encode toxiproxy payloads with emqx_json
2022-11-16 10:57:13 -03:00
780013d5fe
Merge pull request #9367 from lafirest/feat/kick_when_is_banned
...
feat(banned): kick session when it is banned by clientid
2022-11-16 21:53:56 +08:00
b1889fa203
chore: bump emqx version && update changes
2022-11-16 18:00:32 +08:00
085074ac41
feat(banned): kick session when it is banned by clientid
2022-11-16 18:00:22 +08:00
25c32dd2f5
chore(acl): fix acl test
2022-11-15 23:30:19 +03:00
c079760b0a
fix(JWT): make the `exp` to be optional claim
2022-11-15 15:41:01 +08:00
d9e7d36580
chore: bump version && update changes
2022-11-14 09:45:38 +08:00
2f4b2ba405
fix(mgmt_api): Convert only what is needed when parsing subscription information
2022-11-14 09:44:22 +08:00
b5a84b8b0f
test: increase timeout creating listeners
2022-11-11 13:34:46 +01:00
12ba831246
fix(emqx_authn_api): return 404 for status of unknown authenticator
...
This also makes sure we call the same code everytime we access an authenticator.
Moreover we return a 500 in case a remote call fails due to technical issues.
2022-11-11 13:34:44 +01:00
6b0de714bc
chore: bump retainer version
2022-11-11 17:51:20 +08:00
4290847b9d
feat: filter out messages which the source client is banned when delivering the retained message
2022-11-10 10:21:21 +08:00
c19462cb87
Merge pull request #9327 from JimMoen/fix-disconnect-hook-by-takenover
...
fix(channel): session takenover & discarded maybe call disconnect hook
2022-11-09 08:25:44 +01:00
354b94fc2d
test: ensure all modules start
2022-11-08 20:59:24 +01:00
aa215904a9
Merge branch 'master' into authz-api-fixes
2022-11-08 18:13:15 +01:00
30d9143b0e
Merge pull request #9310 from sstrigler/fix-configs-api-for-bad-nodes
...
fix(emqx_mgmt_api_configs): use 'node' query paramter if given
2022-11-08 18:10:43 +01:00
467010e3d3
chore: bump emqx_authz app vsn
2022-11-08 17:40:34 +01:00
0678e05e84
style: fix message returned for 404
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2022-11-08 17:40:34 +01:00
ba1e19f068
fix(emqx_authz_api_sources): make schema fit to what we send
2022-11-08 17:40:34 +01:00
e0ed0855ff
fix(emqx_authz_api_sources): return 'code' in response body for 404
2022-11-08 17:40:34 +01:00
4f00206693
test: different resons for disconnect event
2022-11-08 23:22:58 +08:00
2cd457e07c
fix(channel): session takenover & discarded maybe call disconnect hook
2022-11-08 23:22:58 +08:00
dd7d4224ce
feat(delayed): check if the source client is banned when publishing a delayed message
2022-11-08 16:32:24 +08:00
ebaba0c2b1
fix: Revert "feat(banned): clean retained/delayed data when client is banned"
...
This reverts commit 69701ff578
2022-11-08 11:36:11 +08:00
04588148b7
test(influxdb): increase influxdb bridge/connector coverage (ee5.0)
2022-11-07 15:15:49 -03:00
1fb441dd9e
test: add tests for 'configs?node'
2022-11-07 14:12:21 +01:00
104b1a63d9
test: pass down Opts in request_api/X
2022-11-07 14:12:21 +01:00
8b10b78bce
fix(emqx_mgmt_api_configs): use 'node' query paramter if given
...
also fix result in error case - be compliant to schema and also return correct
http status code
2022-11-07 14:12:20 +01:00
bd13ae0ad6
fix(acl): Check the real topic in delayed messages
...
We need to check the true topic of the delayed message correctly
the cheapest way to do this is to extract the true topic from the original topic when doing ACL check
2022-11-04 10:51:52 +08:00
1580f02045
Merge pull request #9286 from lafirest/fix/list_to_atom
...
fix: use list_to_existing_atom to replace some risky list_to_atom
2022-11-04 09:46:58 +08:00
e9d31b2f4a
Merge pull request #9268 from sstrigler/EMQX-7817-fix-unexpected-400
...
Fix unexpected 400
2022-11-03 12:06:38 +01:00
14c8b5ebb1
fix(mgmt): Ensure the CLI will not create useless atom
...
The log level, the log handler id and the listener id all of them already exist,
so it's better to avoid the user create a useless atom by mistake input
2022-11-02 16:50:43 +08:00
bb7476d3af
fix(listeners): Constraints the atom convert when parsing the esockd access rules
...
esockd rules only use words 'allow' and 'deny', both are existing,
so it is better to restrict the conversion and print a log when errors
2022-11-02 14:45:47 +08:00
5886db08e0
Merge pull request #9279 from lafirest/fix/binary_to_atom
...
fix: use binary_to_existing_atom to replace some risky binary_to_atom
2022-11-02 10:57:05 +08:00
b6445cdc14
test: remove unused var warning
2022-11-01 16:53:20 -03:00
612e5acea8
fix: return 404 instead of 400 for unknown gateway
2022-11-01 11:04:29 +01:00
3cc76c0adf
fix(coap): Ensure that the retain flag is a boolean value
2022-11-01 17:28:40 +08:00
60492615ba
fix(API): Ensure that the node name is known
2022-11-01 17:28:34 +08:00
d0687c7aaa
fix(connector): keep connector name type as binary don't convert it to atom
...
After investigation, it was confirmed that there was no need to convert the connector name to atom
2022-11-01 15:36:31 +08:00
6c52d5de1f
fix(bridge): Ensure that the node name is known
2022-11-01 15:36:10 +08:00
73b4ac9f65
fix(bridge): keep bridge name type as binary don't convert it to atom
...
After investigation, it was confirmed that there was no need to convert the bridge name to atom
2022-11-01 11:24:24 +08:00
198ddda8bc
docs(status_api): add remark about feature introduction versions
2022-10-31 14:10:09 -03:00
935513d38c
docs(fix): remove dynamic example paths from api docs
2022-10-31 14:02:33 -03:00
12addc2118
Merge pull request #9230 from thalesmg/status-endpoint-alias-50
...
feat(mgmt): add alias endpoint for health check
2022-10-31 10:22:17 -03:00
aeca8833f5
Merge pull request #9250 from id/fix-typo-in-http-error-code
...
fix: typo in http error code
2022-10-31 10:23:55 +01:00
ccff64f2c1
docs: re-group api tags for gateway apps
2022-10-31 09:01:44 +01:00
a0cd344752
Merge pull request #9258 from sstrigler/master
...
Re-UP fix(emqx_gateway_api): don't crash on unknown status
2022-10-28 22:18:10 +02:00
f906a5527a
Merge pull request #9228 from zmstone/1025-fix-drop-tuple-header-values
...
fix(emqx_rule_events): drop tuple-value from message headers
2022-10-28 14:00:57 +02:00
d995842f36
Merge branch 'master' into fix-gw-api-erros
2022-10-28 10:18:21 +08:00
18235a7125
chore: update emqx_managment bpapi.versions
2022-10-28 09:16:05 +08:00
af79e652da
chore: clear dialyzer warning.
2022-10-28 09:16:05 +08:00
ea95f792e0
refactor: multicall node_info to improve /node speed
2022-10-28 09:14:33 +08:00
d704de4a84
fix(emqx_rule_events): drop tuple-value from message headers
...
the message headers are fed to a JSON ecnoder which
may crash if the header value is a tuple
2022-10-27 20:31:33 +02:00
4cadb86b18
docs: fix typos
2022-10-27 20:09:31 +02:00
d0ca79fc9e
feat(mgmt): add alias endpoint for health check
...
This allow use to reference `/status` in the API documentation without
manually editing the `swagger.json` file.
2022-10-27 13:20:04 -03:00
d4adf8532e
fix: typo in http error code
2022-10-27 18:14:46 +02:00
c72f3a0ae9
Merge pull request #9211 from thalesmg/fix-mgmt-endpoint-status-code-v50
...
fix(mgmt_api): return 503 when emqx is not running in `/status` (5.0)
2022-10-27 11:11:00 -03:00
3e3653ab22
Merge pull request #9246 from zmstone/1027-fix-docs-br-tag
...
1027 fix docs br tag
2022-10-27 15:00:00 +02:00
571420d8c6
Merge pull request #9235 from zhongwencool/improve-prometheus
...
refactor: update emqx_prometheus via emqx_config_handler
2022-10-27 20:12:24 +08:00
c157392452
docs: fix self-closing html tag, change </br> to <br/>
2022-10-27 13:57:18 +02:00
ef5687d465
fix(emqx_gateway_api): don't crash on unknown status
2022-10-27 12:35:15 +02:00
fd2a3f816e
Merge pull request #9238 from zmstone/1026-fix-docs
...
docs: fix zh punctuations
2022-10-27 10:39:22 +02:00
bb6c3ed4ae
docs: fix more zh translation desc
2022-10-27 08:39:58 +02:00
a314950be9
docs: fix zh punctuations
2022-10-26 16:19:38 +02:00
d6dfead31d
fix: prometheus ct failed
2022-10-26 22:05:20 +08:00
3233a40af3
chore: don't delete bpapi when 5.0.x
2022-10-26 21:58:51 +08:00
97124be63a
chore: add next_push_ms to emqx_prometheus:info/0
2022-10-26 21:32:19 +08:00
1757342e5b
chore: make dialyzer happy
2022-10-26 21:32:19 +08:00
e22f8ff2a8
refactor: sync emqx_prometheus via emqx_config_handler
2022-10-26 21:31:19 +08:00
6c8936467e
chore(ekka): Bump version to 0.13.6
2022-10-26 12:08:14 +02:00
0eca531e64
feat: add `retry-after` headers to unavailable response
2022-10-25 15:01:05 -03:00
049f988642
chore: update apps/emqx_conf/src/emqx_conf_schema.erl
...
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
2022-10-25 22:07:48 +08:00
4c5e64d5a3
feat: hibernate after send data to prometheus push_gateway
2022-10-25 12:27:25 +08:00
8578024637
chore: bump emqx_prometheus to 5.0.3
2022-10-25 11:21:16 +08:00
6710736243
feat: add prometheus collectors config
2022-10-25 09:41:58 +08:00
997a262c96
fix(mgmt_api): return 503 when emqx is not running in `/status` (5.0)
2022-10-24 14:53:41 -03:00
93195f7b5b
chore: fix introduced_in for new proto APIs
2022-10-24 11:53:51 +02:00
637bc886bb
chore: bump release version to 5.0.10
2022-10-24 11:49:20 +02:00
e3240b52a8
chore: bump app versions
2022-10-24 11:48:17 +02:00
508c0e84d0
Merge branch 'release-v50' into master
2022-10-24 11:46:31 +02:00
11daaa08e2
chore: bump version numbers to 5.0.9
2022-10-24 09:42:25 +02:00
fa5d756ae6
Merge pull request #9186 from HJianBo/more-understanderable-trans
...
chore(docs): translate Max Awaiting PUBREL confs
2022-10-21 17:29:28 +02:00
ca052bd0f4
docs: Update apps/emqx/i18n/emqx_schema_i18n.conf
2022-10-21 17:28:49 +02:00
918c011e33
Merge pull request #9198 from lafirest/test/rmv_unused_test_case
...
test(shared_sub): remove redundant test case
2022-10-21 12:36:52 +02:00
9d650a69b8
fix(gen_rpc): Fix Chinese translation
2022-10-21 10:25:22 +02:00
0f03449b43
chore: improve max_awating_rel_timeout conf docs
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2022-10-21 16:08:09 +08:00
49dd25cb14
chore: make spellcheck happy
2022-10-21 14:38:46 +08:00
1d564ab8d5
test(shared_sub): remove redundant test case
2022-10-21 14:37:46 +08:00
0ca4f30a34
Merge pull request #9193 from zmstone/1020-chore-upgrade-gun-1.3.9
...
1020 chore upgrade gun 1.3.9
2022-10-21 08:13:21 +02:00
6d232fda5c
chore(i18n): improve the max_awaiting_rel desc
2022-10-21 10:27:20 +08:00
72a228c521
chore: update apps/emqx/i18n/emqx_schema_i18n.conf
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2022-10-21 09:53:31 +08:00
d1332b72e7
feat(api/publish): return detailed publish results
...
Prior to this change, the publish API returns 200 in most of
the cases.
This change provides more insights to the publish result.
For single message publish endpoint (`publish/`):
HTTP error codes are:
200: Everything is OK
202: No subscriber for the topic
400: When mesage is invalid message.
e.g. bad topic name or QoS out of range.
503: Failed to dispatch the message. e.g. during EMQX restart.
The response body is a JSON object with two fields
`message_id`, and `publish_result`.
The `message_id` is a globally unique ID for tracing.
`publish_result` is `"OK"` when the message is delivered
to at least one subscriber.
Otherwise `"no_subscriber"`.
`publish_result` may also be some other informative
message to hint the failure result, the content of which
may change in the future.
For `publish/bulk` endpoint:
200: When all message in the bulk are published OK
202: If at least one message in the bulk had `"no_subscriber"` result
400: When mesage is invalid message. e.g. bad topic name or
QoS out of range.
503: When there is at least one message failed at dispatch.
The reply body is a list of JSON objects having the same layout
as for hte `publish` endpoint.
2022-10-20 20:03:27 +02:00
b3ffe89f35
test: assert message receive pid is in the expected pids list
2022-10-20 19:10:45 +02:00
d0120e1edc
chore(gen_rpc): Bump version to 3.0.0
2022-10-20 16:32:06 +02:00
fa020d036f
chore(docs): translate Max Awaiting PUBREL confs
2022-10-20 20:14:36 +08:00
c7a90d73b2
fix(shared): do not redispatch shared messages for certain shutdown
...
For takeover, there should be no message re-dispatch because
the messages will be retried by the new session.
For kick, messages should not be re-dispatched for security reason.
i.e. if admin has identified that there are malicious messages
stored in persisted sessions, killing the session should not
cause messages to be re-dispatched
2022-10-20 13:51:48 +02:00
c0c2657a80
Merge pull request #9139 from lafirest/fix/clean_blocked_user_data
...
feat(banned): clean retained/delayed data when client is banned
2022-10-20 18:00:48 +08:00
0546cd3d1a
Merge pull request #9123 from lafirest/fix/kick_seesion_redispatch
...
fix(shared_sub): kick session should not cause session message redispatch
2022-10-19 09:47:10 +08:00
62eeb4b8e8
feat(resource): reset metrics when stopping a resource
2022-10-18 09:32:35 -03:00
7b3c67fbe9
test(shared_sub): ensure snabbkaffe will be stopped
2022-10-18 13:47:57 +08:00
bdaadda479
fix(banned): fix nit code
2022-10-18 13:39:48 +08:00
3f1f244310
fix: fix bpapi versions
2022-10-18 13:39:48 +08:00
b2eed47976
chore: bump retainer version && update CHANGES
2022-10-18 13:36:08 +08:00
69701ff578
feat(banned): clean retained/delayed data when client is banned
2022-10-18 13:35:09 +08:00
c0ed8b82aa
Merge branch 'trace-log-detail-api' of https://github.com/zhongwencool/emqx into trace-log-detail-api
2022-10-17 09:49:55 +08:00
77a5125366
chore: update apps/emqx_management/src/emqx_mgmt_api_trace.erl
...
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
2022-10-17 09:45:00 +08:00
58b990064c
chore: update bpapi.verions
2022-10-17 09:43:17 +08:00
4d9cae0387
feat: get trace file's detail via /trace/:name/log_detail
2022-10-17 09:43:15 +08:00
bc0cc80d32
Merge pull request #8924 from zhongwencool/authn-config-check
...
fix: authentication should be array, not struct
2022-10-17 09:14:05 +08:00
f2db35db39
chore: delete unused function clause
2022-10-14 10:46:11 +02:00
bfc780f95b
Merge branch 'master' into authn-config-check
2022-10-14 16:36:50 +08:00
5a8cab46a9
test: update publish api test suite
2022-10-14 10:17:22 +02:00
c2f176c1e7
fix(api): publish API only returns message ID
2022-10-14 09:49:46 +02:00
a02fea0a19
chore: update bpapi.verions
2022-10-14 15:16:09 +08:00
4579d7fff8
feat: get trace file's detail via /trace/:name/log_detail
2022-10-14 11:38:39 +08:00
2d01726b22
fix: account calls when resource is not connected as matched
2022-10-13 15:32:04 -03:00
1b2b629cdd
feat: emit telemetry events for all resource worker metrics
2022-10-13 15:32:04 -03:00
56000cbf3e
refactor: more rigorous checking of flapping to improve stability of the system
...
port: https://github.com/emqx/emqx/pull/9045
2022-10-12 10:03:47 +08:00
5a66c8b117
Merge pull request #9082 from HJianBo/update-api-docs
...
chore(i18n): enrich HTTP API desc
2022-10-12 09:36:11 +08:00
f0ff32c031
test: fix tests after counter changes
2022-10-11 17:45:48 -03:00
357e5919ce
chore: add copyright disclaimer
2022-10-11 09:51:16 -03:00
57270fb8fc
feat: add support for counters and gauges to the Kafka Bridge
...
This commit adds support for counters and gauges to the Kafka Brige.
The Kafka bridge uses [Wolff](https://github.com/kafka4beam/wolff ) for
the Kafka connection. Wolff does its own batching and does not use the
batching functionality in `emqx_resource_worker` that is used by other
bridge types. Therefore, the counter events have to be generated by
Wolff. We have added
[telemetry](https://github.com/beam-telemetry/telemetry ) events to Wolff
that we hook into to change counters and gauges for the Kafka bridge. The
counter called `matched` does not depend on specific functionality of
any bridge type so the updates of this counter is moved higher up in the
call chain then previously so that it also gets updated for Kafka
bridges.
2022-10-10 14:40:57 -03:00
b4eb0f18f9
fix(shared_subs): rename redispatch function name and simply test case
2022-10-10 18:06:55 +08:00
f0769cb765
fix(shared_sub): kick session should not cause session message redispatch
2022-10-10 13:52:09 +08:00
63774ba5d3
Merge pull request #9104 from zmstone/1005-fix-shared-sub-dispatch
...
fix(shared): re-dispatch inflight (QoS1) and mqueue messages
2022-10-09 11:41:30 +02:00
d600c870af
Merge pull request #9060 from lafirest/fix/delayed_pub
...
fix(delayed): Improve time precision of delayed messages
2022-10-09 10:39:31 +08:00
1c29e2806a
test(shared): add a test case to ensure shared dispatch retry
...
to ensure retry will not enter a dead loop
2022-10-05 22:33:49 +02:00
e8279a02ef
fix(shared): re-dispatch inflight (QoS1) and mqueue messages
...
when session terminates (not due to take over)
shared delivery should be re-dispatched to other members
in the group
2022-10-05 22:33:48 +02:00
abb941d161
docs: remove port 8081
...
port 8081 is the management API in 4.x
in 5.0 api port is 18083 (same as for serving the dashboard)
2022-10-05 17:15:19 +02:00
d43b680f14
chore: add comments to explain`/status` cant be found in swagger docs
2022-10-01 09:40:27 +08:00
7d7b05ae4e
chore: update app.src
2022-09-30 23:32:23 +08:00
93d3fec73f
chore(i18n): correct tags name
2022-09-30 23:14:19 +08:00
6589a66710
Merge branch 'update-api-docs' of github.com:HJianBo/emqx into update-api-docs
2022-09-30 23:05:07 +08:00
a84c6f938c
chore(swagger): caption tags name
2022-09-30 23:04:26 +08:00
9c6c13789e
chore: update apps/emqx_gateway/i18n/emqx_gateway_api_authn_i18n.conf
...
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
2022-09-30 23:03:01 +08:00
8292572da6
chore: apply suggestions from code review
...
Co-authored-by: Thales Macedo Garitezi <thalesmg@gmail.com>
2022-09-30 23:02:28 +08:00
d17c473dc2
chore(i18n): fix the bad desc for statsd
2022-09-30 18:57:08 +08:00
5b219deb4a
Merge remote-tracking branch 'zibo/chore/api-desc' into update-api-docs
2022-09-30 18:48:05 +08:00
0975bf21a9
docs: improve api desc for statsd
2022-09-30 17:55:12 +08:00
5fa1e63392
chore(gw): update HTTP API docs for gateway
2022-09-30 17:44:36 +08:00
f08982be93
chore: improve api desc for alarms
2022-09-30 15:34:49 +08:00
d1a15f1a43
chore: improve api descs for banned
2022-09-30 15:05:01 +08:00
242a69359c
Merge pull request #9047 from HJianBo/remove-colon-port
...
Improve the `ip_port()` definition and `bind` print format
2022-09-29 05:56:50 +02:00
834910b6f6
chore: update app.src
2022-09-27 17:24:44 +08:00
39ad172377
chore: replace ip_port() wuth host_port() for all connectors
2022-09-27 15:19:42 +08:00
6581911d5c
Merge remote-tracking branch 'stone/0922-upgrade-ip-port-schema' into remove-colon-port
2022-09-27 15:08:27 +08:00
00e4b4da5a
fix(schema): support hostname.domain:port for mqtt bridge
2022-09-27 09:02:49 +02:00
56816559d9
chore: bump emqx_modules && update CHANGES
2022-09-27 13:39:25 +08:00
6836a502ac
fix(delayed): Improve time precision of delayed messages
...
Use milliseconds internally in emqx_delayed to store the publish time, improving precision
2022-09-27 13:24:54 +08:00
607f68bab1
chore(schema): don't automaticly add ipv4 address if configured as
...
`:1883`
2022-09-27 13:01:39 +08:00
03eaa07c02
chore: add more comments for bind display perference
2022-09-27 12:51:00 +08:00
129f09f88b
chore: remove extra information from denied lwt log
2022-09-26 15:23:59 -03:00
19e3f5919e
chore: release e5.0.0-beta.4
2022-09-26 19:54:01 +08:00
dfe14be8b2
chore: bump app vsns
2022-09-26 18:23:28 +08:00
c9904e78aa
chore: remove colon port in HTTP-API and CLI
...
In the https://github.com/emqx/emqx/pull/8571 , we add a colon before the
port. But it was not popular, so we removed ta in this PR
2022-09-26 17:30:54 +08:00
4135910b42
chore: merge master into dev/ee5.0
2022-09-26 09:52:33 +08:00
f6ac4c3a76
Merge pull request #8798 from zmstone/0815-feat-add-kafka-connector
...
feat: Add Kafka connector
2022-09-24 22:57:50 +02:00
d24441b204
fix(bridges): some issues found in code review
2022-09-23 18:32:39 +08:00
7b601bf970
chore: delete bad parse_bridge function clause
2022-09-23 11:53:02 +02:00
2984397e73
chore: apps vsn bump
2022-09-23 17:09:15 +08:00
fc3fdfb994
fix(build): apply PR#8956 changes
2022-09-23 17:09:10 +08:00
adc67b165b
test: test cases for Kafka bridge REST API
2022-09-23 10:09:07 +02:00
85835256f1
Merge tag 'v5.0.8' into merge-release-v5.0.8-into-master
2022-09-23 16:06:44 +08:00
516d60c7da
build: fix deps consistency check
2022-09-23 09:00:17 +02:00
5ef1a978bd
chore: bump slow subs version && update CHANGES
2022-09-22 17:59:11 +08:00
89af9c4a5f
fix(slow_subs): fix timestamp unit error and update config not work
...
1. The unit of `deliver_begin_at` is incorrectly used the `seconds`, the resulting is incorrect when `stats_type` is `internal` or `response`
2. The config update doesn't actually take effect, the `load` function always used the old config
2022-09-22 17:57:51 +08:00
9ea0147a8c
feat(rule engine jq function): config for changing implementation
...
This commit adds a rule engine configuration option for changing the
implementation module used for the rule engine function jq. The two
options are `jq_port` (uses Erlang port programs to interact with jq)
and `jq_nif` (uses an Erlang NIF library to interact with jq).
Thanks to @terry-xiaoyu (Xinyu Liu <506895667@qq.com>) for Chinese
translations
2022-09-22 09:02:30 +02:00
6d37fc8dcb
Merge pull request #9012 from JimMoen/rm-influxdb-udp
...
Hide influxdb udp bridge.
2022-09-22 10:33:05 +08:00
b325633390
refactor(resource): resume from queue/inflight-window with async-sending and batching
2022-09-21 22:58:47 +08:00
c11afc357e
fix(auth): use empty strings for absent placeholder values
2022-09-20 15:20:55 +03:00
8c718d891f
Merge pull request #9002 from zhongwencool/fix-listener-crash
...
fix: /listeners API crash when there are nodes still in initial conf
2022-09-20 15:25:03 +08:00
6788881642
fix: hide influxdb udp config
2022-09-20 14:46:59 +08:00
2551c51a8c
fix: ct failed
2022-09-20 11:37:49 +08:00
62957b298b
chore(ekka): Bump version to 0.13.5
2022-09-19 18:21:32 +02:00
0241185225
chore: Add test coverage for listeners API
2022-09-19 18:25:25 +08:00
386110ae1e
fix: /listeners API crash when some nodes still in init configuration
2022-09-19 15:24:36 +08:00
cc327629c3
Merge pull request #8992 from terry-xiaoyu/fast_resume_from_inflight_full
...
Fast resume from inflight full
2022-09-18 17:49:04 +08:00
c20ad3733a
fix: check for authorization on topic before publishing last will testament
...
fixes #8978
Without checking for authorization, a client can, on abnormal
termination, publish a message to any topic, including `$SYS` ones.
2022-09-16 17:31:22 -03:00
dca522d7d3
test: add tests for publishing lwt when deny_action is disconnect
2022-09-16 15:11:54 -03:00
87ab2e3a2d
fix: check conn state before sending will message
2022-09-16 15:11:54 -03:00
9aa7e826cb
refactor(resource): fast resume resource worker if inflight msgs are ACKed
2022-09-17 00:34:30 +08:00
ba37ab4938
chore: bump vsn to 5.0.8
2022-09-16 19:32:17 +08:00
8307f04c2e
refactor(resource): save inflight size into the ETS table
2022-09-16 16:52:08 +08:00
a660004fa4
fix(bridge): mqtt bridge client info `username` & `password`
...
for non configured `username` and `password`, default values `<<>>` should be
used. emqtt needs the values.
2022-09-16 15:09:51 +08:00
0336b935a0
Merge pull request #8901 from JimMoen/fix-bridge-api
...
- for connectors using ecpool, parse connect error `Reason` when start pool failed.
- Refine InfluxDB bridge desc.
2022-09-16 10:22:06 +08:00
5056cbebf4
chore: update apps/emqx_authn/src/emqx_authn_app.erl
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2022-09-16 09:45:37 +08:00
6bd72fe5a1
fix: check authn's mechanism field
2022-09-16 09:45:37 +08:00
49829caaa0
fix: check authn(lazy type) config when boot
2022-09-16 09:45:36 +08:00
0b07561e9b
fix: ensure authentication is array, not struct
2022-09-16 09:45:36 +08:00
14b5977996
feat(authz): Support `cert_common_name` and `cert_subject` in Authz
2022-09-15 18:02:54 +08:00
8054144357
chore: bump vsn
2022-09-15 10:20:25 +08:00
d5d3972ff5
chore: add test cases for MQTT Bridge reconnecting
2022-09-15 10:19:33 +08:00
0390a5e547
fix(bridge): mysql bridge error case
2022-09-15 09:36:52 +08:00
d9c9a1dec3
Merge pull request #8958 from JimMoen/fix-ssl-drop-invalid-certs
...
fix(bridge/authz/exhook): no need to drop invalid certs
2022-09-15 09:01:08 +08:00
4e211c12d3
fix(mqtt_bridge): return value of sending messages was discarded
2022-09-15 08:57:01 +08:00
8845da130e
Merge pull request #8957 from HJianBo/strip-double-quote
...
chore: support strip double quote in authn/authz
2022-09-14 17:35:41 +08:00
9ffbff11c2
Merge pull request #8956 from lafirest/fix/redis_authn
...
fix(authn_redis): Add new clause for non-existent key check
2022-09-14 17:05:34 +08:00
8590fef829
fix(authn_redis): Avoid duplicating check for non-existent keys
2022-09-14 16:30:59 +08:00
a461375b30
chore: support strip double quote in authn/authz
...
more compatibility for https://github.com/emqx/emqx/pull/8827
2022-09-14 15:25:31 +08:00
1c03c236f5
fix(mqtt_bridge): handle send_to_remote in idle state
2022-09-14 15:19:30 +08:00
f41adb0997
refactor: change some default values of resource_opts
2022-09-14 15:18:07 +08:00
62fd955a0e
fix(authn_redis): make dialyzer happy
2022-09-14 14:16:43 +08:00
f018b8ab49
fix(bridge/authz/exhook): no need to drop invalid certs
2022-09-14 14:08:55 +08:00
9e97760520
fix(authn_redis): Add new clause for non-existent key check
...
fix #8800
when the key not-existing, redis may return a list that all elements are `undefined`
2022-09-14 11:30:26 +08:00
53bc6f47e7
Merge pull request #8948 from zhongwencool/deprecated-etc-dir
...
chore: deprecated etc_dir since 5.0.8
2022-09-14 10:05:10 +08:00
0c1595be02
feat: Add Kafka connector
2022-09-13 19:46:56 +02:00
b5bf5d3adb
fix: mqtt bridge payload default value
2022-09-13 18:58:01 +08:00
2c7d518c19
Merge pull request #8851 from zhongwencool/denny-update-local-override-conf
...
feat: deny hot updates to the configuration in local-override.conf
2022-09-13 18:49:51 +08:00
56c1ac5a82
chore: deprecated etc_dir since 5.0.8
2022-09-13 18:38:36 +08:00
9e07f074bf
Merge pull request #8866 from HJianBo/port-exhook-exproto-bugfixes
...
fix(exproto): avoid udp client process leaking
2022-09-13 18:29:41 +08:00
4534966e36
Merge remote-tracking branch 'origin/master' into dev/ee5.0
2022-09-13 12:16:54 +02:00
b9ae4ea276
refactor: rename some metrics for emqx_resource
2022-09-13 14:04:25 +08:00
e282e3986f
Merge branch 'using-erlang-system-time-5' into release-v5.0.8
2022-09-13 11:22:57 +08:00
522f650096
chore: apply review suggestions
2022-09-13 10:28:53 +08:00
44f8108228
chore: update app vsn
2022-09-13 09:15:50 +08:00
4384cae29e
test: fix failed tests
2022-09-13 09:15:50 +08:00
533569ad2a
chore: fix app vsn check
2022-09-13 09:15:50 +08:00
fbc2130865
test: add test for idle_timeout parameter
2022-09-13 09:15:28 +08:00
f8614196ac
test: ensure udp client keepalive value getting right value
2022-09-13 09:15:28 +08:00
ebb2824e15
test: ensure hooks has unloaded if grpc is blocked
2022-09-13 09:15:28 +08:00
dfc6e34680
fix(exproto): avoid udp client process leaking
...
porting from v4.x:
- https://github.com/emqx/emqx/pull/8575
- https://github.com/emqx/emqx/pull/8628
- https://github.com/emqx/emqx/pull/8725
2022-09-13 09:15:28 +08:00
a715573c64
Merge branch 'master' into using-erlang-system-time-5
2022-09-13 09:09:06 +08:00
061e3c264b
fix(authn_redis): fix that redis authn will deny the unknown users
2022-09-09 15:28:01 +08:00
a770447e75
fix(authn_redis): fix that redis authn will deny the unknown users
2022-09-09 14:53:31 +08:00
5ba31cb192
fix(api): add listener create API from `POST /listeners/{type:name}` to `POST /listeners`
...
Old:
API: POST /listeners/{type:demo}
Body: {"type" : "tcp", "id" : "tcp:demo"}
New:
API: POST /listeners
Body: {"type" : "tcp", "name" : "demo"}
2022-09-09 10:46:42 +08:00
9368ae9fa8
test(retainer): add test case for start after retianer is disabled
2022-09-09 10:46:42 +08:00
8768884e2b
chore: bump emqx_retainer version && update CHANGES-5.0.md
2022-09-09 10:46:42 +08:00
42e2d00cfa
fix(retainer): fix that EMQX can't start when the retainer is disabled
2022-09-09 10:46:41 +08:00
de06d1c539
Merge pull request #8876 from lafirest/fix/listeners_api
...
fix(api): add listener create API from `POST /listeners/{type:name…
2022-09-09 10:14:46 +08:00
67945515c9
Merge pull request #8911 from lafirest/fix/retainer_start_error
...
fix(retainer): fix that EMQX can't start when the retainer is disabled
2022-09-09 10:14:34 +08:00
47b35f0c6a
fix(api): add listener create API from `POST /listeners/{type:name}` to `POST /listeners`
...
Old:
API: POST /listeners/{type:demo}
Body: {"type" : "tcp", "id" : "tcp:demo"}
New:
API: POST /listeners
Body: {"type" : "tcp", "name" : "demo"}
2022-09-08 20:28:40 +08:00
1a835e9bd4
test(retainer): add test case for start after retianer is disabled
2022-09-08 19:13:02 +08:00
0e633f87b3
Merge branch 'master' into denny-update-local-override-conf
2022-09-08 17:17:07 +08:00
641763d4d7
chore: update app.src
2022-09-08 16:14:42 +08:00
8521d8dac5
fix(time): replace os:system_time with erlang:system_time
...
Avoid the problem of inaccurate timers caused by mixing erlang:system_time/0-1
and os:system_time/0-1
2022-09-08 16:13:05 +08:00
9f6fb4f1ce
Merge branch 'master' into fix-coap-topic
2022-09-07 17:48:44 +08:00
81ec4c4403
Merge pull request #8906 from zmstone/merge-master-to-ee50-a
...
Merge master to ee50
2022-09-07 11:19:41 +02:00
2b33ca6d49
fix: no error log print if insert bool values into mysql
2022-09-07 16:00:09 +08:00
a526c39ff5
chore: bump emqx_retainer version && update CHANGES-5.0.md
2022-09-07 14:49:33 +08:00
de36b77261
fix(retainer): fix that EMQX can't start when the retainer is disabled
2022-09-07 14:48:28 +08:00
2943cbc261
Merge pull request #8857 from zhongwencool/cluster-rpc-when-node-down
...
feat: cluster-rpc failed fast when some nodes is down
2022-09-07 14:34:36 +08:00
c9b6dfd7f9
Merge pull request #8905 from zmstone/0906-warn-default-erlang-cookie
...
refactor(cookie): Warning message when boot with default Erlang cookie
2022-09-07 08:06:55 +02:00
33341011d8
chore: improve wait_for_nodes_commit/4 function
2022-09-07 10:19:46 +08:00
758b1979ab
chore: Apply suggestions from code review
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2022-09-07 10:19:46 +08:00
1175008a74
feat: cluster-rpc failed fast when some nodes is down
2022-09-07 10:19:46 +08:00
a67484422d
Merge pull request #8902 from terry-xiaoyu/check_dependent_actions
...
Check dependent actions before removing a data-bridge
2022-09-07 08:54:44 +08:00
befc4acced
Merge remote-tracking branch 'origin/master' into merge-master-to-ee50-a
2022-09-06 20:31:38 +02:00
f785da075b
ci: only start required docker for integration tests
2022-09-06 19:25:53 +02:00
ac840e318e
refactor(cookie): Warning message when boot with default Erlang cookie
2022-09-06 18:58:35 +02:00
3f758ca36f
fix(tls): fix ciphers cache return `ok` at the first time call
2022-09-06 16:42:02 +08:00
499da1ebe0
chore: add emqx_release:edition_longstr()
2022-09-06 15:46:18 +08:00
0caaccaa0f
test: add tests for `/` leading topic
2022-09-06 15:38:32 +08:00
da4efc11c2
chore: log authn-http parsing failed reason
2022-09-06 15:38:32 +08:00
d6b222d1ff
test: fix coap authz suite failures
2022-09-06 15:38:32 +08:00
55c1a1868a
fix(coap): remove the leading `/` in assembling publish topic
2022-09-06 15:38:32 +08:00
60a90858f8
feat: check dependent actions before removing the bridges
2022-09-06 15:34:23 +08:00
614be2768f
Merge pull request #8892 from zhongwencool/emqx_vars_override
...
feat: don't override RUNNER_LOG_DIR env in emqx_vars
2022-09-05 22:46:24 +08:00
9408aeb719
Merge pull request #8420 from zmstone/0705-refactor-delete-unused-module
...
chore: delete unused schema module
2022-09-05 16:33:07 +02:00
09d640c1b6
Merge pull request #8887 from thalesmg/bugfix-will-msg-not-connected
...
bugfix: do not publish last will when authentication failed
2022-09-05 10:38:47 -03:00
9dfa82b448
fix(shared_sub): Dispatch shared messages via gen_rpc
2022-09-05 14:06:59 +02:00
e0fcf07cf9
fix: do not publish last will when authentication failed
...
fixes #8886
2022-09-05 08:55:47 -03:00
03766d54cc
feat(emqx_rpc): call with timeout
2022-09-05 13:38:34 +02:00
c2d03838e2
fix(bpapi): Return undefined for unknown API on the node
2022-09-05 12:29:33 +02:00
ed4e890db9
chore: bump emqx_conf to 0.1.4
2022-09-05 16:15:31 +08:00
6de7881569
feat: remove node.etc_dir config
2022-09-05 16:11:11 +08:00
d73f22181d
chore: fix dialyzer warning.
2022-09-05 15:02:50 +08:00
57cc880977
chore: change community to opensource
2022-09-05 14:27:47 +08:00
d447659365
feat: add edition info to /nodes api
2022-09-05 11:29:49 +08:00
d4785553b9
Merge pull request #8872 from JimMoen/fix-mqtt-bridge-fields
...
Fix mqtt bridge fields.
- Show ssl file path in Dashboard.
- MQTT bridge `payload` field not required.
merge `v5.0.7` into `master`.
2022-09-05 09:46:45 +08:00
c695e67e18
chore: release e5.0.0-beta.3
2022-09-03 12:27:20 +08:00
23b6ff399d
Merge pull request #8844 from thalesmg/mongodb-bridge
...
feat: add mongodb bridge (e5.0)
2022-09-03 12:27:01 +08:00
7fed4faac3
Merge pull request #8859 from terry-xiaoyu/refactor_counters_for_resources
...
Some improvements and bug fixes to emqx_resources
2022-09-03 12:16:49 +08:00
d533e35df0
chore: update app vsn
2022-09-02 22:26:21 +08:00
26234d38b9
fix: mark the async msg 'queuing' not 'sent.inflight' on recoverable_error
2022-09-02 18:41:43 +08:00
a41461ac93
chore: update apps/emqx_authn/src/simple_authn/emqx_authn_jwt.erl
2022-09-02 16:17:25 +08:00
16618131ad
fix(bridge): mqtt source/sink bridge use empty payload template
2022-09-02 14:44:38 +08:00
2693fc263d
fix(bridge): show file paths for SSL certs in dashboard for bridge
2022-09-02 14:12:03 +08:00
83f21b4c65
refactor(resource): remove metrics 'sent.exception'
2022-09-02 12:46:53 +08:00
b45f3de8db
refactor(resource): rename metrics batched,queued -> batching,queuing
2022-09-02 12:41:14 +08:00
74659bb864
fix(bridge): rm mqtt bridge default `username` and `password`
2022-09-02 10:43:32 +08:00
1d70e0b0ec
Merge tag 'v5.0.7' into fix-mqtt-bridge-fields
2022-09-02 10:43:23 +08:00
8b9494cf4b
fix(jwt): support non-integer timestamp claims
...
fix #8825
2022-09-02 10:17:47 +08:00
757cee0d8b
Merge pull request #8780 from HJianBo/authz-ignore-nomatch-rules
...
fix: exhook client.authorize never be execauted
2022-09-02 10:14:08 +08:00
275171d217
feat: handle lists of servers in mongo servers config
2022-09-01 14:47:14 -03:00
3d4afd65df
feat: add mongodb bridge (e5.0)
2022-09-01 14:47:14 -03:00
8a5a9ca2bf
Merge pull request #8854 from zmstone/0831-chore-merge-main-to-dev-ee50
...
0831 chore merge main to dev ee50
2022-09-01 11:35:23 +01:00
ee91128cef
chore: bump vsn
2022-09-01 15:05:18 +08:00
33c9c7d497
fix: incorrect message order when batch is enabled
2022-09-01 14:51:13 +08:00
dda0b4ac8c
chore: update emqtt vsn
2022-09-01 12:35:37 +08:00
c1afb34a86
test: fix failed tests
2022-09-01 11:34:31 +08:00
b54ebacd3e
Merge pull request #8852 from zhongwencool/return-503-when-router-not-ready
...
fix: return 503 if dashboard's routers not ready
2022-09-01 10:23:58 +08:00
13c0c79567
chore: bump up emqx_dashboard
2022-09-01 09:39:15 +08:00
a5ac5b6f3a
Merge branch 'dev/ee5.0' into refactor-mqtt-bridge
2022-09-01 09:30:37 +08:00
7bb592a2e1
fix: default override_to is cluster
2022-09-01 09:25:23 +08:00
dac178cbaf
chore: ensure version bumps
2022-08-31 17:23:47 +02:00
5a3fb4a011
Merge remote-tracking branch 'origin/master' into dev/ee5.0
2022-08-31 17:11:15 +02:00
05bbadc8c5
chore: bump ahutz version && update CHANGES-5.0.md
2022-08-31 21:15:55 +08:00
63a6cd15c1
test: add emqx_access_control:authorize case for exhook
2022-08-31 21:14:40 +08:00
0ef0b68de4
refactor: change '{recoverable_error,Reason}' to '{error,{recoverable_error,Reason}}'
2022-08-31 18:25:00 +08:00
71aaf5c538
fix(authz): fix dialyzer && test case && proper error
2022-08-31 16:49:27 +08:00
1cb281fbc4
fix: return 503 if dashboard's router not ready
2022-08-31 15:45:54 +08:00
5718b28eeb
feat: Deny hot updates to the configuration in local-override.conf
2022-08-31 14:55:10 +08:00
168f44e45b
fix: exhook client.authorize never be execauted
...
see: https://github.com/emqx/emqx/issues/8779
2022-08-31 14:34:02 +08:00
47648b3874
Merge pull request #8827 from lafirest/fix/sql_placeholder
...
fix(placeholder): allow placeholders in sql to be wrapped by quotes
2022-08-31 14:13:06 +08:00
ab927c785d
chore: bump emqx_plugin_libs version
2022-08-31 11:26:47 +08:00
e001892d04
fix(placeholder): add test case for placeholders wrapped by quotes
2022-08-31 11:22:07 +08:00
ba1f5eecd3
fix: update the swagger for new resource metrics
2022-08-31 11:14:36 +08:00
aeb5b2a2ff
fix(placeholder): allow placeholders in sql to be wrapped by quotes
2022-08-31 11:03:03 +08:00
1233d3c8df
fix(gateway): compatible with the old "/gateway" form API
2022-08-31 10:53:13 +08:00
14633eaac8
fix: please the elvis
2022-08-31 09:40:22 +08:00
bc12899ef8
fix(gateway): fix coap test case error
2022-08-31 09:27:37 +08:00
81a86e3202
fix(gateway): fix test case error
2022-08-31 09:27:37 +08:00
527ea23ec8
fix(gateway): change the `/gateway` API path to plural form
2022-08-31 09:27:37 +08:00
ca52b8eb29
fix: start connector-mqtt failed when username/password not provided
2022-08-31 09:18:10 +08:00
73e19d84ee
feat: use the new metrics to bridge APIs
2022-08-30 23:47:58 +08:00
9e50866cd0
fix: rename queue_max_bytes -> max_queue_bytes
2022-08-30 17:18:54 +08:00
0aac916c1a
Merge branch 'release-v5.0.7' into sync-changes-from-506
2022-08-30 15:30:41 +08:00
c4106c0d77
fix: resume the resource worker on health check success
2022-08-30 12:28:43 +08:00
65dfa63324
fix: update the counters for data bridges
2022-08-30 12:28:01 +08:00
262e68f7d2
fix: return error when receive HTTP code other than 2xx
2022-08-30 10:16:02 +08:00
b5ad5233a1
fix(mqtt-bridge): username and password defaults to undefined
2022-08-30 10:14:56 +08:00
6fde37791c
refactor: new metrics for resources
2022-08-30 10:14:10 +08:00
a6eff81163
chore: update emqtt to 1.7.0-rc.1
2022-08-30 09:50:36 +08:00
0aa10702db
feat(bridge): support async mode resource options
2022-08-30 09:34:56 +08:00
ca7ad9cc15
chore: refactor mqtt connector
2022-08-30 09:34:56 +08:00
d74564a7f0
Merge pull request #8817 from zmstone/0822-fix-changelog
...
0822 fix changelog
2022-08-29 15:59:00 +01:00
7451351c42
fix: quic listener idle_timeout type err
2022-08-29 16:19:19 +02:00
b8003765f8
Merge pull request #8790 from lafirest/fix/exhook_log
...
fix(exhook): fix the error message of unknown hookpoint
2022-08-27 13:33:51 +08:00
2eb078ff3b
chore: bump changed app versions
2022-08-26 14:32:28 +02:00
ecb79716ad
Merge branch 'master' into merge-506-to-master
2022-08-26 17:40:26 +08:00
1625b8eaeb
fix(mysql_bridge): export the query_mode option to the APIs
2022-08-26 17:11:24 +08:00
6b0ccfbc43
refactor: rename the error return resource_down -> recoverable_error
2022-08-26 17:11:12 +08:00
611053b6ca
chore: bump exhook app version
2022-08-25 16:53:58 +08:00
a896aa8b27
fix: incorrect replayq dir for the emqx_resource
2022-08-25 16:06:18 +08:00
9327c0f51b
fix(mysql_bridge): export the query_mode option to the APIs
2022-08-25 11:38:50 +08:00
97856f2e42
fix: allow empty string as ciphers
2022-08-24 21:02:21 +02:00
9a5dda010e
docs: update CHNAGES-5.0.md
2022-08-24 21:02:21 +02:00
7851a3aefd
refactor(ssl): use 'available' for defaults
...
prior to this change, for TLS versions, 'default's are 'available's
there is no need for such an alias.
now we call available_versions with a specific tag:
tls, dtls, or all
2022-08-24 21:02:21 +02:00
8717535d32
refactor: populate ciphers list at runtime
...
Populating ciphers list when checking schema makes the
config file example and the schmea documents quite bloated
2022-08-24 21:02:21 +02:00
f75932e49f
chore: release e5.0.0-beta.2
2022-08-24 22:28:29 +08:00
9555401ce1
fix(exhook): fix the error message of unknown hookpoint
...
Now if there is an unknown hookpoint, the error message is actually `{unknown_hookpoint,{error,badarg}}`,
the hookpoint name information is lost
2022-08-24 17:13:17 +08:00
eb21a37145
Merge pull request #8785 from JimMoen/feat-influxdb-config
...
Remove influxdb connector config layer. See #8773
2022-08-24 10:56:26 +08:00
4ac6f12252
refactor: configs and APIs for mysql bridge
2022-08-24 10:08:03 +08:00
ca6533395c
feat: influxdb bridge structure fits new style
2022-08-24 09:59:22 +08:00
43c964c87e
fix(docs): ee bridge api docs generation
...
Use try catch. Because function was unexported before called.
2022-08-24 09:52:38 +08:00
86577365e4
fix: use gen_statem:cast/3 for async query
2022-08-23 22:41:45 +08:00
97b9d378a5
Merge tag 'v5.0.6' into merge-506-to-master
2022-08-23 09:08:55 +08:00
1ff53ee8a9
fix(authz): don't stop emqx_resource app in test cases
2022-08-23 08:57:12 +08:00
ff0c44b67d
refactor(emqx_management): Export transactions
2022-08-22 21:29:13 +02:00
5978e4c8be
refactor(sn_registry): Export transactions
2022-08-22 19:52:37 +02:00
5aceeff7b4
refactor(cm_registry): Export transactions
2022-08-22 19:52:37 +02:00
f323e3cb79
refactor(emqx_conf): Extract transactions
2022-08-22 19:52:37 +02:00
6f4d0e2ed5
refactor(retainer_mnesia): Export transactions
2022-08-22 19:52:37 +02:00
fa12c66ad9
refactor(psk): Export transactions
2022-08-22 19:52:37 +02:00
d906715e0a
refactor(telemetry): Export transactions
2022-08-22 19:52:37 +02:00
9449e3cb32
refactor(auth_mnesia): Export transaction funs
2022-08-22 19:52:37 +02:00
45352206a3
fix(auth): remove emqx_connector from testcases of authz/authn
2022-08-22 20:20:45 +08:00
55c18c0b5f
fix(bridges): update the test cases for new config structure
2022-08-22 18:24:59 +08:00
aea8c77b49
refactor: new config structure for mqtt bridge
2022-08-22 18:24:59 +08:00
4ad04b646f
Merge pull request #8759 from lafirest/feat/mysql_batch_query
...
feat(bridge): add `on_batch_query` on emqx_connector_mysql
2022-08-22 17:22:39 +08:00
46f743d16b
chore: bump emqx vsn
2022-08-22 14:37:16 +08:00
ad96bb551e
chore: update changes and release vsn
2022-08-22 12:30:42 +08:00
f0c2b53868
fix(bpapi): make bpapi static_checks happy
2022-08-22 10:51:44 +08:00
62ecf6f545
fix(resource): keep `auto_retry` in `disconnected` state
...
Automatic retries should be maintained even in `disconnected` state without any state transition.
2022-08-22 02:52:06 +08:00
7c4ea38c06
fix(resource): make some resource opts internal
...
Resource options `start_after_created` and `start_timeout` are internal opts.
Not provided to users anymore.
2022-08-22 02:22:57 +08:00
2648362c62
fix(bridge): password for bridge/db format as `password` for dashboard
2022-08-19 15:54:19 +08:00
06363e63d9
fix(influxdb): connector use a fallbacke `pool_size` for influxdb client
2022-08-19 15:54:19 +08:00
3874f14f8c
chore: rename bootstrap_user to bootstrap_users
2022-08-19 14:51:41 +08:00
d1c676a1c5
chore: bump vsn
2022-08-19 14:08:09 +08:00
8d8afd1688
feat(bridge): add `on_batch_query` on emqx_connector_mysql
2022-08-19 13:16:22 +08:00
7ffdd95aa3
chore: bind option support `:1883` style config
...
see: https://github.com/emqx/emqx/pull/8571
2022-08-19 11:12:17 +08:00
c89de81e19
refactor(bpapi): Export transactions
2022-08-18 12:27:13 +02:00
7292095951
test(router_helper): Refactoring
2022-08-18 12:27:13 +02:00
4fa06fcd63
refactor(exclusive_sub): Export transaction
2022-08-18 12:27:13 +02:00
b962a71da2
refactor(shared_sub): Export transactions
2022-08-18 12:20:42 +02:00
cd3aa476c6
refactor(router_helper): Export transactions
2022-08-18 12:20:42 +02:00
8ef1c2db26
refactor(banned): Export transactions
2022-08-18 12:20:42 +02:00
5c260dfbd0
refactor(alarm): Export transaction functions
2022-08-18 12:20:42 +02:00
cdde392d6e
refactor(emqx_trace): Extract transactions to DL module
2022-08-18 12:02:54 +02:00
3906819dda
Merge pull request #8753 from zhongwencool/swagger-tag-titlecase
...
chore: swagger tag titlecase
2022-08-18 11:46:04 +08:00
bfa6acd350
chore: bump emqx_modules to 5.0.3
2022-08-17 23:59:59 +08:00
49b95b0aa8
chore: improve swagger tags
2022-08-17 23:32:19 +08:00
b8a7ab9ad3
fix(connector_psql): Wrap password in a fun
2022-08-17 14:31:12 +02:00
050f68cf5d
test: allow missing schema for app in tests
2022-08-17 08:33:17 +02:00
256cdd50ff
chore: delete unused schema module
2022-08-17 08:33:15 +02:00
f0436a2bd6
chore: bump ekka -> `0.13.4`
...
ZSTD fix for RocksDB.
https://github.com/emqx/mnesia_rocksdb/pull/6
2022-08-16 09:48:32 -03:00
66f06c3ab7
fix(dashboard): change `bootstrap_user` to `bootstrap_user_file`
2022-08-16 14:15:10 +08:00
9050aa6468
Merge pull request #8731 from emqx/copy-of-master
...
merge master into ee5.0
2022-08-16 10:49:10 +08:00
9e35032d78
fix: make resume_interval defaults to health_check_interval
2022-08-16 10:09:02 +08:00
de3a325953
fix: revert the changes in connector mysql
2022-08-16 09:06:13 +08:00
84a8f8b218
Merge branch 'dev/ee5.0' into copy-of-master
2022-08-15 21:46:42 +08:00
2898966439
Merge branch 'dev/ee5.0' into resource_opts
2022-08-15 21:43:22 +08:00
19d85d485b
refactor(resource): add resource_opts level into config structure
2022-08-15 21:40:10 +08:00
48a761c406
fix(mgmt): fix `$queue` topic name error in this API return
2022-08-15 17:26:25 +08:00
d1de262f31
fix: inc 'actions.failed' if bridge query failed
2022-08-15 17:21:14 +08:00
665ef4142d
fix: unify the health check interval
2022-08-15 17:21:14 +08:00
fba3ed6a12
Merge pull request #8721 from lafirest/fix/clients_api
...
fix(mgmt): remove the `will_msg` field from the client API
2022-08-15 15:31:56 +08:00
ecbf867551
refactor: rename Field to Struct for ref type create function
...
Hocon type reference is actually a child-struct's struct name
not necessarily the same name as the parent-sutrct's field name
This commit changes the variable name for more clarity
2022-08-15 09:17:44 +02:00
68946f1f6c
feat: influxdb support `async`/`batch_async` query
2022-08-15 14:02:17 +08:00
b01ae8ece6
chore: refine influxdb bridge/connector i18n
2022-08-15 14:00:14 +08:00
dfa63ff3b1
fix(mgmt): remove the `will_msg` field from the client API
2022-08-15 10:22:18 +08:00
b3162fe5ff
fix: conflicts between master and ee5.0
2022-08-14 22:24:09 +08:00
18d710e932
chore: release v5.0.5-beta.1
2022-08-12 18:37:27 +08:00
4318159b85
Merge pull request #8673 from qzhuyan/dev/william/quic-listener-config-timeouts
...
feat(quic): more listener options
2022-08-12 18:30:53 +08:00
fc6d79c2da
fix: typos in emqx_schema_i18n.conf
2022-08-12 18:30:34 +08:00
594d071c05
feat(influxdb): add async callback
2022-08-12 18:26:47 +08:00
43ed926d67
Merge pull request #8707 from lafirest/fix/bootstrap_user
...
fix(dashboard): add bootstrap user tag && return error when adding bo…
2022-08-12 18:18:57 +08:00
3cb79e811f
fix: remove the extra fields max_retries
2022-08-12 18:05:03 +08:00
dc7953c3e1
chore: refine async query variable name
2022-08-12 17:28:56 +08:00
d4bf658e38
fix(dashboard): add bootstrap user tag && return error when adding bootstrap user fails
2022-08-12 16:40:36 +08:00
fa5e8f1422
chore: refine i18n label
2022-08-12 16:39:03 +08:00
3678673124
fix: schema default value using raw type before convert
2022-08-12 16:38:46 +08:00
00966df18f
Merge pull request #8704 from terry-xiaoyu/webhook_async_conf
...
feat: add more resource creation opts
2022-08-12 14:18:50 +08:00
0cdf4b47f1
feat: add more resource creation opts
2022-08-12 13:47:45 +08:00
8b0da83a31
Merge pull request #8701 from HJianBo/fix-gw-test
...
test(gw): fix gateway flaky tests
2022-08-12 11:21:56 +08:00
c7f6517aee
Merge pull request #8667 from lafirest/feat/bootstrap_user
...
feat(dashboard): add bootstrap files to initialize user accounts
2022-08-12 10:43:42 +08:00
907d9a166a
test(gw): fix gateway flaky tests
2022-08-12 10:20:15 +08:00
404e79b7d7
Merge pull request #8687 from lafirest/fix/bridge_mysql
...
fix(bridge): replace prepare_statement by sql_template
2022-08-12 10:12:34 +08:00
449239d0f4
fix: count all msg size of `event_message` for mqtt bridge
2022-08-12 01:29:56 +08:00
bed10b097f
chore: release e5.0.0-beta.1
2022-08-12 00:27:13 +08:00
c3c4ed02b4
fix: bump emqx_dashboard to 5.0.4
2022-08-12 00:24:58 +08:00
a05cc20db7
Merge pull request #8693 from JimMoen/feat-influxdb-batch-query
...
Feat influxdb batch query
2022-08-12 00:22:23 +08:00
83746daad5
fix: update bridge config badmap error
2022-08-11 23:15:53 +08:00
458dab53c5
fix: undefined_functions dialyzer warning
2022-08-11 22:55:22 +08:00
ed796acb95
fix: fetch resource options after reboot
2022-08-11 22:11:28 +08:00
88388b0c54
feat: http connector support async sending
2022-08-11 21:44:22 +08:00
3a76a50382
fix: syntax error and compile error
2022-08-11 20:58:43 +08:00
2872f0b668
fix(bridges): support create resources with options
2022-08-11 19:11:44 +08:00
0f6c371760
feat(influxdb): influxdb connector add `on_batch_query/3` callback
2022-08-11 18:12:41 +08:00
d55c9341eb
fix(dashboard): fix nit codes
2022-08-11 17:42:22 +08:00
22a4ca311c
feat(resource): resource batch/async/queue config schema
2022-08-11 16:59:18 +08:00
7581082fcb
fix(bridge): replace prepare_statement by sql_template
2022-08-11 13:22:16 +08:00
223b84017e
fix(influxdb): api schema `write_syntax` using raw type `string()`
2022-08-11 11:36:08 +08:00
03b004e0ce
Merge pull request #8685 from terry-xiaoyu/resource_inflight_window
...
feat: add inflight window to emqx_resource
2022-08-11 09:22:52 +08:00
6203a01320
feat: add inflight window to emqx_resource
2022-08-11 08:36:35 +08:00
64aa30ec63
chore(authn/authz): better handling of placeholder interpolation errors
2022-08-10 18:22:37 +03:00
7ca8550a5d
feat(quic): more listener options
2022-08-10 12:37:12 +02:00
07933e3638
feat: translate map to object in schema.json
2022-08-10 17:45:34 +08:00
4994731d3e
chore: update emqx_connector app vsn
2022-08-10 09:50:12 +02:00
18614ad291
fix(connector): add back deleted fields as deprecated
...
max_retries and retry_interval were removed from 5.0.4 wihtout
backward compatibliity.
This commit adds the fields back as deprecated
2022-08-10 09:50:12 +02:00
f7016e53a4
chore: delete hocon from emqx_prometheus application deps
2022-08-09 20:19:31 +02:00
82550a585a
fix: add test cases for query async
2022-08-10 00:45:34 +08:00
efd6c56dd9
fix: test cases for batch query sync
2022-08-10 00:45:34 +08:00
145ff66a9a
fix: issues found by dialyzer and elvis
2022-08-10 00:45:26 +08:00
35fe70b887
feat: support aysnc callback to connector modules
2022-08-10 00:34:35 +08:00
f1419d52f1
fix(resource): remove resource at the end of each test
2022-08-10 00:34:35 +08:00
a2afdeeb48
feat: add test cases for batching query
2022-08-10 00:34:35 +08:00
8f0954837b
fix: update test cases for emqx_connector
2022-08-10 00:34:35 +08:00
75adba0781
fix: increase resource metrics using the resource id
2022-08-10 00:34:35 +08:00
d3950b9534
fix(resource): make option 'queue_enabled' disabled by default
2022-08-10 00:34:35 +08:00
0377d3cf61
fix: update existing testcases for new emqx_resource
2022-08-10 00:34:35 +08:00
2fb42e4d37
refactor: create emqx_resource_worker_sup for resource workers
2022-08-10 00:34:35 +08:00
0087b7c960
fix: remove the extra file replay.erl
2022-08-10 00:34:35 +08:00
d8d8d674e4
feat(resource): start emqx_resource_worker in pools
2022-08-10 00:34:35 +08:00
12904d797f
feat(resource): first commit for batching/async/caching mechanism
2022-08-10 00:34:35 +08:00
6d5ad97528
Merge pull request #8670 from zmstone/0809-5.0-improve-lwm2m-logging
...
fix(lwm2m): better logging for unknown object IDs
2022-08-09 16:24:20 +01:00
dd8bcd80cb
chore: bump app vsn for emqx_gateway to 0.1.3
2022-08-09 13:30:09 +02:00
30f24131e2
Merge pull request #8650 from qzhuyan/fix/william/keep-alive-check
...
fix: keep alive check
2022-08-09 11:37:12 +02:00
13f5c0b6b1
fix(lwm2m): better logging for unknown object IDs
...
Prior to this change, unknown object IDs would result in a tuple
{error, no_xml_definition}, and this tuple is passed down to xmerl
lib to get XML node data and eventually crash with function_clause.
With this fix, the unknown object ID exception is caught and logged
properly.
2022-08-09 11:26:12 +02:00
699489297b
Merge pull request #8462 from fridayy/feat_round_robin_per_node
...
feat(shared-sub): add round_robin_per_group strategy
2022-08-09 10:03:52 +01:00
463d255c0a
fix(dashboard): make dialyzer happy
2022-08-09 16:36:46 +08:00
0f8ebbdf0f
feat(dashboard): add bootstrap files to initialize user accounts
2022-08-09 16:02:50 +08:00
dee92bb8b8
fix(mgmt): fix status api test case error
2022-08-09 11:22:48 +08:00
01ba45cc37
fix(mgmt): remove the `/api/v5` prefix of status API
2022-08-08 17:34:18 +08:00
2e336fbc01
fix: bridge and connector namespace contains DB name
...
Contains Detailed DB name for identifier hocon schema refs.
2022-08-07 19:37:44 +08:00
70cb7768b0
Merge branch 'emqx:master' into feat_round_robin_per_node
2022-08-05 11:12:23 +02:00
71f31ab5cd
feat(shared-sub): add round_robin_per_group strategy
...
remove flaky tests that provide little value
2022-08-05 11:10:54 +02:00
e9d7cde0b4
Merge pull request #8638 from thalesmg/license-http-api-50-upload
...
chore(license): treat license file API as an upload (5.0)
2022-08-04 16:27:55 -03:00
5bd2875db8
Merge pull request #8637 from thalesmg/esockd-tls-gc
...
feat: add option to gc after TLS/SSL handshake
2022-08-04 14:18:45 -03:00
d2e146aeff
test: fix flaky gateway tests
2022-08-04 13:16:17 -03:00
5fa2a2aa44
Merge branch 'emqx:master' into feat_round_robin_per_node
2022-08-04 11:02:51 +02:00
dec892e867
feat(shared-sub): add round_robin_per_group strategy
...
add round robin per group strategy that balances load in a more predictable fashion when using no replication
2022-08-04 10:40:50 +02:00
aa6077bdea
fix(bridge): remove emqx_ee_connector_mysql
2022-08-04 14:52:16 +08:00
01b9115fd8
fix: keep alive check
...
According to MQTT spec, MQTT Server should check a complete MQTT message
recv in last keep-alive time frame instead of number of received bytes
from the socket.
This commit change to check the recv pkt counter from process dict
instead.
Also it could save some calls to erlang port.
2022-08-03 17:14:19 +02:00
7f932d64be
docs: adjust descriptions
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2022-08-03 09:38:51 -03:00
19e101445c
feat: add option to gc after TLS/SSL handshake
2022-08-03 09:38:51 -03:00
8e062df809
Merge pull request #8642 from zhongwencool/fix-node-status
...
chore: update Running/Stopped to running/stopped
2022-08-03 16:32:01 +08:00
11165f4a9c
Merge pull request #8626 from lafirest/fix/connect_event_5
...
fix(channel): Adjust the timing of the `client.connected` event
2022-08-03 16:01:17 +08:00
fd7c97735d
chore: make sure path is binary
2022-08-03 12:58:20 +08:00
a19514f000
chore: bump emqx_management to 5.0.3
2022-08-03 12:34:30 +08:00
4869225395
chore: update Running/Stopped to running/stopped
2022-08-03 12:24:03 +08:00
c6f879e03b
Merge pull request #8634 from zhongwencool/improve-swagger-router-generate
...
fix: return 503 instead of crash when dashboard generate router timeout
2022-08-03 10:46:59 +08:00
8e53a61791
fix: return 503 instead of crash when dashboard generate router timeout
2022-08-02 19:49:06 +08:00
cffaf95d00
chore: update apps/emqx/src/emqx_channel.erl
2022-08-02 17:20:58 +08:00
4a1ede7e7e
test: fix flaky gateway tests
2022-08-01 10:57:34 -03:00
a78760dbac
chore: bump app vsns
2022-08-01 10:57:34 -03:00
78deee6846
fix(channel): Adjust the timing of the `client.connected` event
2022-08-01 17:35:48 +08:00
14920743ca
Merge pull request #8513 from lafirest/fix/limiter_interface
...
refactor(limiter): refactor the user interface
2022-08-01 11:02:15 +08:00
55b9684541
fix: influxdb bridge api available
2022-08-01 10:28:07 +08:00
01e9e8a0eb
feat: add ee influxdb connector & bridge
2022-08-01 10:27:35 +08:00
3fe76446bc
Merge branch 'master' into dev/ee5.0
2022-08-01 10:14:21 +08:00
a9b176b8bd
Merge pull request #8598 from thalesmg/license-fixes-50
...
license fixes (5.0)
2022-07-29 13:13:51 -03:00
be679f8128
Merge pull request #8589 from emqx/release-v5.0.4
...
Merge v5.0.4 into master branch
2022-07-29 08:49:10 +08:00
8e08f045aa
chore(bpapi): add new vsn
2022-07-28 17:59:54 -03:00
f8a1bd0715
feat(license): copy license file to cluster when updating it
2022-07-28 17:29:59 -03:00
a4992ef1b5
fix: hstreamdb connector conf & api
2022-07-28 16:47:30 +08:00
5835120d8e
chore: relealse v5.0.4
2022-07-28 13:47:41 +08:00
527289090d
Merge pull request #8580 from terry-xiaoyu/webhook_max_retries
...
fix(webhook): the 'max_retries' opt means request retry times
2022-07-27 17:42:33 +08:00
23eeb21b13
fix(webhook): the 'max_retries' opt means request retry times
2022-07-27 17:06:14 +08:00
9ae7c62656
fix: exs deps & bad suites
2022-07-27 16:24:13 +08:00
9323878442
chore: bump vsn
2022-07-27 16:23:54 +08:00
be6de4aad0
fix: ee bridge & connector remove app mod
2022-07-27 11:38:45 +08:00
fa4bc921ac
fix: hstream db connector & bridge, TODO: SUITE
2022-07-27 11:38:45 +08:00
98b36c4681
fix: hstream db connector , TODO: start apps
2022-07-27 11:38:45 +08:00
f00a7417bb
feat: hstream bridge & connector
2022-07-27 11:38:45 +08:00
b4be9b6fae
chore: bump ekka -> 0.13.3
...
Mainly: https://github.com/emqx/erlang-rocksdb/pull/7
2022-07-26 09:50:14 -03:00
257e310931
chore: ensure the `bind` output style
...
e.g:
- Configured as `1883`, printed as `:1883`
- Configured as `0.0.0.0:1883`, printed as `:1883`
- Configured as `127.0.0.1:1883`, printed as `127.0.0.1:1883`
- Configured as `::1:1883`, printed as `[::1]:1883`
- Configured as `[::1]:1883`, printed as `[::1]:1883`
2022-07-26 19:02:04 +08:00
bc716884e0
fix(limiter): fix spellcheck error
2022-07-26 15:16:53 +08:00
bcc78950a9
fix(limiter): fix schema error
2022-07-26 14:33:04 +08:00
38b5882dc8
test(gw): using ip_port in listener tests
2022-07-26 11:40:52 +08:00
53fda85c93
fix: conflicts resolving legacy
2022-07-26 11:10:40 +08:00
bad82b29ce
feat(gw): change the listeners api fields
2022-07-26 11:05:04 +08:00
2c71d27a89
feat(listeners): change the `GET /listeners` api fields
2022-07-26 11:04:33 +08:00
79d6613a18
Merge pull request #8531 from HJianBo/fix-authn-cndn
...
fix(authn): fix cert_subject and cert_common_name placeholder
2022-07-26 09:09:34 +08:00
bc93d5f525
Merge pull request #8567 from emqx/EMQX-6018-v-5-0-4-cli-command-to-verify-config-syntax-against-schema
...
feat: Added emqx command to check configs
2022-07-25 17:14:42 +02:00
2f470b8878
Merge pull request #8554 from savonarola/authn-logging
...
Add more tracing for authentication
2022-07-25 17:43:00 +03:00
1a236db91b
chore(log): add authentication tracing
2022-07-25 17:14:19 +03:00
80831a7593
Merge pull request #8563 from zhongwencool/titlecase-swagger-tags
...
chore: make sure swagger's tags always titlecase
2022-07-25 17:45:54 +08:00
2466881460
chore: Update apps/emqx_authn/src/emqx_authn_user_import_api.erl
...
Co-authored-by: zhouzb <zhouzb@emqx.io>
2022-07-25 17:45:38 +08:00
Shawn