402ab7e759
chore: remove unnecessary repeated code
...
Co-authored-by: Zaiming (Stone) Shi <zmstone@gmail.com>
2022-05-18 07:21:16 +02:00
05032467bd
feat(rule_engine): default timeout for jq/2 and jq/3 with timeout
...
This commit adds a default timeout of 10 seconds to the rule engine's
`jq/2` function, and adds a new function `jq/3` (where the last parameter is
a timeout value). The default timeout can be configured with the setting
"rule_engine.jq_function_default_timeout".
Having a timeout when executing jq code in the rule engine is important
as jq code can potentially run forever. Also, the Erlang jq library
limits the number of jq programs that can execute concurrently so a jq
program that loops forever could potentially also prevent a "non-buggy"
jq program from ever starting.
2022-05-17 19:36:32 +02:00
c98fd04f8f
fix: rename the rule metrics
2022-05-17 17:17:07 +08:00
d8ec51a0c2
feat(rule-engine): add proto_name/proto_ver for $event/client_disconnected event
2022-05-16 15:12:41 +08:00
8b0adf69d2
Merge pull request #7926 from DDDHuang/rule_api_errormsg
...
fix: better error message for rule engine
2022-05-12 19:07:47 +08:00
2de69c97ba
fix: ruleengine & connector & bridge api, better error message
2022-05-12 16:51:36 +08:00
a284ab9cf8
fix: better error message for rule engine
2022-05-12 11:06:07 +08:00
47ed9cbc76
fix(telemetry): count bridges referenced in `from` rule clauses
2022-05-11 15:15:17 -03:00
82da4d82be
chore: update jq to v0.2.0
2022-05-06 22:20:35 +08:00
685b06eeed
fix: avoid 'rule_test' api crash
2022-05-05 17:28:59 +08:00
74c33cd4e5
feat(rule_engine): add jq function to the rule engine
...
This commit adds a function to the rule engine that alows users
to transform text or JSON objects using [jq filter programs][1].
[jq][1] is a command line tool that can be used to transform
and filter JSON text using jq's built-in language. The rule engine
function that is added with this commit uses the
[Erlang jq NIF library][2] that wraps the jq C library in an
Erlang NIF function.
[1]: https://stedolan.github.io/jq/
[2]: https://github.com/emqx/jq
2022-05-04 17:09:16 +02:00
6b44d96c0d
refactor: rename functions to please elvis
2022-04-29 10:52:08 +02:00
4e65322667
refactor: move emqx_plugin_libs_metrics to emqx app
...
because it can not depend on other apps
2022-04-29 12:41:36 +08:00
02c3f87b31
style: reformat all remaining apps
2022-04-27 15:51:18 +02:00
46e993fa81
Merge pull request #7786 from terry-xiaoyu/save_tls_files_for_bridges
...
Save tls files for bridges
2022-04-27 21:48:18 +08:00
ba800d853d
fix(rule): republish all available fields if payload template empty
2022-04-27 11:59:15 +08:00
1fac70d2bb
fix: remove error field
2022-04-27 09:48:57 +08:00
cef16ac382
fix: improve document quality
2022-04-21 15:05:56 +08:00
51972af472
feat: add chinese to rule engine description
2022-04-20 10:23:56 +08:00
21fe7f01ee
Merge pull request #7624 from DDDHuang/fix_api_params
...
Fix api params
2022-04-18 09:33:22 +08:00
ea6b3c7b51
fix: format code
2022-04-16 16:37:10 +08:00
82ce6ae9f9
fix: bad integer, bad qos; TODO: gateway api * 2
2022-04-16 16:37:10 +08:00
e4b62f3a5f
feat: add rule-engine functions
2022-04-15 18:02:24 +08:00
ee6ac90d47
fix: behavior of rule-engine when selection field does not exist
2022-04-13 18:19:42 +08:00
21dfd5dd47
fix: export rule reset_metrics api
2022-04-11 15:21:14 +08:00
f91c0e140d
fix: fix static_checks error
2022-04-11 10:25:48 +08:00
fa0c4d17ee
feat: impl rule_engine reset_metrics api
2022-04-11 10:25:48 +08:00
1aea6b3ea7
Merge pull request #7522 from thalesmg/telemetry-revamp-part5
...
feat: add basic rule engine and bridge usage info to telemetry
2022-04-07 10:19:55 -03:00
8354095e4b
feat(rules): export basic usage info for telemetry
2022-04-06 10:20:23 -03:00
a31891e8e6
feat: enhanced rule engine error handling when json parsing error
2022-04-06 09:56:55 +08:00
99b3f2f83e
docs(schema): Document missing records and fields
2022-04-04 23:58:43 +02:00
d23a88d0a9
docs(schema): Minor improvements to spelling and formatting.
2022-03-30 13:05:56 +02:00
ce450b7da7
docs(schema): Document the records
2022-03-30 11:53:53 +02:00
3b43cca5bf
fix: use masp:get/3 to avoid crash after match failure
2022-03-29 18:51:10 +08:00
ccc134d061
fix(emqx_rule_api_schema): add rule events schema
2022-03-29 14:03:15 +08:00
4791c64b73
feat: add rule event 'client.check_authz_complete'
2022-03-29 11:24:36 +08:00
65164fb046
feat: add rule event 'client.connack'
2022-03-28 11:32:07 +08:00
83e16a5bc5
Merge pull request #7343 from HJianBo/fix-gw-bugs
2022-03-22 17:49:02 +08:00
6cff53ad67
fix(rule): replace sql crlf with spaces
...
get around the hocon bug: error handling escape character \n
2022-03-21 19:26:06 +08:00
6da4592bb0
chore: fix elivs warnings
2022-03-21 18:52:41 +08:00
5682dcb72e
fix(gw): enrich conninfo for coap&lwm2m
2022-03-21 18:17:24 +08:00
edb1460b56
chore(rule-engine): more safe generate even_msg content
2022-03-21 18:17:24 +08:00
50ee6ad2e2
fix(rule): update rules without reset the metrics
2022-03-21 15:06:34 +08:00
93c5fa60b4
fix(rules): store rule configs to cluster config files
2022-03-16 00:39:01 +08:00
869dc1a081
fix(rules): ensure create_at unchanged after rule is updated
2022-03-16 00:38:42 +08:00
0b4b3a7cf0
fix(dialyzer): some bad type specs
2022-03-11 18:33:08 +08:00
590fa1b375
fix(rule): check request body for /rule_test crashes
2022-03-11 18:13:12 +08:00
f924b9389d
fix(rule): add swagger schema for events from bridge sources
2022-03-11 14:13:14 +08:00
5ca0d4f856
fix(rule): rename the eventname of bridge sources to $bridges/mqtt:*
2022-03-10 23:03:35 +08:00
3ca3470844
fix(rule_events): add descs for test columns
2022-03-10 22:49:29 +08:00
c673e55a47
fix(rule): add SQL test examples for user properties
...
Porting from v4.4
2022-03-10 16:01:30 +08:00
247b14c95f
fix(mqtt_bridge): refine the message format from a mqtt bridge source
2022-03-10 15:57:33 +08:00
db584f79d6
feat: upgrade hocon to 0.25.0 to replace nullable with required.
2022-02-24 22:39:03 +08:00
574bbafc9b
fix(schema): Ensure enum is atom or int.
2022-02-24 15:36:04 +08:00
5638bcb92b
docs: Fix typos
2022-02-17 23:22:31 +01:00
0528262705
chore(app.src): EMQ X -> EMQX in .app.src files
2022-02-16 17:51:45 +01:00
f5415589e9
chore(schema): use emqx_schema:qos() instead of union integer.
2022-02-11 10:09:59 +08:00
e6997dc1ce
Merge pull request #6942 from terry-xiaoyu/hook_delivery_drop
...
Hook delivery drop
2022-02-09 18:28:56 +08:00
b2f027bcf7
feat(rule): add 'delivery.dropped' hook for rules
2022-02-08 10:32:25 +08:00
261e9929b6
fix(rule): deny POST empty rule ids
2022-02-08 09:57:44 +08:00
f7703c906e
refactor: move plain_check impl to emqx_hocon
2022-01-29 10:16:55 +01:00
052bd9081d
docs(schema): Fix typos in the schema files
2022-01-27 22:39:19 +01:00
d6f7ffec3c
Merge pull request #6881 from zmstone/refactor-upgrade-hocon-0.23.0
...
refactor: upgrade to hocon 0.23.0
2022-01-27 15:48:23 +01:00
fc92e4c8bf
docs: fix typos
2022-01-27 12:29:38 +01:00
252d7e85d9
refactor: call new hocon apis
2022-01-27 00:23:08 +01:00
6e3b05d665
refactor(emqx_plugin): Decorate RPCs
2022-01-18 15:25:34 +01:00
8cee9a9e47
fix(rule): compare to null variables should return false
2022-01-17 14:17:49 +08:00
2a2a00e0ad
fix(rule): remove rules from all nodes in the cluster
2022-01-11 14:44:08 +08:00
72d55c8c0d
fix(rules): improve the names of the metrics
2022-01-07 09:35:00 +08:00
67a60e1153
refactor(rule): add more metrics for rule and bridges
2022-01-07 09:34:54 +08:00
63167cea70
chore: update copyright
2022-01-05 20:55:00 +01:00
657ecef67b
fix(resource): don't crash on resource stopped
2021-12-31 20:57:34 +08:00
e299d8d138
fix(rule): rules not triggered after the ingress mqtt bridge received some msg
2021-12-31 15:47:03 +08:00
94a5965560
fix(rule): dead lock when update configs for rules
2021-12-31 00:03:03 +08:00
a42ab3d9da
fix(rule): use emqx_conf:update/3 to make changes to all nodes
2021-12-31 00:03:03 +08:00
4b6bba11eb
feat(trace): struct log for trace
2021-12-29 00:26:54 +08:00
668180388c
feat(trace): replace logger_formatter by emqx_trace_formatter
2021-12-27 14:40:40 +08:00
cd4227b851
fix(rules): don't show the module name 'emqx_rule_outputs' in outputs
2021-12-22 10:26:22 +08:00
9b4b3d2e8c
fix(rules): make the 'name' field of POST /rules mandatory
2021-12-22 10:26:22 +08:00
5f050b149b
fix(rules): the schema for unsubscribe is messing from rule_test API
2021-12-22 10:26:22 +08:00
a9c9d9d805
fix(rule): rename enabled to enable
2021-12-18 20:28:14 +08:00
a44e18e869
fix(bridge): filter out some extra fields from the request body
2021-12-18 19:19:58 +08:00
494c08f849
refactor(rule): add name field to request body of POST /rules
2021-12-18 06:34:44 +08:00
fcb7c2c70f
docs: change <module> to {module} so markdown render will not crash
...
<module> is treated as an HTML tag
2021-12-12 19:34:29 +01:00
416b9f8d7c
refactor(rule): generate swagger from hocon schema for /rules
2021-12-07 09:48:47 +08:00
24bded99d5
refactor(metrics): rename speed to rate in emqx_plugin_libs_metrics
2021-12-07 09:47:53 +08:00
e07fce791f
feat(connector): add examples to the swagger doc
2021-12-07 09:47:53 +08:00
d9a980c7e1
docs: fix config doc, avoid using <text> in doc body
2021-12-06 08:00:42 +01:00
4c149f92c1
feat(bridge): support metrics for bridges
2021-11-23 09:36:10 +08:00
a0e81226d7
fix(elvis): improve some code format
2021-11-22 19:10:00 +08:00
9c93ea0338
feat(connector): add API for /connectors_test
2021-11-22 17:35:33 +08:00
7d64013edd
refactor(connector): add connector configs
2021-11-22 17:35:32 +08:00
6edd862dd5
refactor: no more EMQX_ENTERPRISE compile flag
...
The compile flag was introduced in EQM X 4.3 series
where CE and EE code was diverged large enough which made
non-practicle to determin edition at runtime.
such approach made testing quite challenging as we'll have to
build with different compile flags inorder to run per-edition
test cases
In this commit, we try to retrieve edition info from EMQX's
description text, (put to PT for fast access) at runtime
so we can test ALL editions from a super-set edition (EE).
2021-11-20 20:41:06 +01:00
b3f9220d02
style: make elvis happy
2021-11-15 16:30:44 +08:00
106aa559e0
fix(api): DELETE success wrongly returned code 200
2021-11-15 16:30:44 +08:00
d1abb30818
ci: fix elvis check
2021-11-04 15:27:10 +01:00
56e2a9741f
style: ensure newline at EOF for all files
2021-11-04 14:40:14 +01:00
d784e63b9f
emqx_conf ( #5939 )
...
* feat(emqx_conf): move conf manager for emqx_machine to emqx_conf
* chore(emqx_conf): change emqx:get_config/2 to emqx_conf:get/2
* fix: common test failed
* fix: badmatch by typo wrong key
* fix(emqx_conf): get the wrong core nodes
* fix(emqx_conf): get core node's tnx_id not latest tnx_id
* fix: add ro_transation when copy conf file
* fix: delete debug info
* fix: change ekka_rlog to mria_rlog
* fix: remove cluster_rpc from emqx_machine.
* fix: don't call ekka:start/0 explicitly
* fix: ekka should be start in emqx_machine
2021-10-21 18:08:51 +08:00
ff48322e0c
chore(mria): ekka_mnesia:running_nodes -> mria:running_nodes
2021-10-18 22:04:05 +02:00
2e52ab9712
fix(rules): improve some code for emqx_rule_engine
2021-10-14 15:09:37 +08:00
Kjell Winblad