Add create item endpoint

internal/app/application/services/asset.go

@@ -4,9 +4,17 @@ import (
 	"github.com/jibaru/home-inventory-api/m/internal/app/domain/entities"
 	"github.com/jibaru/home-inventory-api/m/internal/app/domain/repositories"
 	"github.com/jibaru/home-inventory-api/m/internal/app/domain/services"
+	"github.com/stretchr/testify/mock"
 	"os"
 )
 
+type AssetServiceInterface interface {
+	CreateFromFile(file *os.File, entity entities.Entity) (*entities.Asset, error)
+	GetUrl(asset *entities.Asset) string
+	GetByEntity(entity entities.Entity, pageFilter *PageFilter) ([]*entities.Asset, error)
+	Delete(asset *entities.Asset) error
+}
+
 type AssetService struct {
 	fileManager     services.FileManager
 	assetRepository repositories.AssetRepository
@@ -65,3 +73,51 @@ func (s *AssetService) GetByEntity(entity entities.Entity, pageFilter *PageFilte
 
 	return assets, nil
 }
+
+func (s *AssetService) Delete(asset *entities.Asset) error {
+	err := s.fileManager.Delete(asset.FileID, asset.Extension)
+	if err != nil {
+		return err
+	}
+
+	err = s.assetRepository.Delete(asset.ID)
+	if err != nil {
+		return err
+	}
+
+	return nil
+}
+
+type AssetServiceMock struct {
+	mock.Mock
+}
+
+func (s *AssetServiceMock) CreateFromFile(file *os.File, entity entities.Entity) (*entities.Asset, error) {
+	args := s.Called(file, entity)
+
+	if args.Get(0) == nil {
+		return nil, args.Error(1)
+	}
+
+	return args.Get(0).(*entities.Asset), args.Error(1)
+}
+
+func (s *AssetServiceMock) GetUrl(asset *entities.Asset) string {
+	args := s.Called(asset)
+	return args.String(0)
+}
+
+func (s *AssetServiceMock) GetByEntity(entity entities.Entity, pageFilter *PageFilter) ([]*entities.Asset, error) {
+	args := s.Called(entity, pageFilter)
+
+	if args.Get(0) == nil {
+		return nil, args.Error(1)
+	}
+
+	return args.Get(0).([]*entities.Asset), args.Error(1)
+}
+
+func (s *AssetServiceMock) Delete(asset *entities.Asset) error {
+	args := s.Called(asset)
+	return args.Error(0)
+}

internal/app/application/services/asset_test.go

@@ -191,3 +191,70 @@ func TestAssetServiceGetByEntityErrorFromAssetRepository(t *testing.T) {
 	assert.Nil(t, assets)
 	assetRepository.AssertExpectations(t)
 }
+
+func TestAssetServiceDelete(t *testing.T) {
+	assetRepository := &stub.AssetRepositoryMock{}
+	fileManager := &serviceStubs.FileManagerMock{}
+	service := NewAssetService(fileManager, assetRepository)
+
+	asset := &entities.Asset{
+		ID:        uuid.NewString(),
+		Extension: ".png",
+		FileID:    uuid.NewString(),
+	}
+
+	fileManager.On("Delete", asset.FileID, asset.Extension).
+		Return(nil)
+	assetRepository.On("Delete", asset.ID).
+		Return(nil)
+
+	err := service.Delete(asset)
+
+	assert.NoError(t, err)
+	assetRepository.AssertExpectations(t)
+	fileManager.AssertExpectations(t)
+}
+
+func TestAssetServiceDeleteErrorFromAssetRepository(t *testing.T) {
+	assetRepository := &stub.AssetRepositoryMock{}
+	fileManager := &serviceStubs.FileManagerMock{}
+	service := NewAssetService(fileManager, assetRepository)
+
+	asset := &entities.Asset{
+		ID:        uuid.NewString(),
+		Extension: ".png",
+		FileID:    uuid.NewString(),
+	}
+
+	fileManager.On("Delete", asset.FileID, asset.Extension).
+		Return(nil)
+	assetRepository.On("Delete", asset.ID).
+		Return(errors.New("repository error"))
+
+	err := service.Delete(asset)
+
+	assert.Error(t, err)
+	assetRepository.AssertExpectations(t)
+	fileManager.AssertExpectations(t)
+}
+
+func TestAssetServiceDeleteErrorFromFileManager(t *testing.T) {
+	assetRepository := &stub.AssetRepositoryMock{}
+	fileManager := &serviceStubs.FileManagerMock{}
+	service := NewAssetService(fileManager, assetRepository)
+
+	asset := &entities.Asset{
+		ID:        uuid.NewString(),
+		Extension: ".png",
+		FileID:    uuid.NewString(),
+	}
+
+	fileManager.On("Delete", asset.FileID, asset.Extension).
+		Return(errors.New("file manager error"))
+
+	err := service.Delete(asset)
+
+	assert.Error(t, err)
+	assetRepository.AssertExpectations(t)
+	fileManager.AssertExpectations(t)
+}

internal/app/application/services/item.go

@@ -0,0 +1,80 @@
+package services
+
+import (
+	"github.com/jibaru/home-inventory-api/m/internal/app/domain/entities"
+	"github.com/jibaru/home-inventory-api/m/internal/app/domain/repositories"
+	"log"
+	"os"
+)
+
+type ItemService struct {
+	itemRepository        repositories.ItemRepository
+	itemKeywordRepository repositories.ItemKeywordRepository
+	assetService          AssetServiceInterface
+}
+
+func NewItemService(
+	itemRepository repositories.ItemRepository,
+	itemKeywordRepository repositories.ItemKeywordRepository,
+	assetService AssetServiceInterface,
+) *ItemService {
+	return &ItemService{
+		itemRepository,
+		itemKeywordRepository,
+		assetService,
+	}
+}
+
+func (s *ItemService) Create(
+	sku string,
+	name string,
+	description *string,
+	unit string,
+	userID string,
+	keywords []string,
+	imageFile *os.File,
+) (*entities.Item, error) {
+	item, err := entities.NewItem(sku, name, description, unit, userID)
+	if err != nil {
+		return nil, err
+	}
+
+	var itemKeywords []*entities.ItemKeyword
+	for _, keyword := range keywords {
+		itemKeyword, err := entities.NewItemKeyword(item.ID, keyword)
+		if err != nil {
+			return nil, err
+		}
+
+		itemKeywords = append(itemKeywords, itemKeyword)
+	}
+
+	asset, err := s.assetService.CreateFromFile(imageFile, item)
+	if err != nil {
+		return nil, err
+	}
+
+	err = s.itemRepository.Create(item)
+	if err != nil {
+		go func() {
+			err := s.assetService.Delete(asset)
+			if err != nil {
+				log.Println(err)
+			}
+		}()
+		return nil, err
+	}
+
+	err = s.itemKeywordRepository.CreateMany(itemKeywords)
+	if err != nil {
+		go func() {
+			err := s.assetService.Delete(asset)
+			if err != nil {
+				log.Println(err)
+			}
+		}()
+		return nil, err
+	}
+
+	return item, nil
+}