fix: 243 tx to InTx for account,tab,user

Author: the-npden4ik

Diff for: modules/core/handlers/tab_handler.go

@@ -2,6 +2,7 @@ package handlers
 
 import (
 	"context"
+	"github.com/iota-uz/iota-sdk/pkg/composables"
 
 	"github.com/iota-uz/iota-sdk/modules/core/domain/aggregates/user"
 	"github.com/iota-uz/iota-sdk/modules/core/domain/entities/tab"
@@ -59,12 +60,20 @@ func (h *TabHandler) createUserTabs(ctx context.Context, user user.User) {
 
 	if len(tabs) > 0 {
 		ctxWithUser := context.WithValue(ctx, constants.UserKey, user)
-		if err := h.tabService.DeleteUserTabs(ctxWithUser, user.ID()); err != nil {
-			h.logger.Errorf("Failed to delete existing tabs for user %d: %v", user.ID(), err)
-			return
-		}
-		if err := h.tabService.CreateMany(ctxWithUser, tabs); err != nil {
-			h.logger.Errorf("Failed to create tab for user %d: %v", user.ID(), err)
+		err := composables.InTx(ctx, func(txCtx context.Context) error {
+			if err := h.tabService.DeleteUserTabs(ctxWithUser, user.ID()); err != nil {
+				h.logger.Errorf("Failed to delete existing tabs for user %d: %v", user.ID(), err)
+				return err
+			}
+			if err := h.tabService.CreateMany(ctxWithUser, tabs); err != nil {
+				h.logger.Errorf("Failed to create tab for user %d: %v", user.ID(), err)
+				return err
+			}
+			return nil
+		})
+
+		if err != nil {
+			h.logger.Errorf("Failed to create tabs for user %d: %v", user.ID(), err)
 		}
 	}
 }

Diff for: modules/core/module.go

@@ -64,7 +64,6 @@ func (m *Module) Register(app application.Application) error {
 		services.NewRoleService(roleRepo, app.EventPublisher()),
 		services.NewPermissionService(permRepo, app.EventPublisher()),
 		services.NewTabService(persistence.NewTabRepository()),
-		services.NewTabService(persistence.NewTabRepository()),
 		services.NewGroupService(persistence.NewGroupRepository(userRepo, roleRepo), app.EventPublisher()),
 	)
 

Diff for: modules/core/presentation/controllers/account_controller.go

@@ -55,7 +55,7 @@ func (c *AccountController) Register(r *mux.Router) {
 
 	setRouter := r.PathPrefix(c.basePath).Subrouter()
 	setRouter.Use(commonMiddleware...)
-	setRouter.Use(middleware.WithTransaction())
+	//setRouter.Use(middleware.WithTransaction())
 	setRouter.HandleFunc("", c.Update).Methods(http.MethodPost)
 	setRouter.HandleFunc("/sidebar", c.PostSettings).Methods(http.MethodPost)
 }

Diff for: modules/core/services/tab_service.go

@@ -2,8 +2,8 @@ package services
 
 import (
 	"context"
-
 	"github.com/iota-uz/iota-sdk/modules/core/domain/entities/tab"
+	"github.com/iota-uz/iota-sdk/pkg/composables"
 )
 
 type TabService struct {
@@ -46,10 +46,16 @@ func (s *TabService) CreateManyUserTabs(ctx context.Context, userID uint, data [
 		}
 		entities = append(entities, entity)
 	}
-	if err := s.repo.DeleteUserTabs(ctx, userID); err != nil {
-		return nil, err
-	}
-	if err := s.repo.CreateMany(ctx, entities); err != nil {
+	err := composables.InTx(ctx, func(txCtx context.Context) error {
+		if err := s.repo.DeleteUserTabs(txCtx, userID); err != nil {
+			return err
+		}
+		if err := s.repo.CreateMany(txCtx, entities); err != nil {
+			return err
+		}
+		return nil
+	})
+	if err != nil {
 		return nil, err
 	}
 	return entities, nil

Diff for: modules/core/services/user_service.go

@@ -65,41 +65,39 @@ func (s *UserService) GetPaginatedWithTotal(ctx context.Context, params *user.Fi
 }
 
 func (s *UserService) Create(ctx context.Context, data user.User) error {
-	if err := composables.CanUser(ctx, permissions.UserCreate); err != nil {
-		return err
-	}
-	if err := s.validator.ValidateCreate(ctx, data); err != nil {
+	err := composables.CanUser(ctx, permissions.UserCreate)
+	if err != nil {
 		return err
 	}
-	logger := composables.UseLogger(ctx)
-	tx, err := composables.BeginTx(ctx)
+	err = s.validator.ValidateCreate(ctx, data)
 	if err != nil {
 		return err
 	}
-	defer func() {
-		if err := tx.Rollback(ctx); err != nil {
-			logger.WithError(err).Error("failed to rollback transaction")
+
+	var createdUser user.User
+	err = composables.InTx(ctx, func(txCtx context.Context) error {
+		data, err = data.SetPassword(data.Password())
+		if err != nil {
+			return err
 		}
-	}()
-	createdEvent, err := user.NewCreatedEvent(ctx, data)
-	if err != nil {
+		created, err := s.repo.Create(ctx, data)
+		if err != nil {
+			return err
+		}
+		createdUser = created
 		return err
-	}
-	data, err = data.SetPassword(data.Password())
+	})
 	if err != nil {
 		return err
 	}
-	created, err := s.repo.Create(ctx, data)
+	createdEvent, err := user.NewCreatedEvent(ctx, data)
 	if err != nil {
 		return err
 	}
-
-	if err := tx.Commit(ctx); err != nil {
-		return err
-	}
-	createdEvent.Result = created
+	createdEvent.Result = createdUser
 	s.publisher.Publish(createdEvent)
-	return nil
+
+	return err
 }
 
 func (s *UserService) UpdateLastAction(ctx context.Context, id uint) error {