feat: move entity and usecase to root folder
This commit is contained in:
Elton Minetto
@@ -0,0 +1,35 @@
|
||||
package book
|
||||
|
||||
import (
|
||||
"github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
)
|
||||
|
||||
//Reader interface
|
||||
type Reader interface {
|
||||
Get(id entity.ID) (*entity.Book, error)
|
||||
Search(query string) ([]*entity.Book, error)
|
||||
List() ([]*entity.Book, error)
|
||||
}
|
||||
|
||||
//Writer book writer
|
||||
type Writer interface {
|
||||
Create(e *entity.Book) (entity.ID, error)
|
||||
Update(e *entity.Book) error
|
||||
Delete(id entity.ID) error
|
||||
}
|
||||
|
||||
//Repository interface
|
||||
type Repository interface {
|
||||
Reader
|
||||
Writer
|
||||
}
|
||||
|
||||
//UseCase interface
|
||||
type UseCase interface {
|
||||
GetBook(id entity.ID) (*entity.Book, error)
|
||||
SearchBooks(query string) ([]*entity.Book, error)
|
||||
ListBooks() ([]*entity.Book, error)
|
||||
CreateBook(title string, author string, pages int, quantity int) (entity.ID, error)
|
||||
UpdateBook(e *entity.Book) error
|
||||
DeleteBook(id entity.ID) error
|
||||
}
|
||||
@@ -0,0 +1,367 @@
|
||||
// Code generated by MockGen. DO NOT EDIT.
|
||||
// Source: usecase/book/interface.go
|
||||
|
||||
// Package mock is a generated GoMock package.
|
||||
package mock
|
||||
|
||||
import (
|
||||
entity "github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
gomock "github.com/golang/mock/gomock"
|
||||
reflect "reflect"
|
||||
)
|
||||
|
||||
// MockReader is a mock of Reader interface
|
||||
type MockReader struct {
|
||||
ctrl *gomock.Controller
|
||||
recorder *MockReaderMockRecorder
|
||||
}
|
||||
|
||||
// MockReaderMockRecorder is the mock recorder for MockReader
|
||||
type MockReaderMockRecorder struct {
|
||||
mock *MockReader
|
||||
}
|
||||
|
||||
// NewMockReader creates a new mock instance
|
||||
func NewMockReader(ctrl *gomock.Controller) *MockReader {
|
||||
mock := &MockReader{ctrl: ctrl}
|
||||
mock.recorder = &MockReaderMockRecorder{mock}
|
||||
return mock
|
||||
}
|
||||
|
||||
// EXPECT returns an object that allows the caller to indicate expected use
|
||||
func (m *MockReader) EXPECT() *MockReaderMockRecorder {
|
||||
return m.recorder
|
||||
}
|
||||
|
||||
// Get mocks base method
|
||||
func (m *MockReader) Get(id entity.ID) (*entity.Book, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Get", id)
|
||||
ret0, _ := ret[0].(*entity.Book)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Get indicates an expected call of Get
|
||||
func (mr *MockReaderMockRecorder) Get(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*MockReader)(nil).Get), id)
|
||||
}
|
||||
|
||||
// Search mocks base method
|
||||
func (m *MockReader) Search(query string) ([]*entity.Book, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Search", query)
|
||||
ret0, _ := ret[0].([]*entity.Book)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Search indicates an expected call of Search
|
||||
func (mr *MockReaderMockRecorder) Search(query interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Search", reflect.TypeOf((*MockReader)(nil).Search), query)
|
||||
}
|
||||
|
||||
// List mocks base method
|
||||
func (m *MockReader) List() ([]*entity.Book, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "List")
|
||||
ret0, _ := ret[0].([]*entity.Book)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// List indicates an expected call of List
|
||||
func (mr *MockReaderMockRecorder) List() *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*MockReader)(nil).List))
|
||||
}
|
||||
|
||||
// MockWriter is a mock of Writer interface
|
||||
type MockWriter struct {
|
||||
ctrl *gomock.Controller
|
||||
recorder *MockWriterMockRecorder
|
||||
}
|
||||
|
||||
// MockWriterMockRecorder is the mock recorder for MockWriter
|
||||
type MockWriterMockRecorder struct {
|
||||
mock *MockWriter
|
||||
}
|
||||
|
||||
// NewMockWriter creates a new mock instance
|
||||
func NewMockWriter(ctrl *gomock.Controller) *MockWriter {
|
||||
mock := &MockWriter{ctrl: ctrl}
|
||||
mock.recorder = &MockWriterMockRecorder{mock}
|
||||
return mock
|
||||
}
|
||||
|
||||
// EXPECT returns an object that allows the caller to indicate expected use
|
||||
func (m *MockWriter) EXPECT() *MockWriterMockRecorder {
|
||||
return m.recorder
|
||||
}
|
||||
|
||||
// Create mocks base method
|
||||
func (m *MockWriter) Create(e *entity.Book) (entity.ID, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Create", e)
|
||||
ret0, _ := ret[0].(entity.ID)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Create indicates an expected call of Create
|
||||
func (mr *MockWriterMockRecorder) Create(e interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*MockWriter)(nil).Create), e)
|
||||
}
|
||||
|
||||
// Update mocks base method
|
||||
func (m *MockWriter) Update(e *entity.Book) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Update", e)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// Update indicates an expected call of Update
|
||||
func (mr *MockWriterMockRecorder) Update(e interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*MockWriter)(nil).Update), e)
|
||||
}
|
||||
|
||||
// Delete mocks base method
|
||||
func (m *MockWriter) Delete(id entity.ID) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Delete", id)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// Delete indicates an expected call of Delete
|
||||
func (mr *MockWriterMockRecorder) Delete(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockWriter)(nil).Delete), id)
|
||||
}
|
||||
|
||||
// MockRepository is a mock of Repository interface
|
||||
type MockRepository struct {
|
||||
ctrl *gomock.Controller
|
||||
recorder *MockRepositoryMockRecorder
|
||||
}
|
||||
|
||||
// MockRepositoryMockRecorder is the mock recorder for MockRepository
|
||||
type MockRepositoryMockRecorder struct {
|
||||
mock *MockRepository
|
||||
}
|
||||
|
||||
// NewMockRepository creates a new mock instance
|
||||
func NewMockRepository(ctrl *gomock.Controller) *MockRepository {
|
||||
mock := &MockRepository{ctrl: ctrl}
|
||||
mock.recorder = &MockRepositoryMockRecorder{mock}
|
||||
return mock
|
||||
}
|
||||
|
||||
// EXPECT returns an object that allows the caller to indicate expected use
|
||||
func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder {
|
||||
return m.recorder
|
||||
}
|
||||
|
||||
// Get mocks base method
|
||||
func (m *MockRepository) Get(id entity.ID) (*entity.Book, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Get", id)
|
||||
ret0, _ := ret[0].(*entity.Book)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Get indicates an expected call of Get
|
||||
func (mr *MockRepositoryMockRecorder) Get(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*MockRepository)(nil).Get), id)
|
||||
}
|
||||
|
||||
// Search mocks base method
|
||||
func (m *MockRepository) Search(query string) ([]*entity.Book, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Search", query)
|
||||
ret0, _ := ret[0].([]*entity.Book)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Search indicates an expected call of Search
|
||||
func (mr *MockRepositoryMockRecorder) Search(query interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Search", reflect.TypeOf((*MockRepository)(nil).Search), query)
|
||||
}
|
||||
|
||||
// List mocks base method
|
||||
func (m *MockRepository) List() ([]*entity.Book, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "List")
|
||||
ret0, _ := ret[0].([]*entity.Book)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// List indicates an expected call of List
|
||||
func (mr *MockRepositoryMockRecorder) List() *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*MockRepository)(nil).List))
|
||||
}
|
||||
|
||||
// Create mocks base method
|
||||
func (m *MockRepository) Create(e *entity.Book) (entity.ID, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Create", e)
|
||||
ret0, _ := ret[0].(entity.ID)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Create indicates an expected call of Create
|
||||
func (mr *MockRepositoryMockRecorder) Create(e interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*MockRepository)(nil).Create), e)
|
||||
}
|
||||
|
||||
// Update mocks base method
|
||||
func (m *MockRepository) Update(e *entity.Book) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Update", e)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// Update indicates an expected call of Update
|
||||
func (mr *MockRepositoryMockRecorder) Update(e interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*MockRepository)(nil).Update), e)
|
||||
}
|
||||
|
||||
// Delete mocks base method
|
||||
func (m *MockRepository) Delete(id entity.ID) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Delete", id)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// Delete indicates an expected call of Delete
|
||||
func (mr *MockRepositoryMockRecorder) Delete(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockRepository)(nil).Delete), id)
|
||||
}
|
||||
|
||||
// MockUseCase is a mock of UseCase interface
|
||||
type MockUseCase struct {
|
||||
ctrl *gomock.Controller
|
||||
recorder *MockUseCaseMockRecorder
|
||||
}
|
||||
|
||||
// MockUseCaseMockRecorder is the mock recorder for MockUseCase
|
||||
type MockUseCaseMockRecorder struct {
|
||||
mock *MockUseCase
|
||||
}
|
||||
|
||||
// NewMockUseCase creates a new mock instance
|
||||
func NewMockUseCase(ctrl *gomock.Controller) *MockUseCase {
|
||||
mock := &MockUseCase{ctrl: ctrl}
|
||||
mock.recorder = &MockUseCaseMockRecorder{mock}
|
||||
return mock
|
||||
}
|
||||
|
||||
// EXPECT returns an object that allows the caller to indicate expected use
|
||||
func (m *MockUseCase) EXPECT() *MockUseCaseMockRecorder {
|
||||
return m.recorder
|
||||
}
|
||||
|
||||
// GetBook mocks base method
|
||||
func (m *MockUseCase) GetBook(id entity.ID) (*entity.Book, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "GetBook", id)
|
||||
ret0, _ := ret[0].(*entity.Book)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// GetBook indicates an expected call of GetBook
|
||||
func (mr *MockUseCaseMockRecorder) GetBook(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetBook", reflect.TypeOf((*MockUseCase)(nil).GetBook), id)
|
||||
}
|
||||
|
||||
// SearchBooks mocks base method
|
||||
func (m *MockUseCase) SearchBooks(query string) ([]*entity.Book, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "SearchBooks", query)
|
||||
ret0, _ := ret[0].([]*entity.Book)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// SearchBooks indicates an expected call of SearchBooks
|
||||
func (mr *MockUseCaseMockRecorder) SearchBooks(query interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SearchBooks", reflect.TypeOf((*MockUseCase)(nil).SearchBooks), query)
|
||||
}
|
||||
|
||||
// ListBooks mocks base method
|
||||
func (m *MockUseCase) ListBooks() ([]*entity.Book, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "ListBooks")
|
||||
ret0, _ := ret[0].([]*entity.Book)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// ListBooks indicates an expected call of ListBooks
|
||||
func (mr *MockUseCaseMockRecorder) ListBooks() *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListBooks", reflect.TypeOf((*MockUseCase)(nil).ListBooks))
|
||||
}
|
||||
|
||||
// CreateBook mocks base method
|
||||
func (m *MockUseCase) CreateBook(title, author string, pages, quantity int) (entity.ID, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "CreateBook", title, author, pages, quantity)
|
||||
ret0, _ := ret[0].(entity.ID)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// CreateBook indicates an expected call of CreateBook
|
||||
func (mr *MockUseCaseMockRecorder) CreateBook(title, author, pages, quantity interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CreateBook", reflect.TypeOf((*MockUseCase)(nil).CreateBook), title, author, pages, quantity)
|
||||
}
|
||||
|
||||
// UpdateBook mocks base method
|
||||
func (m *MockUseCase) UpdateBook(e *entity.Book) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "UpdateBook", e)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// UpdateBook indicates an expected call of UpdateBook
|
||||
func (mr *MockUseCaseMockRecorder) UpdateBook(e interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateBook", reflect.TypeOf((*MockUseCase)(nil).UpdateBook), e)
|
||||
}
|
||||
|
||||
// DeleteBook mocks base method
|
||||
func (m *MockUseCase) DeleteBook(id entity.ID) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "DeleteBook", id)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// DeleteBook indicates an expected call of DeleteBook
|
||||
func (mr *MockUseCaseMockRecorder) DeleteBook(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteBook", reflect.TypeOf((*MockUseCase)(nil).DeleteBook), id)
|
||||
}
|
||||
@@ -0,0 +1,85 @@
|
||||
package book
|
||||
|
||||
import (
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
)
|
||||
|
||||
//Service book usecase
|
||||
type Service struct {
|
||||
repo Repository
|
||||
}
|
||||
|
||||
//NewService create new service
|
||||
func NewService(r Repository) *Service {
|
||||
return &Service{
|
||||
repo: r,
|
||||
}
|
||||
}
|
||||
|
||||
//CreateBook create a book
|
||||
func (s *Service) CreateBook(title string, author string, pages int, quantity int) (entity.ID, error) {
|
||||
b, err := entity.NewBook(title, author, pages, quantity)
|
||||
if err != nil {
|
||||
return b.ID, err
|
||||
}
|
||||
return s.repo.Create(b)
|
||||
}
|
||||
|
||||
//GetBook get a book
|
||||
func (s *Service) GetBook(id entity.ID) (*entity.Book, error) {
|
||||
b, err := s.repo.Get(id)
|
||||
if b == nil {
|
||||
return nil, entity.ErrNotFound
|
||||
}
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
|
||||
return b, nil
|
||||
}
|
||||
|
||||
//SearchBooks search books
|
||||
func (s *Service) SearchBooks(query string) ([]*entity.Book, error) {
|
||||
books, err := s.repo.Search(strings.ToLower(query))
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if len(books) == 0 {
|
||||
return nil, entity.ErrNotFound
|
||||
}
|
||||
return books, nil
|
||||
}
|
||||
|
||||
//ListBooks list books
|
||||
func (s *Service) ListBooks() ([]*entity.Book, error) {
|
||||
books, err := s.repo.List()
|
||||
if err != nil {
|
||||
return nil, err
|
||||
}
|
||||
if len(books) == 0 {
|
||||
return nil, entity.ErrNotFound
|
||||
}
|
||||
return books, nil
|
||||
}
|
||||
|
||||
//DeleteBook Delete a book
|
||||
func (s *Service) DeleteBook(id entity.ID) error {
|
||||
_, err := s.GetBook(id)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return s.repo.Delete(id)
|
||||
}
|
||||
|
||||
//UpdateBook Update a book
|
||||
func (s *Service) UpdateBook(e *entity.Book) error {
|
||||
err := e.Validate()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
e.UpdatedAt = time.Now()
|
||||
return s.repo.Update(e)
|
||||
}
|
||||
@@ -0,0 +1,93 @@
|
||||
package book
|
||||
|
||||
import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
"github.com/eminetto/clean-architecture-go-v2/infra/repository"
|
||||
|
||||
"github.com/stretchr/testify/assert"
|
||||
)
|
||||
|
||||
func newFixtureBook() *entity.Book {
|
||||
return &entity.Book{
|
||||
Title: "I Am Ozzy",
|
||||
Author: "Ozzy Osbourne",
|
||||
Pages: 294,
|
||||
Quantity: 1,
|
||||
CreatedAt: time.Now(),
|
||||
}
|
||||
}
|
||||
|
||||
func Test_Create(t *testing.T) {
|
||||
repo := repository.NewBookInmem()
|
||||
m := NewService(repo)
|
||||
u := newFixtureBook()
|
||||
_, err := m.CreateBook(u.Title, u.Author, u.Pages, u.Quantity)
|
||||
assert.Nil(t, err)
|
||||
assert.False(t, u.CreatedAt.IsZero())
|
||||
}
|
||||
|
||||
func Test_SearchAndFind(t *testing.T) {
|
||||
repo := repository.NewBookInmem()
|
||||
m := NewService(repo)
|
||||
u1 := newFixtureBook()
|
||||
u2 := newFixtureBook()
|
||||
u2.Title = "Lemmy: Biography"
|
||||
|
||||
uID, _ := m.CreateBook(u1.Title, u1.Author, u1.Pages, u1.Quantity)
|
||||
_, _ = m.CreateBook(u2.Title, u2.Author, u2.Pages, u2.Quantity)
|
||||
|
||||
t.Run("search", func(t *testing.T) {
|
||||
c, err := m.SearchBooks("ozzy")
|
||||
assert.Nil(t, err)
|
||||
assert.Equal(t, 1, len(c))
|
||||
assert.Equal(t, "I Am Ozzy", c[0].Title)
|
||||
|
||||
c, err = m.SearchBooks("dio")
|
||||
assert.Equal(t, entity.ErrNotFound, err)
|
||||
assert.Nil(t, c)
|
||||
})
|
||||
t.Run("list all", func(t *testing.T) {
|
||||
all, err := m.ListBooks()
|
||||
assert.Nil(t, err)
|
||||
assert.Equal(t, 2, len(all))
|
||||
})
|
||||
|
||||
t.Run("get", func(t *testing.T) {
|
||||
saved, err := m.GetBook(uID)
|
||||
assert.Nil(t, err)
|
||||
assert.Equal(t, u1.Title, saved.Title)
|
||||
})
|
||||
}
|
||||
|
||||
func Test_Update(t *testing.T) {
|
||||
repo := repository.NewBookInmem()
|
||||
m := NewService(repo)
|
||||
u := newFixtureBook()
|
||||
id, err := m.CreateBook(u.Title, u.Author, u.Pages, u.Quantity)
|
||||
assert.Nil(t, err)
|
||||
saved, _ := m.GetBook(id)
|
||||
saved.Title = "Lemmy: Biography"
|
||||
assert.Nil(t, m.UpdateBook(saved))
|
||||
updated, err := m.GetBook(id)
|
||||
assert.Nil(t, err)
|
||||
assert.Equal(t, "Lemmy: Biography", updated.Title)
|
||||
}
|
||||
|
||||
func TestDelete(t *testing.T) {
|
||||
repo := repository.NewBookInmem()
|
||||
m := NewService(repo)
|
||||
u1 := newFixtureBook()
|
||||
u2 := newFixtureBook()
|
||||
u2ID, _ := m.CreateBook(u2.Title, u2.Author, u2.Pages, u2.Quantity)
|
||||
|
||||
err := m.DeleteBook(u1.ID)
|
||||
assert.Equal(t, entity.ErrNotFound, err)
|
||||
|
||||
err = m.DeleteBook(u2ID)
|
||||
assert.Nil(t, err)
|
||||
_, err = m.GetBook(u2ID)
|
||||
assert.Equal(t, entity.ErrNotFound, err)
|
||||
}
|
||||
@@ -0,0 +1,11 @@
|
||||
package loan
|
||||
|
||||
import (
|
||||
"github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
)
|
||||
|
||||
//UseCase use case interface
|
||||
type UseCase interface {
|
||||
Borrow(u *entity.User, b *entity.Book) error
|
||||
Return(b *entity.Book) error
|
||||
}
|
||||
@@ -0,0 +1,62 @@
|
||||
// Code generated by MockGen. DO NOT EDIT.
|
||||
// Source: usecase/loan/interface.go
|
||||
|
||||
// Package mock is a generated GoMock package.
|
||||
package mock
|
||||
|
||||
import (
|
||||
entity "github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
gomock "github.com/golang/mock/gomock"
|
||||
reflect "reflect"
|
||||
)
|
||||
|
||||
// MockUseCase is a mock of UseCase interface
|
||||
type MockUseCase struct {
|
||||
ctrl *gomock.Controller
|
||||
recorder *MockUseCaseMockRecorder
|
||||
}
|
||||
|
||||
// MockUseCaseMockRecorder is the mock recorder for MockUseCase
|
||||
type MockUseCaseMockRecorder struct {
|
||||
mock *MockUseCase
|
||||
}
|
||||
|
||||
// NewMockUseCase creates a new mock instance
|
||||
func NewMockUseCase(ctrl *gomock.Controller) *MockUseCase {
|
||||
mock := &MockUseCase{ctrl: ctrl}
|
||||
mock.recorder = &MockUseCaseMockRecorder{mock}
|
||||
return mock
|
||||
}
|
||||
|
||||
// EXPECT returns an object that allows the caller to indicate expected use
|
||||
func (m *MockUseCase) EXPECT() *MockUseCaseMockRecorder {
|
||||
return m.recorder
|
||||
}
|
||||
|
||||
// Borrow mocks base method
|
||||
func (m *MockUseCase) Borrow(u *entity.User, b *entity.Book) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Borrow", u, b)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// Borrow indicates an expected call of Borrow
|
||||
func (mr *MockUseCaseMockRecorder) Borrow(u, b interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Borrow", reflect.TypeOf((*MockUseCase)(nil).Borrow), u, b)
|
||||
}
|
||||
|
||||
// Return mocks base method
|
||||
func (m *MockUseCase) Return(b *entity.Book) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Return", b)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// Return indicates an expected call of Return
|
||||
func (mr *MockUseCaseMockRecorder) Return(b interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Return", reflect.TypeOf((*MockUseCase)(nil).Return), b)
|
||||
}
|
||||
@@ -0,0 +1,97 @@
|
||||
package loan
|
||||
|
||||
import (
|
||||
"github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
"github.com/eminetto/clean-architecture-go-v2/usecase/book"
|
||||
"github.com/eminetto/clean-architecture-go-v2/usecase/user"
|
||||
)
|
||||
|
||||
//Service loan usecase
|
||||
type Service struct {
|
||||
userService user.UseCase
|
||||
bookService book.UseCase
|
||||
}
|
||||
|
||||
//NewService create new use case
|
||||
func NewService(u user.UseCase, b book.UseCase) *Service {
|
||||
return &Service{
|
||||
userService: u,
|
||||
bookService: b,
|
||||
}
|
||||
}
|
||||
|
||||
//Borrow borrow a book to an user
|
||||
func (s *Service) Borrow(u *entity.User, b *entity.Book) error {
|
||||
u, err := s.userService.GetUser(u.ID)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
b, err = s.bookService.GetBook(b.ID)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if b.Quantity <= 0 {
|
||||
return entity.ErrNotEnoughBooks
|
||||
}
|
||||
|
||||
err = u.AddBook(b.ID)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
err = s.userService.UpdateUser(u)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
b.Quantity--
|
||||
err = s.bookService.UpdateBook(b)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
return nil
|
||||
}
|
||||
|
||||
//Return return a book
|
||||
func (s *Service) Return(b *entity.Book) error {
|
||||
b, err := s.bookService.GetBook(b.ID)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
all, err := s.userService.ListUsers()
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
borrowed := false
|
||||
var borrowedBy entity.ID
|
||||
for _, u := range all {
|
||||
_, err := u.GetBook(b.ID)
|
||||
if err != nil {
|
||||
continue
|
||||
}
|
||||
borrowed = true
|
||||
borrowedBy = u.ID
|
||||
break
|
||||
}
|
||||
if !borrowed {
|
||||
return entity.ErrBookNotBorrowed
|
||||
}
|
||||
u, err := s.userService.GetUser(borrowedBy)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
err = u.RemoveBook(b.ID)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
err = s.userService.UpdateUser(u)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
b.Quantity++
|
||||
err = s.bookService.UpdateBook(b)
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
|
||||
return nil
|
||||
}
|
||||
@@ -0,0 +1,129 @@
|
||||
package loan
|
||||
|
||||
import (
|
||||
"testing"
|
||||
|
||||
"github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
|
||||
bmock "github.com/eminetto/clean-architecture-go-v2/usecase/book/mock"
|
||||
umock "github.com/eminetto/clean-architecture-go-v2/usecase/user/mock"
|
||||
"github.com/golang/mock/gomock"
|
||||
"github.com/stretchr/testify/assert"
|
||||
)
|
||||
|
||||
func Test_Borrow(t *testing.T) {
|
||||
controller := gomock.NewController(t)
|
||||
defer controller.Finish()
|
||||
uMock := umock.NewMockUseCase(controller)
|
||||
bMock := bmock.NewMockUseCase(controller)
|
||||
uc := NewService(uMock, bMock)
|
||||
t.Run("user not found", func(t *testing.T) {
|
||||
u := &entity.User{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
b := &entity.Book{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
uMock.EXPECT().GetUser(u.ID).Return(nil, entity.ErrNotFound)
|
||||
err := uc.Borrow(u, b)
|
||||
assert.Equal(t, entity.ErrNotFound, err)
|
||||
})
|
||||
t.Run("book not found", func(t *testing.T) {
|
||||
u := &entity.User{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
b := &entity.Book{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
uMock.EXPECT().GetUser(u.ID).Return(u, nil)
|
||||
bMock.EXPECT().GetBook(b.ID).Return(nil, entity.ErrNotFound)
|
||||
err := uc.Borrow(u, b)
|
||||
assert.Equal(t, entity.ErrNotFound, err)
|
||||
})
|
||||
t.Run("not enough books to borrow", func(t *testing.T) {
|
||||
u := &entity.User{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
b := &entity.Book{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
b.Quantity = 0
|
||||
uMock.EXPECT().GetUser(u.ID).Return(u, nil)
|
||||
bMock.EXPECT().GetBook(b.ID).Return(b, nil)
|
||||
err := uc.Borrow(u, b)
|
||||
assert.Equal(t, entity.ErrNotEnoughBooks, err)
|
||||
})
|
||||
t.Run("book already borrowed", func(t *testing.T) {
|
||||
u := &entity.User{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
b := &entity.Book{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
u.AddBook(b.ID)
|
||||
b.Quantity = 1
|
||||
uMock.EXPECT().GetUser(u.ID).Return(u, nil)
|
||||
bMock.EXPECT().GetBook(b.ID).Return(b, nil)
|
||||
err := uc.Borrow(u, b)
|
||||
assert.Equal(t, entity.ErrBookAlreadyBorrowed, err)
|
||||
})
|
||||
t.Run("sucess", func(t *testing.T) {
|
||||
u := &entity.User{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
b := &entity.Book{
|
||||
ID: entity.NewID(),
|
||||
Quantity: 10,
|
||||
}
|
||||
uMock.EXPECT().GetUser(u.ID).Return(u, nil)
|
||||
bMock.EXPECT().GetBook(b.ID).Return(b, nil)
|
||||
uMock.EXPECT().UpdateUser(u).Return(nil)
|
||||
bMock.EXPECT().UpdateBook(b).Return(nil)
|
||||
err := uc.Borrow(u, b)
|
||||
assert.Nil(t, err)
|
||||
})
|
||||
}
|
||||
|
||||
func Test_Return(t *testing.T) {
|
||||
controller := gomock.NewController(t)
|
||||
defer controller.Finish()
|
||||
uMock := umock.NewMockUseCase(controller)
|
||||
bMock := bmock.NewMockUseCase(controller)
|
||||
uc := NewService(uMock, bMock)
|
||||
t.Run("book not found", func(t *testing.T) {
|
||||
b := &entity.Book{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
bMock.EXPECT().GetBook(b.ID).Return(nil, entity.ErrNotFound)
|
||||
err := uc.Return(b)
|
||||
assert.Equal(t, entity.ErrNotFound, err)
|
||||
})
|
||||
t.Run("book not borrowed", func(t *testing.T) {
|
||||
u := &entity.User{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
b := &entity.Book{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
bMock.EXPECT().GetBook(b.ID).Return(b, nil)
|
||||
uMock.EXPECT().ListUsers().Return([]*entity.User{u}, nil)
|
||||
err := uc.Return(b)
|
||||
assert.Equal(t, entity.ErrBookNotBorrowed, err)
|
||||
})
|
||||
t.Run("success", func(t *testing.T) {
|
||||
u := &entity.User{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
b := &entity.Book{
|
||||
ID: entity.NewID(),
|
||||
}
|
||||
u.AddBook(b.ID)
|
||||
bMock.EXPECT().GetBook(b.ID).Return(b, nil)
|
||||
uMock.EXPECT().GetUser(u.ID).Return(u, nil)
|
||||
uMock.EXPECT().ListUsers().Return([]*entity.User{u}, nil)
|
||||
uMock.EXPECT().UpdateUser(u).Return(nil)
|
||||
bMock.EXPECT().UpdateBook(b).Return(nil)
|
||||
err := uc.Return(b)
|
||||
assert.Nil(t, err)
|
||||
})
|
||||
}
|
||||
@@ -0,0 +1,35 @@
|
||||
package user
|
||||
|
||||
import (
|
||||
"github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
)
|
||||
|
||||
//Reader interface
|
||||
type Reader interface {
|
||||
Get(id entity.ID) (*entity.User, error)
|
||||
Search(query string) ([]*entity.User, error)
|
||||
List() ([]*entity.User, error)
|
||||
}
|
||||
|
||||
//Writer user writer
|
||||
type Writer interface {
|
||||
Create(e *entity.User) (entity.ID, error)
|
||||
Update(e *entity.User) error
|
||||
Delete(id entity.ID) error
|
||||
}
|
||||
|
||||
//Repository interface
|
||||
type Repository interface {
|
||||
Reader
|
||||
Writer
|
||||
}
|
||||
|
||||
//UseCase interface
|
||||
type UseCase interface {
|
||||
GetUser(id entity.ID) (*entity.User, error)
|
||||
SearchUsers(query string) ([]*entity.User, error)
|
||||
ListUsers() ([]*entity.User, error)
|
||||
CreateUser(email, password, firstName, lastName string) (entity.ID, error)
|
||||
UpdateUser(e *entity.User) error
|
||||
DeleteUser(id entity.ID) error
|
||||
}
|
||||
@@ -0,0 +1,367 @@
|
||||
// Code generated by MockGen. DO NOT EDIT.
|
||||
// Source: usecase/user/interface.go
|
||||
|
||||
// Package mock is a generated GoMock package.
|
||||
package mock
|
||||
|
||||
import (
|
||||
entity "github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
gomock "github.com/golang/mock/gomock"
|
||||
reflect "reflect"
|
||||
)
|
||||
|
||||
// MockReader is a mock of Reader interface
|
||||
type MockReader struct {
|
||||
ctrl *gomock.Controller
|
||||
recorder *MockReaderMockRecorder
|
||||
}
|
||||
|
||||
// MockReaderMockRecorder is the mock recorder for MockReader
|
||||
type MockReaderMockRecorder struct {
|
||||
mock *MockReader
|
||||
}
|
||||
|
||||
// NewMockReader creates a new mock instance
|
||||
func NewMockReader(ctrl *gomock.Controller) *MockReader {
|
||||
mock := &MockReader{ctrl: ctrl}
|
||||
mock.recorder = &MockReaderMockRecorder{mock}
|
||||
return mock
|
||||
}
|
||||
|
||||
// EXPECT returns an object that allows the caller to indicate expected use
|
||||
func (m *MockReader) EXPECT() *MockReaderMockRecorder {
|
||||
return m.recorder
|
||||
}
|
||||
|
||||
// Get mocks base method
|
||||
func (m *MockReader) Get(id entity.ID) (*entity.User, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Get", id)
|
||||
ret0, _ := ret[0].(*entity.User)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Get indicates an expected call of Get
|
||||
func (mr *MockReaderMockRecorder) Get(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*MockReader)(nil).Get), id)
|
||||
}
|
||||
|
||||
// Search mocks base method
|
||||
func (m *MockReader) Search(query string) ([]*entity.User, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Search", query)
|
||||
ret0, _ := ret[0].([]*entity.User)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Search indicates an expected call of Search
|
||||
func (mr *MockReaderMockRecorder) Search(query interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Search", reflect.TypeOf((*MockReader)(nil).Search), query)
|
||||
}
|
||||
|
||||
// List mocks base method
|
||||
func (m *MockReader) List() ([]*entity.User, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "List")
|
||||
ret0, _ := ret[0].([]*entity.User)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// List indicates an expected call of List
|
||||
func (mr *MockReaderMockRecorder) List() *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*MockReader)(nil).List))
|
||||
}
|
||||
|
||||
// MockWriter is a mock of Writer interface
|
||||
type MockWriter struct {
|
||||
ctrl *gomock.Controller
|
||||
recorder *MockWriterMockRecorder
|
||||
}
|
||||
|
||||
// MockWriterMockRecorder is the mock recorder for MockWriter
|
||||
type MockWriterMockRecorder struct {
|
||||
mock *MockWriter
|
||||
}
|
||||
|
||||
// NewMockWriter creates a new mock instance
|
||||
func NewMockWriter(ctrl *gomock.Controller) *MockWriter {
|
||||
mock := &MockWriter{ctrl: ctrl}
|
||||
mock.recorder = &MockWriterMockRecorder{mock}
|
||||
return mock
|
||||
}
|
||||
|
||||
// EXPECT returns an object that allows the caller to indicate expected use
|
||||
func (m *MockWriter) EXPECT() *MockWriterMockRecorder {
|
||||
return m.recorder
|
||||
}
|
||||
|
||||
// Create mocks base method
|
||||
func (m *MockWriter) Create(e *entity.User) (entity.ID, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Create", e)
|
||||
ret0, _ := ret[0].(entity.ID)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Create indicates an expected call of Create
|
||||
func (mr *MockWriterMockRecorder) Create(e interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*MockWriter)(nil).Create), e)
|
||||
}
|
||||
|
||||
// Update mocks base method
|
||||
func (m *MockWriter) Update(e *entity.User) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Update", e)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// Update indicates an expected call of Update
|
||||
func (mr *MockWriterMockRecorder) Update(e interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*MockWriter)(nil).Update), e)
|
||||
}
|
||||
|
||||
// Delete mocks base method
|
||||
func (m *MockWriter) Delete(id entity.ID) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Delete", id)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// Delete indicates an expected call of Delete
|
||||
func (mr *MockWriterMockRecorder) Delete(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockWriter)(nil).Delete), id)
|
||||
}
|
||||
|
||||
// MockRepository is a mock of Repository interface
|
||||
type MockRepository struct {
|
||||
ctrl *gomock.Controller
|
||||
recorder *MockRepositoryMockRecorder
|
||||
}
|
||||
|
||||
// MockRepositoryMockRecorder is the mock recorder for MockRepository
|
||||
type MockRepositoryMockRecorder struct {
|
||||
mock *MockRepository
|
||||
}
|
||||
|
||||
// NewMockRepository creates a new mock instance
|
||||
func NewMockRepository(ctrl *gomock.Controller) *MockRepository {
|
||||
mock := &MockRepository{ctrl: ctrl}
|
||||
mock.recorder = &MockRepositoryMockRecorder{mock}
|
||||
return mock
|
||||
}
|
||||
|
||||
// EXPECT returns an object that allows the caller to indicate expected use
|
||||
func (m *MockRepository) EXPECT() *MockRepositoryMockRecorder {
|
||||
return m.recorder
|
||||
}
|
||||
|
||||
// Get mocks base method
|
||||
func (m *MockRepository) Get(id entity.ID) (*entity.User, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Get", id)
|
||||
ret0, _ := ret[0].(*entity.User)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Get indicates an expected call of Get
|
||||
func (mr *MockRepositoryMockRecorder) Get(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*MockRepository)(nil).Get), id)
|
||||
}
|
||||
|
||||
// Search mocks base method
|
||||
func (m *MockRepository) Search(query string) ([]*entity.User, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Search", query)
|
||||
ret0, _ := ret[0].([]*entity.User)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Search indicates an expected call of Search
|
||||
func (mr *MockRepositoryMockRecorder) Search(query interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Search", reflect.TypeOf((*MockRepository)(nil).Search), query)
|
||||
}
|
||||
|
||||
// List mocks base method
|
||||
func (m *MockRepository) List() ([]*entity.User, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "List")
|
||||
ret0, _ := ret[0].([]*entity.User)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// List indicates an expected call of List
|
||||
func (mr *MockRepositoryMockRecorder) List() *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*MockRepository)(nil).List))
|
||||
}
|
||||
|
||||
// Create mocks base method
|
||||
func (m *MockRepository) Create(e *entity.User) (entity.ID, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Create", e)
|
||||
ret0, _ := ret[0].(entity.ID)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// Create indicates an expected call of Create
|
||||
func (mr *MockRepositoryMockRecorder) Create(e interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*MockRepository)(nil).Create), e)
|
||||
}
|
||||
|
||||
// Update mocks base method
|
||||
func (m *MockRepository) Update(e *entity.User) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Update", e)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// Update indicates an expected call of Update
|
||||
func (mr *MockRepositoryMockRecorder) Update(e interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*MockRepository)(nil).Update), e)
|
||||
}
|
||||
|
||||
// Delete mocks base method
|
||||
func (m *MockRepository) Delete(id entity.ID) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "Delete", id)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// Delete indicates an expected call of Delete
|
||||
func (mr *MockRepositoryMockRecorder) Delete(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockRepository)(nil).Delete), id)
|
||||
}
|
||||
|
||||
// MockUseCase is a mock of UseCase interface
|
||||
type MockUseCase struct {
|
||||
ctrl *gomock.Controller
|
||||
recorder *MockUseCaseMockRecorder
|
||||
}
|
||||
|
||||
// MockUseCaseMockRecorder is the mock recorder for MockUseCase
|
||||
type MockUseCaseMockRecorder struct {
|
||||
mock *MockUseCase
|
||||
}
|
||||
|
||||
// NewMockUseCase creates a new mock instance
|
||||
func NewMockUseCase(ctrl *gomock.Controller) *MockUseCase {
|
||||
mock := &MockUseCase{ctrl: ctrl}
|
||||
mock.recorder = &MockUseCaseMockRecorder{mock}
|
||||
return mock
|
||||
}
|
||||
|
||||
// EXPECT returns an object that allows the caller to indicate expected use
|
||||
func (m *MockUseCase) EXPECT() *MockUseCaseMockRecorder {
|
||||
return m.recorder
|
||||
}
|
||||
|
||||
// GetUser mocks base method
|
||||
func (m *MockUseCase) GetUser(id entity.ID) (*entity.User, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "GetUser", id)
|
||||
ret0, _ := ret[0].(*entity.User)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// GetUser indicates an expected call of GetUser
|
||||
func (mr *MockUseCaseMockRecorder) GetUser(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "GetUser", reflect.TypeOf((*MockUseCase)(nil).GetUser), id)
|
||||
}
|
||||
|
||||
// SearchUsers mocks base method
|
||||
func (m *MockUseCase) SearchUsers(query string) ([]*entity.User, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "SearchUsers", query)
|
||||
ret0, _ := ret[0].([]*entity.User)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// SearchUsers indicates an expected call of SearchUsers
|
||||
func (mr *MockUseCaseMockRecorder) SearchUsers(query interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "SearchUsers", reflect.TypeOf((*MockUseCase)(nil).SearchUsers), query)
|
||||
}
|
||||
|
||||
// ListUsers mocks base method
|
||||
func (m *MockUseCase) ListUsers() ([]*entity.User, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "ListUsers")
|
||||
ret0, _ := ret[0].([]*entity.User)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// ListUsers indicates an expected call of ListUsers
|
||||
func (mr *MockUseCaseMockRecorder) ListUsers() *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "ListUsers", reflect.TypeOf((*MockUseCase)(nil).ListUsers))
|
||||
}
|
||||
|
||||
// CreateUser mocks base method
|
||||
func (m *MockUseCase) CreateUser(email, password, firstName, lastName string) (entity.ID, error) {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "CreateUser", email, password, firstName, lastName)
|
||||
ret0, _ := ret[0].(entity.ID)
|
||||
ret1, _ := ret[1].(error)
|
||||
return ret0, ret1
|
||||
}
|
||||
|
||||
// CreateUser indicates an expected call of CreateUser
|
||||
func (mr *MockUseCaseMockRecorder) CreateUser(email, password, firstName, lastName interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "CreateUser", reflect.TypeOf((*MockUseCase)(nil).CreateUser), email, password, firstName, lastName)
|
||||
}
|
||||
|
||||
// UpdateUser mocks base method
|
||||
func (m *MockUseCase) UpdateUser(e *entity.User) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "UpdateUser", e)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// UpdateUser indicates an expected call of UpdateUser
|
||||
func (mr *MockUseCaseMockRecorder) UpdateUser(e interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "UpdateUser", reflect.TypeOf((*MockUseCase)(nil).UpdateUser), e)
|
||||
}
|
||||
|
||||
// DeleteUser mocks base method
|
||||
func (m *MockUseCase) DeleteUser(id entity.ID) error {
|
||||
m.ctrl.T.Helper()
|
||||
ret := m.ctrl.Call(m, "DeleteUser", id)
|
||||
ret0, _ := ret[0].(error)
|
||||
return ret0
|
||||
}
|
||||
|
||||
// DeleteUser indicates an expected call of DeleteUser
|
||||
func (mr *MockUseCaseMockRecorder) DeleteUser(id interface{}) *gomock.Call {
|
||||
mr.mock.ctrl.T.Helper()
|
||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "DeleteUser", reflect.TypeOf((*MockUseCase)(nil).DeleteUser), id)
|
||||
}
|
||||
@@ -0,0 +1,69 @@
|
||||
package user
|
||||
|
||||
import (
|
||||
"strings"
|
||||
"time"
|
||||
|
||||
"github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
)
|
||||
|
||||
//Service interface
|
||||
type Service struct {
|
||||
repo Repository
|
||||
}
|
||||
|
||||
//NewService create new use case
|
||||
func NewService(r Repository) *Service {
|
||||
return &Service{
|
||||
repo: r,
|
||||
}
|
||||
}
|
||||
|
||||
//CreateUser Create an user
|
||||
func (s *Service) CreateUser(email, password, firstName, lastName string) (entity.ID, error) {
|
||||
e, err := entity.NewUser(email, password, firstName, lastName)
|
||||
if err != nil {
|
||||
return e.ID, err
|
||||
}
|
||||
return s.repo.Create(e)
|
||||
}
|
||||
|
||||
//GetUser Get an user
|
||||
func (s *Service) GetUser(id entity.ID) (*entity.User, error) {
|
||||
return s.repo.Get(id)
|
||||
}
|
||||
|
||||
//SearchUsers Search users
|
||||
func (s *Service) SearchUsers(query string) ([]*entity.User, error) {
|
||||
return s.repo.Search(strings.ToLower(query))
|
||||
}
|
||||
|
||||
//ListUsers List users
|
||||
func (s *Service) ListUsers() ([]*entity.User, error) {
|
||||
return s.repo.List()
|
||||
}
|
||||
|
||||
//DeleteUser Delete an user
|
||||
func (s *Service) DeleteUser(id entity.ID) error {
|
||||
u, err := s.GetUser(id)
|
||||
if u == nil {
|
||||
return entity.ErrNotFound
|
||||
}
|
||||
if err != nil {
|
||||
return err
|
||||
}
|
||||
if len(u.Books) > 0 {
|
||||
return entity.ErrCannotBeDeleted
|
||||
}
|
||||
return s.repo.Delete(id)
|
||||
}
|
||||
|
||||
//UpdateUser Update an user
|
||||
func (s *Service) UpdateUser(e *entity.User) error {
|
||||
err := e.Validate()
|
||||
if err != nil {
|
||||
return entity.ErrInvalidEntity
|
||||
}
|
||||
e.UpdatedAt = time.Now()
|
||||
return s.repo.Update(e)
|
||||
}
|
||||
@@ -0,0 +1,107 @@
|
||||
package user
|
||||
|
||||
import (
|
||||
"testing"
|
||||
"time"
|
||||
|
||||
"github.com/eminetto/clean-architecture-go-v2/infra/repository"
|
||||
|
||||
"github.com/eminetto/clean-architecture-go-v2/entity"
|
||||
|
||||
"github.com/stretchr/testify/assert"
|
||||
)
|
||||
|
||||
func newFixtureUser() *entity.User {
|
||||
return &entity.User{
|
||||
ID: entity.NewID(),
|
||||
Email: "[email protected]",
|
||||
Password: "123456",
|
||||
FirstName: "Ozzy",
|
||||
LastName: "Osbourne",
|
||||
CreatedAt: time.Now(),
|
||||
}
|
||||
}
|
||||
|
||||
func Test_Create(t *testing.T) {
|
||||
repo := repository.NewUserInmem()
|
||||
m := NewService(repo)
|
||||
u := newFixtureUser()
|
||||
_, err := m.CreateUser(u.Email, u.Password, u.FirstName, u.LastName)
|
||||
assert.Nil(t, err)
|
||||
assert.False(t, u.CreatedAt.IsZero())
|
||||
assert.True(t, u.UpdatedAt.IsZero())
|
||||
}
|
||||
|
||||
func Test_SearchAndFind(t *testing.T) {
|
||||
repo := repository.NewUserInmem()
|
||||
m := NewService(repo)
|
||||
u1 := newFixtureUser()
|
||||
u2 := newFixtureUser()
|
||||
u2.FirstName = "Lemmy"
|
||||
|
||||
uID, _ := m.CreateUser(u1.Email, u1.Password, u1.FirstName, u1.LastName)
|
||||
_, _ = m.CreateUser(u2.Email, u2.Password, u2.FirstName, u2.LastName)
|
||||
|
||||
t.Run("search", func(t *testing.T) {
|
||||
c, err := m.SearchUsers("ozzy")
|
||||
assert.Nil(t, err)
|
||||
assert.Equal(t, 1, len(c))
|
||||
assert.Equal(t, "Osbourne", c[0].LastName)
|
||||
|
||||
c, err = m.SearchUsers("dio")
|
||||
assert.Equal(t, entity.ErrNotFound, err)
|
||||
assert.Nil(t, c)
|
||||
})
|
||||
t.Run("list all", func(t *testing.T) {
|
||||
all, err := m.ListUsers()
|
||||
assert.Nil(t, err)
|
||||
assert.Equal(t, 2, len(all))
|
||||
})
|
||||
|
||||
t.Run("get", func(t *testing.T) {
|
||||
saved, err := m.GetUser(uID)
|
||||
assert.Nil(t, err)
|
||||
assert.Equal(t, u1.FirstName, saved.FirstName)
|
||||
})
|
||||
}
|
||||
|
||||
func Test_Update(t *testing.T) {
|
||||
repo := repository.NewUserInmem()
|
||||
m := NewService(repo)
|
||||
u := newFixtureUser()
|
||||
id, err := m.CreateUser(u.Email, u.Password, u.FirstName, u.LastName)
|
||||
assert.Nil(t, err)
|
||||
saved, _ := m.GetUser(id)
|
||||
saved.FirstName = "Dio"
|
||||
saved.Books = append(saved.Books, entity.NewID())
|
||||
assert.Nil(t, m.UpdateUser(saved))
|
||||
updated, err := m.GetUser(id)
|
||||
assert.Nil(t, err)
|
||||
assert.Equal(t, "Dio", updated.FirstName)
|
||||
assert.False(t, updated.UpdatedAt.IsZero())
|
||||
assert.Equal(t, 1, len(updated.Books))
|
||||
}
|
||||
|
||||
func TestDelete(t *testing.T) {
|
||||
repo := repository.NewUserInmem()
|
||||
m := NewService(repo)
|
||||
u1 := newFixtureUser()
|
||||
u2 := newFixtureUser()
|
||||
u2ID, _ := m.CreateUser(u2.Email, u2.Password, u2.FirstName, u2.LastName)
|
||||
|
||||
err := m.DeleteUser(u1.ID)
|
||||
assert.Equal(t, entity.ErrNotFound, err)
|
||||
|
||||
err = m.DeleteUser(u2ID)
|
||||
assert.Nil(t, err)
|
||||
_, err = m.GetUser(u2ID)
|
||||
assert.Equal(t, entity.ErrNotFound, err)
|
||||
|
||||
u3 := newFixtureUser()
|
||||
id, _ := m.CreateUser(u3.Email, u3.Password, u3.FirstName, u3.LastName)
|
||||
saved, _ := m.GetUser(id)
|
||||
saved.Books = []entity.ID{entity.NewID()}
|
||||
_ = m.UpdateUser(saved)
|
||||
err = m.DeleteUser(id)
|
||||
assert.Equal(t, entity.ErrCannotBeDeleted, err)
|
||||
}
|
||||
Reference in New Issue
Block a user