From 9bb3533d112f1ed05474146e03844916a135986c Mon Sep 17 00:00:00 2001
From: JianBo He <heeejianbo@gmail.com>
Date: Fri, 24 Jun 2022 14:13:27 +0800
Subject: [PATCH 1/3] fix(exhook): guarantee sequential dispatch of client's
 events from the same node

fix: https://github.com/emqx/emqx/issues/7569
---
 apps/emqx_exhook/src/emqx_exhook.appup.src  |  6 ++++--
 apps/emqx_exhook/src/emqx_exhook_server.erl | 12 +++++++++++-
 rebar.config                                |  2 +-
 3 files changed, 16 insertions(+), 4 deletions(-)

diff --git a/apps/emqx_exhook/src/emqx_exhook.appup.src b/apps/emqx_exhook/src/emqx_exhook.appup.src
index d3b73d98a..f286255f0 100644
--- a/apps/emqx_exhook/src/emqx_exhook.appup.src
+++ b/apps/emqx_exhook/src/emqx_exhook.appup.src
@@ -1,6 +1,7 @@
 %% -*- mode: erlang -*-
 {VSN,
- [  {"4.3.5", [
+ [
+    {"4.3.5", [
         {load_module, emqx_exhook_server, brutal_purge, soft_purge, []}
     ]},
     {"4.3.4", [
@@ -16,7 +17,8 @@
     ]},
     {<<".*">>, []}
  ],
- [  {"4.3.5", [
+ [
+    {"4.3.5", [
         {load_module, emqx_exhook_server, brutal_purge, soft_purge, []}
     ]},
     {"4.3.4", [
diff --git a/apps/emqx_exhook/src/emqx_exhook_server.erl b/apps/emqx_exhook/src/emqx_exhook_server.erl
index e767cd84b..93568783a 100644
--- a/apps/emqx_exhook/src/emqx_exhook_server.erl
+++ b/apps/emqx_exhook/src/emqx_exhook_server.erl
@@ -273,7 +273,7 @@ match_topic_filter(TopicName, TopicFilter) ->
 -spec do_call(string(), atom(), map(), map()) -> {ok, map()} | {error, term()}.
 do_call(ChannName, Fun, Req, ReqOpts) ->
     NReq = Req#{meta => emqx_exhook:request_meta()},
-    Options = ReqOpts#{channel => ChannName},
+    Options = ReqOpts#{channel => ChannName, key_dispatch => key_dispatch(NReq)},
     ?LOG(debug, "Call ~0p:~0p(~0p, ~0p)", [?PB_CLIENT_MOD, Fun, NReq, Options]),
     case catch apply(?PB_CLIENT_MOD, Fun, [NReq, Options]) of
         {ok, Resp, _Metadata} ->
@@ -331,3 +331,13 @@ available_hooks() ->
      'session.created', 'session.subscribed', 'session.unsubscribed',
      'session.resumed', 'session.discarded', 'session.takeovered',
      'session.terminated' | message_hooks()].
+
+%% @doc Get dispatch_key for each request
+key_dispatch(_Req = #{clientinfo := #{clientid := ClientId}}) ->
+    ClientId;
+key_dispatch(_Req = #{conninfo := #{clientid := ClientId}}) ->
+    ClientId;
+key_dispatch(_Req = #{message := #{from := From}}) ->
+    From;
+key_dispatch(_Req) ->
+    self().
diff --git a/rebar.config b/rebar.config
index 1cd36d47c..7c5e01ff9 100644
--- a/rebar.config
+++ b/rebar.config
@@ -62,7 +62,7 @@
     , {lc, {git, "https://github.com/emqx/lc.git", {tag, "0.3.1"}}}
     , {mongodb, {git,"https://github.com/emqx/mongodb-erlang", {tag, "v3.0.13"}}}
     , {epgsql, {git, "https://github.com/emqx/epgsql.git", {tag, "4.6.0"}}}
-    , {grpc, {git, "https://github.com/emqx/grpc-erl", {tag, "0.6.5"}}}
+    , {grpc, {git, "https://github.com/emqx/grpc-erl", {tag, "0.6.6"}}}
     ]}.
 
 {xref_ignores,

From e4df71d90ef149ec4a129e5a75738e27ffb5cfc0 Mon Sep 17 00:00:00 2001
From: JianBo He <heeejianbo@gmail.com>
Date: Fri, 24 Jun 2022 14:18:41 +0800
Subject: [PATCH 2/3] chore: update changes-4.3

---
 CHANGES-4.3.md | 1 +
 1 file changed, 1 insertion(+)

diff --git a/CHANGES-4.3.md b/CHANGES-4.3.md
index 51c5e7cb8..7a3d6f4f3 100644
--- a/CHANGES-4.3.md
+++ b/CHANGES-4.3.md
@@ -29,6 +29,7 @@ File format:
   information to fill them. [#8280]
 - Fixed issue in Lua hook that didn't prevent a topic from being
   subscribed to. [#8288]
+- Ensuring that exhook dispatches the client events are sequential. [#8311]
 
 ## v4.3.15
 

From ee0589505848ed8e5e8b1e8e222855deb5d0f92d Mon Sep 17 00:00:00 2001
From: JianBo He <heeejianbo@gmail.com>
Date: Mon, 27 Jun 2022 11:30:54 +0800
Subject: [PATCH 3/3] chore(exhook): update changes-4.3 for #8314

---
 CHANGES-4.3.md | 1 +
 1 file changed, 1 insertion(+)

diff --git a/CHANGES-4.3.md b/CHANGES-4.3.md
index 7a3d6f4f3..e73e45124 100644
--- a/CHANGES-4.3.md
+++ b/CHANGES-4.3.md
@@ -19,6 +19,7 @@ File format:
   management HTTPS listeners. [#8129]
 - Add message republish supports using placeholder variables to specify QoS and Retain values. Set `${qos}` and `${flags.retain}` use the original QoS & Retain flag.
 - Add supports specifying the network interface address of the cluster listener & rcp call listener. Specify `0.0.0.0` use all network interfaces, or a particular network interface IP address.
+- ExHook supports to customize the socket parameters for gRPC client. [#8314]
 
 ### Bug fixes