use structs in channels

Author: msanlli

backend/pkg/broker/topics/blcu/blcu_test.go

@@ -123,12 +123,12 @@ func TestBLCUTopic_Download_Push(t *testing.T) {
 	}
 
 	// Use a timeout for client read
-	done := make(chan bool)
+	done := make(chan struct{})
 	go func() {
 		output, readErr := client.Read()
 		if readErr != nil {
 			logger.Error().Err(readErr).Msg("Client read failed")
-			done <- true
+			done <- struct{}{}
 			return
 		}
 		if output.Topic != blcu.DownloadName {
@@ -137,7 +137,7 @@ func TestBLCUTopic_Download_Push(t *testing.T) {
 		if string(output.Payload) != "test" {
 			t.Error("Expected payload 'test', got", string(output.Payload))
 		}
-		done <- true
+		done <- struct{}{}
 	}()
 
 	select {
@@ -224,12 +224,12 @@ func TestBLCUTopic_Upload_Push(t *testing.T) {
 	}
 
 	// Use a timeout for client read
-	done := make(chan bool)
+	done := make(chan struct{})
 	go func() {
 		output, err := client.Read()
 		if err != nil {
 			logger.Error().Err(err).Msg("Client read failed")
-			done <- true
+			done <- struct{}{}
 			return
 		}
 		if output.Topic != blcu.UploadName {
@@ -238,7 +238,7 @@ func TestBLCUTopic_Upload_Push(t *testing.T) {
 		if string(output.Payload) != "test" {
 			t.Error("Expected payload 'test', got", string(output.Payload))
 		}
-		done <- true
+		done <- struct{}{}
 	}()
 
 	select {

backend/pkg/broker/topics/connection/connection_test.go

@@ -76,12 +76,12 @@ func TestConnectionTopic_Push(t *testing.T) {
 	}
 
 	// Use a timeout for client read
-	done := make(chan bool)
+	done := make(chan struct{})
 	go func() {
 		output, readErr := client.Read()
 		if readErr != nil {
 			logger.Error().Err(readErr).Msg("Client read failed")
-			done <- true
+			done <- struct{}{}
 			return
 		}
 		if output.Topic != data.UpdateName {
@@ -94,7 +94,7 @@ func TestConnectionTopic_Push(t *testing.T) {
 		if string(output.Payload) != string(payloadBytes) {
 			t.Error("Expected payload 'test', got", string(output.Payload))
 		}
-		done <- true
+		done <- struct{}{}
 	}()
 
 	select {
@@ -171,12 +171,12 @@ func TestConnectionTopic_ClientMessage(t *testing.T) {
 	})
 
 	// Use a timeout for client read
-	done := make(chan bool)
+	done := make(chan struct{})
 	go func() {
 		output, readErr := client.Read()
 		if readErr != nil {
 			logger.Error().Err(readErr).Msg("Client read failed")
-			done <- true
+			done <- struct{}{}
 			return
 		}
 		if output.Topic != data.SubscribeName {
@@ -190,7 +190,7 @@ func TestConnectionTopic_ClientMessage(t *testing.T) {
 			comparison, _ := json.Marshal(payloadInput)
 			t.Errorf("Expected payload %s , got %s", string(comparison), string(output.Payload))
 		}
-		done <- true
+		done <- struct{}{}
 	}()
 
 	select {

backend/pkg/broker/topics/data/data_test.go

@@ -89,12 +89,12 @@ func TestDataTopic_Push(t *testing.T) {
 	}
 
 	// Use a timeout for client read
-	done := make(chan bool)
+	done := make(chan struct{})
 	go func() {
 		output, readErr := client.Read()
 		if readErr != nil {
 			logger.Error().Err(readErr).Msg("Client read failed")
-			done <- true
+			done <- struct{}{}
 			return
 		}
 		if output.Topic != data.UpdateName {
@@ -118,7 +118,7 @@ func TestDataTopic_Push(t *testing.T) {
 		if string(output.Payload) != string(payloadBytes) {
 			t.Error("Expected payload 'test', got", string(output.Payload))
 		}
-		done <- true
+		done <- struct{}{}
 	}()
 
 	select {

backend/pkg/broker/topics/message/message_test.go

@@ -78,12 +78,12 @@ func TestMessageTopic_Push(t *testing.T) {
 	}
 
 	// Use a timeout for client read
-	done := make(chan bool)
+	done := make(chan struct{})
 	go func() {
 		output, readErr := client.Read()
 		if readErr != nil {
 			logger.Error().Err(readErr).Msg("Client read failed")
-			done <- true
+			done <- struct{}{}
 			return
 		}
 		if output.Topic != data.UpdateName {
@@ -97,7 +97,7 @@ func TestMessageTopic_Push(t *testing.T) {
 		if string(output.Payload) != string(comparisonBytes) {
 			t.Error("Expected payload 'test', got", string(output.Payload))
 		}
-		done <- true
+		done <- struct{}{}
 	}()
 
 	select {