Test attach_sender_link_sync

Author: MarcialRosales

deps/amqp10_client/test/system_SUITE.erl

@@ -54,7 +54,8 @@ groups() ->
                  incoming_heartbeat,
                  multi_transfer_without_delivery_id,
                  set_receiver_capabilities,
-                 set_sender_capabilities
+                 set_sender_capabilities,
+                 set_sender_sync_capabilities
                 ]}
     ].
 
@@ -911,6 +912,54 @@ set_sender_capabilities(Config) ->
     ok = amqp10_client:close_connection(Connection),
     ok.
 
+
+set_sender_sync_capabilities(Config) ->
+    Hostname = ?config(mock_host, Config),
+    Port = ?config(mock_port, Config),
+    OpenStep = fun({0 = Ch, #'v1_0.open'{}, _Pay}) ->
+                       {Ch, [#'v1_0.open'{container_id = {utf8, <<"mock">>}}]}
+               end,
+    BeginStep = fun({1 = Ch, #'v1_0.begin'{}, _Pay}) ->
+                         {Ch, [#'v1_0.begin'{remote_channel = {ushort, 1},
+                                             next_outgoing_id = {uint, 1},
+                                             incoming_window = {uint, 1000},
+                                             outgoing_window = {uint, 1000}}
+                                             ]}
+                end,
+    AttachStep = fun({1 = Ch, #'v1_0.attach'{role = false,
+                                             name = Name,
+                                             source = #'v1_0.source'{
+
+                                             },
+                                             target = #'v1_0.target'{
+                                                capabilities = {utf8, <<"capability-1">>}}}, <<>>}) ->
+                         {Ch, [#'v1_0.attach'{name = Name,
+                                              handle = {uint, 99},
+                                              role = true}]}
+                 end,
+    Steps = [fun mock_server:recv_amqp_header_step/1,
+             fun mock_server:send_amqp_header_step/1,
+             mock_server:amqp_step(OpenStep),
+             mock_server:amqp_step(BeginStep),
+             mock_server:amqp_step(AttachStep)],
+
+    ok = mock_server:set_steps(?config(mock_server, Config), Steps),
+
+    Cfg = #{address => Hostname, port => Port, sasl => none, notify => self()},
+    {ok, Connection} = amqp10_client:open_connection(Cfg),
+    {ok, Session} = amqp10_client:begin_session_sync(Connection),
+    {ok, Sender} = amqp10_client:attach_sender_link_sync(Session, <<"mock1-sender">>,
+                                                    <<"test">>, 
+                                                    mixed, 
+                                                    none,
+                                                    <<"capability-1">>),
+    Msg = amqp10_msg:new(<<"mock-tag">>, <<"banana">>, true),
+    {error, insufficient_credit} = amqp10_client:send_msg(Sender, Msg),
+
+    ok = amqp10_client:end_session(Session),
+    ok = amqp10_client:close_connection(Connection),
+    ok.
+
 outgoing_heartbeat(Config) ->
     Hostname = ?config(rmq_hostname, Config),
     Port = rabbit_ct_broker_helpers:get_node_config(Config, 0, tcp_port_amqp),