diff --git a/apps/emqx_message_transformation/BSL.txt b/apps/emqx_message_transformation/BSL.txt index 127b85777..023786aa5 100644 --- a/apps/emqx_message_transformation/BSL.txt +++ b/apps/emqx_message_transformation/BSL.txt @@ -2,7 +2,7 @@ Business Source License 1.1 Licensor: Hangzhou EMQ Technologies Co., Ltd. Licensed Work: EMQX Enterprise Edition - The Licensed Work is (c) 2023 + The Licensed Work is (c) 2024 Hangzhou EMQ Technologies Co., Ltd. Additional Use Grant: Students and educators are granted right to copy, modify, and create derivative work for research diff --git a/apps/emqx_message_transformation/src/emqx_message_transformation.erl b/apps/emqx_message_transformation/src/emqx_message_transformation.erl index 4baa0b00d..d0c314553 100644 --- a/apps/emqx_message_transformation/src/emqx_message_transformation.erl +++ b/apps/emqx_message_transformation/src/emqx_message_transformation.erl @@ -49,9 +49,9 @@ -define(TRANSFORMATIONS_CONF_PATH, [?CONF_ROOT, transformations]). -type transformation_name() :: binary(). -%% TODO +%% TODO: make more specific typespec -type transformation() :: #{atom() => term()}. -%% TODO +%% TODO: make more specific typespec -type variform() :: any(). -type operation() :: #{key := [binary(), ...], value := variform()}. -type qos() :: 0..2. @@ -174,7 +174,6 @@ on_message_publish(Message = #message{topic = Topic, headers = Headers}) -> Transformations -> case run_transformations(Transformations, Message) of #message{} = FinalMessage -> - %% FIXME: must ensure final payload is a binary!! Check this. emqx_metrics:inc('messages.transformation_succeeded'), {ok, FinalMessage}; drop -> diff --git a/apps/emqx_schema_validation/BSL.txt b/apps/emqx_schema_validation/BSL.txt index f0cd31c6f..c770ed9a2 100644 --- a/apps/emqx_schema_validation/BSL.txt +++ b/apps/emqx_schema_validation/BSL.txt @@ -2,7 +2,7 @@ Business Source License 1.1 Licensor: Hangzhou EMQ Technologies Co., Ltd. Licensed Work: EMQX Enterprise Edition - The Licensed Work is (c) 2023 + The Licensed Work is (c) 2024 Hangzhou EMQ Technologies Co., Ltd. Additional Use Grant: Students and educators are granted right to copy, modify, and create derivative work for research