chore: Add configuration test.

Author: ldmi3i

internal/config/application_test.go

@@ -0,0 +1,38 @@
+package config
+
+import (
+	"github.com/stretchr/testify/assert"
+	"os"
+	"strconv"
+	"testing"
+)
+
+func TestReadConfig(t *testing.T) {
+	expUrlRequestQueue := "url_request_queue"
+	err := os.Setenv("QUEUE_URL_REQUEST_QUEUE", expUrlRequestQueue)
+	assert.Nil(t, err)
+
+	expScrResQueue := "scraping_res_queue"
+	err = os.Setenv("QUEUE_SCRAPING_RESULT_QUEUE", expScrResQueue)
+	assert.Nil(t, err)
+
+	expNotificationQueue := "test_notifications"
+	err = os.Setenv("QUEUE_NOTIFICATION_QUEUE", expNotificationQueue)
+	assert.Nil(t, err)
+
+	expQueueUrl := "test_url"
+	err = os.Setenv("QUEUE_URL", expQueueUrl)
+	assert.Nil(t, err)
+
+	expQueueConcurrency := 50
+	err = os.Setenv("QUEUE_CONCURRENCY", strconv.Itoa(expQueueConcurrency))
+	assert.Nil(t, err)
+
+	conf, err := ReadConfig()
+	assert.Nil(t, err)
+	assert.Equal(t, expUrlRequestQueue, conf.Queue.UrlRequestQueue)
+	assert.Equal(t, expScrResQueue, conf.Queue.ScrapingResultQueue)
+	assert.Equal(t, expNotificationQueue, conf.Queue.NotificationQueue)
+	assert.Equal(t, expQueueUrl, conf.Queue.Url)
+	assert.Equal(t, expQueueConcurrency, conf.Queue.Concurrency)
+}

internal/config/queue.go

@@ -2,9 +2,9 @@ package config
 
 //QueueConfig queue configuration
 type QueueConfig struct {
-	UrlRequestQueue     string `default:"data-scraping-asd"`                  //UrlRequestQueue name to listen to the new events
-	ScrapingResultQueue string `default:"storage-update-asd"`                 //Queue name to send processed ApiSpecDoc
-	NotificationQueue   string `default:"gateway-scrape_notifications"`       //Queue name to notify a user about error or success (if required)
-	Url                 string `default:"amqp://guest:guest@localhost:5672/"` //RabbitMQ url
-	Concurrency         int    `default:"30"`                                 //Number of parallel handlers
+	UrlRequestQueue     string `default:"data-scraping-asd" envconfig:"URL_REQUEST_QUEUE"`             //UrlRequestQueue name to listen to the new events
+	ScrapingResultQueue string `default:"storage-update-asd" envconfig:"SCRAPING_RESULT_QUEUE"`        //Queue name to send processed ApiSpecDoc
+	NotificationQueue   string `default:"gateway-scrape-notifications" envconfig:"NOTIFICATION_QUEUE"` //Queue name to notify a user about error or success (if required)
+	Url                 string `default:"amqp://guest:guest@localhost:5672/"`                          //RabbitMQ url
+	Concurrency         int    `default:"30"`                                                          //Number of parallel handlers
 }