Sfoglia il codice sorgente

fix(test): always init session with zone and listener names

Shawn 4 anni fa
parent
commit
88638da287

+ 3 - 2
apps/emqx/test/emqx_channel_SUITE.erl

@@ -624,7 +624,7 @@ t_handle_deliver_nl(_) ->
     Channel = channel(#{clientinfo => ClientInfo, session => Session}),
     Msg = emqx_message:make(<<"clientid">>, ?QOS_1, <<"t1">>, <<"qos1">>),
     NMsg = emqx_message:set_flag(nl, Msg),
-    {ok, Channel} = emqx_channel:handle_deliver([{deliver, <<"t1">>, NMsg}], Channel).
+    {ok, _} = emqx_channel:handle_deliver([{deliver, <<"t1">>, NMsg}], Channel).
 
 %%--------------------------------------------------------------------
 %% Test cases for handle_out
@@ -973,7 +973,8 @@ session(InitFields) when is_map(InitFields) ->
     maps:fold(fun(Field, Value, Session) ->
                       emqx_session:set_field(Field, Value, Session)
               end,
-              emqx_session:init(#{zone => channel}, #{receive_maximum => 0}),
+              emqx_session:init(#{zone => default, listener => mqtt_tcp},
+                  #{receive_maximum => 0}),
               InitFields).
 
 %% conn: 5/s; overall: 10/s

+ 4 - 2
apps/emqx/test/emqx_session_SUITE.erl

@@ -50,7 +50,8 @@ end_per_testcase(_TestCase, Config) ->
 %%--------------------------------------------------------------------
 
 t_session_init(_) ->
-    Session = emqx_session:init(#{zone => zone}, #{receive_maximum => 64}),
+    Session = emqx_session:init(#{zone => default, listener => mqtt_tcp},
+        #{receive_maximum => 64}),
     ?assertEqual(#{}, emqx_session:info(subscriptions, Session)),
     ?assertEqual(0, emqx_session:info(subscriptions_cnt, Session)),
     ?assertEqual(0, emqx_session:info(subscriptions_max, Session)),
@@ -375,7 +376,8 @@ session(InitFields) when is_map(InitFields) ->
     maps:fold(fun(Field, Value, Session) ->
                       emqx_session:set_field(Field, Value, Session)
               end,
-              emqx_session:init(#{zone => channel}, #{receive_maximum => 0}),
+              emqx_session:init(#{zone => default, listener => mqtt_tcp},
+                  #{receive_maximum => 0}),
               InitFields).
 
 

+ 1 - 1
apps/emqx/test/emqx_ws_connection_SUITE.erl

@@ -502,7 +502,7 @@ channel(InitFields) ->
                    peercert   => undefined,
                    mountpoint => undefined
                   },
-    Session = emqx_session:init(#{zone => external},
+    Session = emqx_session:init(#{zone => default, listener => mqtt_tcp},
                                 #{receive_maximum => 0}
                                ),
     maps:fold(fun(Field, Value, Channel) ->