From 373532f9e4944371751f5b057ca86e429caa33a5 Mon Sep 17 00:00:00 2001 From: JianBo He Date: Thu, 15 Apr 2021 20:09:01 +0800 Subject: [PATCH] fix(exhook): fix the match pattern --- apps/emqx_exhook/src/emqx_exhook_handler.erl | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/apps/emqx_exhook/src/emqx_exhook_handler.erl b/apps/emqx_exhook/src/emqx_exhook_handler.erl index e2044237c..3ef631da9 100644 --- a/apps/emqx_exhook/src/emqx_exhook_handler.erl +++ b/apps/emqx_exhook/src/emqx_exhook_handler.erl @@ -293,6 +293,8 @@ stringfy(Term) -> %% Acc funcs %% see exhook.proto +merge_responsed_bool(_Req, #{type := 'IGNORE'}) -> + ignore; merge_responsed_bool(Req, #{type := Type, value := {bool_result, NewBool}}) when is_boolean(NewBool) -> NReq = Req#{result => NewBool}, @@ -300,20 +302,18 @@ merge_responsed_bool(Req, #{type := Type, value := {bool_result, NewBool}}) 'CONTINUE' -> {ok, NReq}; 'STOP_AND_RETURN' -> {stop, NReq} end; -merge_responsed_bool(_Req, #{type := 'IGNORE'}) -> - ignore; merge_responsed_bool(_Req, Resp) -> ?LOG(warning, "Unknown responsed value ~0p to merge to callback chain", [Resp]), ignore. +merge_responsed_message(_Req, #{type := 'IGNORE'}) -> + ignore; merge_responsed_message(Req, #{type := Type, value := {message, NMessage}}) -> NReq = Req#{message => NMessage}, case Type of 'CONTINUE' -> {ok, NReq}; 'STOP_AND_RETURN' -> {stop, NReq} end; -merge_responsed_message(_Req, #{type := 'IGNORE'}) -> - ignore; merge_responsed_message(_Req, Resp) -> ?LOG(warning, "Unknown responsed value ~0p to merge to callback chain", [Resp]), ignore.