remove user name in case of tls (#57)

* remove user name in case of tls

Signed-off-by: Gabriele Santomaggio <[email protected]>

* Update pkg/rabbitmqamqp/amqp_connection_test.go

Co-authored-by: Aitor Pérez Cedres <[email protected]>

---------

Signed-off-by: Gabriele Santomaggio <[email protected]>
Co-authored-by: Aitor Pérez Cedres <[email protected]>

Author: Gsantomaggio

pkg/rabbitmqamqp/amqp_connection.go

@@ -262,6 +262,10 @@ func (a *AmqpConnection) open(ctx context.Context, address string, connOptions *
 		WriteTimeout: connOptions.WriteTimeout,
 	}
 	azureConnection, err = amqp.Dial(ctx, address, amqpLiteConnOptions)
+	if err != nil && (connOptions.TLSConfig != nil || uri.Scheme == AMQPS) {
+		Error("Failed to open TLS connection", fmt.Sprintf("%s://%s", uri.Scheme, uri.Host), err, "ID", connOptions.Id)
+		return fmt.Errorf("failed to open TLS connection: %w", err)
+	}
 	if err != nil {
 		Error("Failed to open connection", ExtractWithoutPassword(address), err, "ID", connOptions.Id)
 		return fmt.Errorf("failed to open connection: %w", err)

pkg/rabbitmqamqp/amqp_connection_test.go

@@ -164,4 +164,16 @@ var _ = Describe("AMQP connection Test", func() {
 		}()
 	})
 
+	Describe("AMQP TLS connection should fail with error.", func() {
+		tlsConfig := &tls.Config{}
+
+		// Dial the AMQP server with TLS configuration
+		connection, err := Dial(context.Background(), "amqps://does_not_exist:5671", &AmqpConnOptions{
+			TLSConfig: tlsConfig,
+		})
+		Expect(connection).To(BeNil())
+		Expect(err).To(HaveOccurred())
+		Expect(err.Error()).To(ContainSubstring("failed to open TLS connection"))
+	})
+
 })

pkg/rabbitmqamqp/common.go

@@ -10,6 +10,7 @@ import (
 
 // public consts
 
+const AMQPS = "amqps"
 const StreamFilterValue = "x-stream-filter-value"
 
 const (