From 25be9c2890074eb835a727043a1522c7f4ee77a1 Mon Sep 17 00:00:00 2001 From: JimMoen Date: Wed, 8 May 2024 14:18:28 +0800 Subject: [PATCH] fix(plugin): use binary `NameVsn` to re-build plugin avsc serde --- apps/emqx_plugins/src/emqx_plugins_serde.erl | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/apps/emqx_plugins/src/emqx_plugins_serde.erl b/apps/emqx_plugins/src/emqx_plugins_serde.erl index ec54a40fc..b50258b9c 100644 --- a/apps/emqx_plugins/src/emqx_plugins_serde.erl +++ b/apps/emqx_plugins/src/emqx_plugins_serde.erl @@ -157,7 +157,7 @@ get_plugin_avscs() -> lists:foldl( fun(AvscPath, AccIn) -> [_, NameVsn | _] = lists:reverse(filename:split(AvscPath)), - [{NameVsn, AvscPath} | AccIn] + [{to_bin(NameVsn), AvscPath} | AccIn] end, _Acc0 = [], filelib:wildcard(Pattern) @@ -186,6 +186,8 @@ do_build_serde({NameVsn, AvscPath}) -> {error, Error} end. +make_serde(NameVsn, AvscPath) when not is_binary(NameVsn) -> + make_serde(to_bin(NameVsn), AvscPath); make_serde(NameVsn, AvscPath) -> {ok, AvscBin} = read_avsc_file(AvscPath), Store0 = avro_schema_store:new([map]),