Fix: Fix the lint

backend/integration-test/integration_test.go

@@ -13,16 +13,11 @@ import (
 const (
 	// Attempts connection
 	host       = "backend:8080"
-	healthPath = "http://" + host + "/healthz"
+	healthPath = "/healthz"
 	attempts   = 20
 
 	// HTTP REST
 	basePath = "http://" + host + "/v1"
-
-	// Kafka
-	kafkaHost     = "kafka:9092"
-	consumerTopic = "consumer_topic"
-	producerTopic = "producer_topic"
 )
 
 func TestMain(t *testing.M) {
@@ -41,12 +36,12 @@ func healthCheck(attempts int) error {
 	var err error
 
 	for attempts > 0 {
-		err = Do(Get(healthPath), Expect().Status().Equal(http.StatusOK))
+		err = Do(Get(basePath+healthPath), Expect().Status().Equal(http.StatusOK))
 		if err == nil {
 			return nil
 		}
 
-		log.Printf("Integration tests: url %s is not available, attempts left: %d", healthPath, attempts)
+		log.Printf("Integration tests: url %s is not available, attempts left: %d", basePath+healthPath, attempts)
 
 		time.Sleep(time.Second)
 

backend/internal/controller/http/v1/utils.go

@@ -36,7 +36,10 @@ func (m *HTTPControllerMessenger) SendMessage(chanName string, value interface{}
 	}
 
 	res := <-channel
-	notify.Stop(msgKey, channel)
+	err = notify.Stop(msgKey, channel)
+	if err != nil {
+		return &entity.NotifyData{}, fmt.Errorf("sendMessage - notify.Stop: %v", err)
+	}
 	if notifyData, ok := res.(*entity.NotifyData); ok {
 		switch msg := notifyData.Message.(type) {
 		case entity.EnvelopeResponse:

backend/internal/usecase/role_permission_test.go

@@ -11,16 +11,6 @@ import (
 	"github.com/stretchr/testify/assert"
 )
 
-var validateError = errors.New("error")
-
-type rolePermissionTest struct {
-	name   string
-	roleId int
-	mock   func()
-	res    interface{}
-	err    error
-}
-
 func TestRolePermissionUseCase_Validate(t *testing.T) {
 	t.Helper()
 

backend/internal/usecase/users.go

@@ -41,7 +41,11 @@ func (uc *UserUseCase) CreateUser(user entity.User) error {
 	if err != nil {
 		return err
 	}
-	uc.repo.CreateUser(user)
+
+	err = uc.repo.CreateUser(user)
+	if err != nil {
+		return err
+	}
 	return nil
 }
 
@@ -91,11 +95,10 @@ func (uc *UserUseCase) GetAllUsers() ([]entity.UserResponse, error) {
 }
 
 func (uc *UserUseCase) EditUsersRole(userRole entity.UserRole) error {
-	var err error
+	err := uc.repo.EditUsersRole(userRole.ID_user, userRole.ID_role)
 	if err != nil {
 		return err
 	}
-	uc.repo.EditUsersRole(userRole.ID_user, userRole.ID_role)
 	return nil
 }
 

backend/internal/usecase/vault_test.go

@@ -246,6 +246,3 @@ func TestVaultUseCaseCreate(t *testing.T) {
 		})
 	}
 }
-
-func TestsVaultUseCaseUpdateVault(t *testing.T) {
-}

backend/pkg/kafka/connection.go

@@ -101,7 +101,11 @@ func (c Connection) Run(cfg *config.Config, chanName string) {
 				fmt.Println(err)
 				continue
 			}
-			notify.Post(string(msg.Key), &entity.NotifyData{Key: string(msg.Key), Message: data})
+			err = notify.Post(string(msg.Key), &entity.NotifyData{Key: string(msg.Key), Message: data})
+			if err != nil {
+				fmt.Println(err)
+				continue
+			}
 		}
 	}
 }