bazel run gazelle

deps/amqp10_client/BUILD.bazel

@@ -78,6 +78,7 @@ rabbitmq_app(
         "//deps/amqp10_common:erlang_app",
         "//deps/rabbit_common:erlang_app",
         "@credentials_obfuscation//:erlang_app",
+        "@gun//:erlang_app",
     ],
 )
 

deps/amqp10_client/app.bzl

@@ -16,6 +16,7 @@ def all_beam_files(name = "all_beam_files"):
             "src/amqp10_client_frame_reader.erl",
             "src/amqp10_client_session.erl",
             "src/amqp10_client_sessions_sup.erl",
+            "src/amqp10_client_socket.erl",
             "src/amqp10_client_sup.erl",
             "src/amqp10_client_types.erl",
             "src/amqp10_msg.erl",
@@ -44,6 +45,7 @@ def all_test_beam_files(name = "all_test_beam_files"):
             "src/amqp10_client_frame_reader.erl",
             "src/amqp10_client_session.erl",
             "src/amqp10_client_sessions_sup.erl",
+            "src/amqp10_client_socket.erl",
             "src/amqp10_client_sup.erl",
             "src/amqp10_client_types.erl",
             "src/amqp10_msg.erl",
@@ -78,6 +80,7 @@ def all_srcs(name = "all_srcs"):
             "src/amqp10_client_frame_reader.erl",
             "src/amqp10_client_session.erl",
             "src/amqp10_client_sessions_sup.erl",
+            "src/amqp10_client_socket.erl",
             "src/amqp10_client_sup.erl",
             "src/amqp10_client_types.erl",
             "src/amqp10_msg.erl",

deps/rabbit/app.bzl

@@ -533,6 +533,8 @@ def all_srcs(name = "all_srcs"):
             "include/internal_user.hrl",
             "include/mc.hrl",
             "include/rabbit_amqp.hrl",
+            "include/rabbit_amqp_metrics.hrl",
+            "include/rabbit_amqp_reader.hrl",
             "include/rabbit_global_counters.hrl",
             "include/rabbit_khepri.hrl",
             "include/vhost.hrl",
@@ -548,7 +550,6 @@ def all_srcs(name = "all_srcs"):
         name = "private_hdrs",
         srcs = [
             "src/mirrored_supervisor.hrl",
-            "src/rabbit_amqp_reader.hrl",
             "src/rabbit_feature_flags.hrl",
             "src/rabbit_ff_registry.hrl",
             "src/rabbit_fifo.hrl",

deps/rabbitmq_ct_client_helpers/app.bzl

@@ -10,7 +10,7 @@ def all_beam_files(name = "all_beam_files"):
     erlang_bytecode(
         name = "other_beam",
         testonly = True,
-        srcs = ["src/rabbit_ct_client_helpers.erl"],
+        srcs = ["src/rabbit_ct_client_helpers.erl", "src/rfc6455_client.erl"],
         hdrs = [":public_and_private_hdrs"],
         app_name = "rabbitmq_ct_client_helpers",
         dest = "ebin",
@@ -38,7 +38,7 @@ def all_srcs(name = "all_srcs"):
     filegroup(
         name = "srcs",
         testonly = True,
-        srcs = ["src/rabbit_ct_client_helpers.erl"],
+        srcs = ["src/rabbit_ct_client_helpers.erl", "src/rfc6455_client.erl"],
     )
     filegroup(
         name = "private_hdrs",
@@ -66,7 +66,7 @@ def all_test_beam_files(name = "all_test_beam_files"):
     erlang_bytecode(
         name = "test_other_beam",
         testonly = True,
-        srcs = ["src/rabbit_ct_client_helpers.erl"],
+        srcs = ["src/rabbit_ct_client_helpers.erl", "src/rfc6455_client.erl"],
         hdrs = [":public_and_private_hdrs"],
         app_name = "rabbitmq_ct_client_helpers",
         dest = "test",

deps/rabbitmq_web_mqtt/BUILD.bazel

@@ -94,7 +94,6 @@ eunit(
     name = "eunit",
     compiled_suites = [
         ":test_src_rabbit_ws_test_util_beam",
-        ":test_src_rfc6455_client_beam",
         ":test_rabbit_web_mqtt_test_util_beam",
     ],
     target = ":test_erlang_app",

deps/rabbitmq_web_mqtt/app.bzl

@@ -100,14 +100,6 @@ def test_suite_beam_files(name = "test_suite_beam_files"):
         app_name = "rabbitmq_web_mqtt",
         erlc_opts = "//:test_erlc_opts",
     )
-    erlang_bytecode(
-        name = "test_src_rfc6455_client_beam",
-        testonly = True,
-        srcs = ["test/src/rfc6455_client.erl"],
-        outs = ["test/src/rfc6455_client.beam"],
-        app_name = "rabbitmq_web_mqtt",
-        erlc_opts = "//:test_erlc_opts",
-    )
 
     erlang_bytecode(
         name = "test_rabbit_web_mqtt_test_util_beam",

deps/rabbitmq_web_stomp/BUILD.bazel

@@ -94,7 +94,6 @@ eunit(
     name = "eunit",
     compiled_suites = [
         ":test_src_rabbit_ws_test_util_beam",
-        ":test_src_rfc6455_client_beam",
         ":test_src_stomp_beam",
     ],
     target = ":test_erlang_app",

deps/rabbitmq_web_stomp/app.bzl

@@ -155,14 +155,7 @@ def test_suite_beam_files(name = "test_suite_beam_files"):
         app_name = "rabbitmq_web_stomp",
         erlc_opts = "//:test_erlc_opts",
     )
-    erlang_bytecode(
-        name = "test_src_rfc6455_client_beam",
-        testonly = True,
-        srcs = ["test/src/rfc6455_client.erl"],
-        outs = ["test/src/rfc6455_client.beam"],
-        app_name = "rabbitmq_web_stomp",
-        erlc_opts = "//:test_erlc_opts",
-    )
+
     erlang_bytecode(
         name = "test_src_stomp_beam",
         testonly = True,

moduleindex.yaml

@@ -36,6 +36,7 @@ amqp10_client:
 - amqp10_client_frame_reader
 - amqp10_client_session
 - amqp10_client_sessions_sup
+- amqp10_client_socket
 - amqp10_client_sup
 - amqp10_client_types
 - amqp10_msg
@@ -867,6 +868,7 @@ rabbitmq_consistent_hash_exchange:
 - rabbit_exchange_type_consistent_hash
 rabbitmq_ct_client_helpers:
 - rabbit_ct_client_helpers
+- rfc6455_client
 rabbitmq_ct_helpers:
 - ct_master_event_fork
 - ct_master_fork