Merge live tests into messenger tests

Skip the test step if the compose certs are missing

dev_utils/docker-compose.yml

@@ -127,7 +127,7 @@ services:
       - "-c"
       - "cd /app; echo 'Running go ${GOLANG_VERSION:-1.18} tests';
          go install 2>/dev/null
-         && go test -tags live -coverprofile=coverage.txt -covermode=atomic"
+         && go test . -v -coverprofile=coverage.txt -covermode=atomic"
     depends_on:
       mq:
         condition: service_healthy

messenger_test.go

@@ -3,6 +3,7 @@ package main
 import (
 	"testing"
 
+	"github.com/spf13/viper"
 	"github.com/stretchr/testify/assert"
 )
 
@@ -12,3 +13,49 @@ func TestBuildMqURI(t *testing.T) {
 	amqp := buildMqURI("localhost", "5555", "mquser", "mqpass", "/vhost", false)
 	assert.Equal(t, "amqp://mquser:mqpass@localhost:5555/vhost", amqp)
 }
+
+func TestNewAMQPMessenger(t *testing.T) {
+	viper.Reset()
+	viper.Set("server.confFile", "dev_utils/config.yaml")
+
+	config, err := NewConfig()
+	assert.NoError(t, err)
+	assert.NotNil(t, config)
+	tlsConfig, err := TLSConfigBroker(config)
+	if err != nil {
+		t.Log(err)
+		t.Skip("skip test since certificates are not present")
+	}
+	assert.NotNil(t, tlsConfig)
+	assert.NoError(t, err)
+
+	assert.NotPanics(t, func() { NewAMQPMessenger(config.Broker, tlsConfig) })
+}
+
+func TestSendMessage(t *testing.T) {
+	viper.Reset()
+	viper.Set("server.confFile", "dev_utils/config.yaml")
+
+	config, err := NewConfig()
+	assert.NotNil(t, config)
+	assert.NoError(t, err)
+	tlsConfig, err := TLSConfigBroker(config)
+	if err != nil {
+		t.Log(err)
+		t.Skip("skip test since certificates are not present")
+	}
+	assert.NotNil(t, tlsConfig)
+	assert.NoError(t, err)
+
+	messenger := NewAMQPMessenger(config.Broker, tlsConfig)
+
+	event := Event{}
+	checksum := Checksum{}
+	event.Username = "Dummy"
+	checksum.Type = "md5"
+	checksum.Value = "123456789"
+	event.Checksum = []interface{}{checksum}
+
+	err = messenger.SendMessage(event)
+	assert.NoError(t, err)
+}