From e7153c4266e839f3ea768d76790ca65f73753d6b Mon Sep 17 00:00:00 2001
From: wwhai <751957846@qq.com>
Date: Wed, 27 Jan 2021 15:06:12 +0800
Subject: [PATCH] fix(rule-engine): add cluster init callback

---
 apps/emqx_rule_engine/src/emqx_rule_engine.erl | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/apps/emqx_rule_engine/src/emqx_rule_engine.erl b/apps/emqx_rule_engine/src/emqx_rule_engine.erl
index bbf82f7db..c45a3a20c 100644
--- a/apps/emqx_rule_engine/src/emqx_rule_engine.erl
+++ b/apps/emqx_rule_engine/src/emqx_rule_engine.erl
@@ -288,7 +288,8 @@ do_update_resource_check(Id, NewParams) ->
 
 do_update_resource(#{id := Id, type := Type, description:= NewDescription, config:= NewConfig}) ->
     case emqx_rule_registry:find_resource_type(Type) of
-        {ok, #resource_type{params_spec = ParamSpec}} ->
+        {ok, #resource_type{on_create = {Module, Create},
+                            params_spec = ParamSpec}} ->
             Config = emqx_rule_validator:validate_params(NewConfig, ParamSpec),
             case test_resource(#{type => Type, config => NewConfig}) of
                 ok ->
@@ -297,6 +298,7 @@ do_update_resource(#{id := Id, type := Type, description:= NewDescription, confi
                                          config = Config,
                                          description = NewDescription,
                                          created_at = erlang:system_time(millisecond)},
+                    cluster_call(init_resource, [Module, Create, Id, Config]),
                     emqx_rule_registry:add_resource(Resource);
                {error, Reason} ->
                     {error, Reason}