@@ -34,7 +34,7 @@ build-mocks:
|
|||||||
@go install github.com/golang/mock/mockgen
|
@go install github.com/golang/mock/mockgen
|
||||||
@~/go/bin/mockgen -source=domain/entity/book/interface.go -destination=domain/entity/book/mock/book.go -package=mock
|
@~/go/bin/mockgen -source=domain/entity/book/interface.go -destination=domain/entity/book/mock/book.go -package=mock
|
||||||
@~/go/bin/mockgen -source=domain/entity/user/interface.go -destination=domain/entity/user/mock/user.go -package=mock
|
@~/go/bin/mockgen -source=domain/entity/user/interface.go -destination=domain/entity/user/mock/user.go -package=mock
|
||||||
@~/go/bin/mockgen -source=domain/loan/interface.go -destination=domain/loan/mock/loan.go -package=mock
|
@~/go/bin/mockgen -source=domain/usecase/loan/interface.go -destination=domain/usecase/loan/mock/loan.go -package=mock
|
||||||
|
|
||||||
test:
|
test:
|
||||||
go test -tags testing ./...
|
go test -tags testing ./...
|
||||||
|
|||||||
+14
-14
@@ -17,7 +17,7 @@ import (
|
|||||||
"github.com/gorilla/mux"
|
"github.com/gorilla/mux"
|
||||||
)
|
)
|
||||||
|
|
||||||
func listBooks(service book.UseCase) http.Handler {
|
func listBooks(manager book.Manager) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
errorMessage := "Error reading books"
|
errorMessage := "Error reading books"
|
||||||
var data []*book.Book
|
var data []*book.Book
|
||||||
@@ -25,9 +25,9 @@ func listBooks(service book.UseCase) http.Handler {
|
|||||||
title := r.URL.Query().Get("title")
|
title := r.URL.Query().Get("title")
|
||||||
switch {
|
switch {
|
||||||
case title == "":
|
case title == "":
|
||||||
data, err = service.List()
|
data, err = manager.List()
|
||||||
default:
|
default:
|
||||||
data, err = service.Search(title)
|
data, err = manager.Search(title)
|
||||||
}
|
}
|
||||||
w.Header().Set("Content-Type", "application/json")
|
w.Header().Set("Content-Type", "application/json")
|
||||||
if err != nil && err != domain.ErrNotFound {
|
if err != nil && err != domain.ErrNotFound {
|
||||||
@@ -58,7 +58,7 @@ func listBooks(service book.UseCase) http.Handler {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func createBook(service book.UseCase) http.Handler {
|
func createBook(manager book.Manager) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
errorMessage := "Error adding book"
|
errorMessage := "Error adding book"
|
||||||
var input struct {
|
var input struct {
|
||||||
@@ -82,7 +82,7 @@ func createBook(service book.UseCase) http.Handler {
|
|||||||
Quantity: input.Quantity,
|
Quantity: input.Quantity,
|
||||||
CreatedAt: time.Now(),
|
CreatedAt: time.Now(),
|
||||||
}
|
}
|
||||||
b.ID, err = service.Create(b)
|
b.ID, err = manager.Create(b)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println(err.Error())
|
log.Println(err.Error())
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
@@ -107,7 +107,7 @@ func createBook(service book.UseCase) http.Handler {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func getBook(service book.UseCase) http.Handler {
|
func getBook(manager book.Manager) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
errorMessage := "Error reading book"
|
errorMessage := "Error reading book"
|
||||||
vars := mux.Vars(r)
|
vars := mux.Vars(r)
|
||||||
@@ -117,7 +117,7 @@ func getBook(service book.UseCase) http.Handler {
|
|||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
data, err := service.Get(id)
|
data, err := manager.Get(id)
|
||||||
if err != nil && err != domain.ErrNotFound {
|
if err != nil && err != domain.ErrNotFound {
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
@@ -143,7 +143,7 @@ func getBook(service book.UseCase) http.Handler {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func deleteBook(service book.UseCase) http.Handler {
|
func deleteBook(manager book.Manager) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
errorMessage := "Error removing bookmark"
|
errorMessage := "Error removing bookmark"
|
||||||
vars := mux.Vars(r)
|
vars := mux.Vars(r)
|
||||||
@@ -153,7 +153,7 @@ func deleteBook(service book.UseCase) http.Handler {
|
|||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
err = service.Delete(id)
|
err = manager.Delete(id)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
@@ -163,20 +163,20 @@ func deleteBook(service book.UseCase) http.Handler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//MakeBookHandlers make url handlers
|
//MakeBookHandlers make url handlers
|
||||||
func MakeBookHandlers(r *mux.Router, n negroni.Negroni, service book.UseCase) {
|
func MakeBookHandlers(r *mux.Router, n negroni.Negroni, manager book.Manager) {
|
||||||
r.Handle("/v1/book", n.With(
|
r.Handle("/v1/book", n.With(
|
||||||
negroni.Wrap(listBooks(service)),
|
negroni.Wrap(listBooks(manager)),
|
||||||
)).Methods("GET", "OPTIONS").Name("listBooks")
|
)).Methods("GET", "OPTIONS").Name("listBooks")
|
||||||
|
|
||||||
r.Handle("/v1/book", n.With(
|
r.Handle("/v1/book", n.With(
|
||||||
negroni.Wrap(createBook(service)),
|
negroni.Wrap(createBook(manager)),
|
||||||
)).Methods("POST", "OPTIONS").Name("createBook")
|
)).Methods("POST", "OPTIONS").Name("createBook")
|
||||||
|
|
||||||
r.Handle("/v1/book/{id}", n.With(
|
r.Handle("/v1/book/{id}", n.With(
|
||||||
negroni.Wrap(getBook(service)),
|
negroni.Wrap(getBook(manager)),
|
||||||
)).Methods("GET", "OPTIONS").Name("getBook")
|
)).Methods("GET", "OPTIONS").Name("getBook")
|
||||||
|
|
||||||
r.Handle("/v1/book/{id}", n.With(
|
r.Handle("/v1/book/{id}", n.With(
|
||||||
negroni.Wrap(deleteBook(service)),
|
negroni.Wrap(deleteBook(manager)),
|
||||||
)).Methods("DELETE", "OPTIONS").Name("deleteBook")
|
)).Methods("DELETE", "OPTIONS").Name("deleteBook")
|
||||||
}
|
}
|
||||||
|
|||||||
+22
-22
@@ -23,18 +23,18 @@ import (
|
|||||||
func Test_listBooks(t *testing.T) {
|
func Test_listBooks(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
manager := mock.NewMockManager(controller)
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
n := negroni.New()
|
n := negroni.New()
|
||||||
MakeBookHandlers(r, *n, service)
|
MakeBookHandlers(r, *n, manager)
|
||||||
path, err := r.GetRoute("listBooks").GetPathTemplate()
|
path, err := r.GetRoute("listBooks").GetPathTemplate()
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, "/v1/book", path)
|
assert.Equal(t, "/v1/book", path)
|
||||||
b := book.NewFixtureBook()
|
b := book.NewFixtureBook()
|
||||||
service.EXPECT().
|
manager.EXPECT().
|
||||||
List().
|
List().
|
||||||
Return([]*book.Book{b}, nil)
|
Return([]*book.Book{b}, nil)
|
||||||
ts := httptest.NewServer(listBooks(service))
|
ts := httptest.NewServer(listBooks(manager))
|
||||||
defer ts.Close()
|
defer ts.Close()
|
||||||
res, err := http.Get(ts.URL)
|
res, err := http.Get(ts.URL)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
@@ -44,10 +44,10 @@ func Test_listBooks(t *testing.T) {
|
|||||||
func Test_listBooks_NotFound(t *testing.T) {
|
func Test_listBooks_NotFound(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
manager := mock.NewMockManager(controller)
|
||||||
ts := httptest.NewServer(listBooks(service))
|
ts := httptest.NewServer(listBooks(manager))
|
||||||
defer ts.Close()
|
defer ts.Close()
|
||||||
service.EXPECT().
|
manager.EXPECT().
|
||||||
Search("book of books").
|
Search("book of books").
|
||||||
Return(nil, domain.ErrNotFound)
|
Return(nil, domain.ErrNotFound)
|
||||||
res, err := http.Get(ts.URL + "?title=book+of+books")
|
res, err := http.Get(ts.URL + "?title=book+of+books")
|
||||||
@@ -58,12 +58,12 @@ func Test_listBooks_NotFound(t *testing.T) {
|
|||||||
func Test_listBooks_Search(t *testing.T) {
|
func Test_listBooks_Search(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
manager := mock.NewMockManager(controller)
|
||||||
b := book.NewFixtureBook()
|
b := book.NewFixtureBook()
|
||||||
service.EXPECT().
|
manager.EXPECT().
|
||||||
Search("ozzy").
|
Search("ozzy").
|
||||||
Return([]*book.Book{b}, nil)
|
Return([]*book.Book{b}, nil)
|
||||||
ts := httptest.NewServer(listBooks(service))
|
ts := httptest.NewServer(listBooks(manager))
|
||||||
defer ts.Close()
|
defer ts.Close()
|
||||||
res, err := http.Get(ts.URL + "?title=ozzy")
|
res, err := http.Get(ts.URL + "?title=ozzy")
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
@@ -73,18 +73,18 @@ func Test_listBooks_Search(t *testing.T) {
|
|||||||
func Test_createBook(t *testing.T) {
|
func Test_createBook(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
manager := mock.NewMockManager(controller)
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
n := negroni.New()
|
n := negroni.New()
|
||||||
MakeBookHandlers(r, *n, service)
|
MakeBookHandlers(r, *n, manager)
|
||||||
path, err := r.GetRoute("createBook").GetPathTemplate()
|
path, err := r.GetRoute("createBook").GetPathTemplate()
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, "/v1/book", path)
|
assert.Equal(t, "/v1/book", path)
|
||||||
|
|
||||||
service.EXPECT().
|
manager.EXPECT().
|
||||||
Create(gomock.Any()).
|
Create(gomock.Any()).
|
||||||
Return(entity.NewID(), nil)
|
Return(entity.NewID(), nil)
|
||||||
h := createBook(service)
|
h := createBook(manager)
|
||||||
|
|
||||||
ts := httptest.NewServer(h)
|
ts := httptest.NewServer(h)
|
||||||
defer ts.Close()
|
defer ts.Close()
|
||||||
@@ -105,18 +105,18 @@ func Test_createBook(t *testing.T) {
|
|||||||
func Test_getBook(t *testing.T) {
|
func Test_getBook(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
manager := mock.NewMockManager(controller)
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
n := negroni.New()
|
n := negroni.New()
|
||||||
MakeBookHandlers(r, *n, service)
|
MakeBookHandlers(r, *n, manager)
|
||||||
path, err := r.GetRoute("getBook").GetPathTemplate()
|
path, err := r.GetRoute("getBook").GetPathTemplate()
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, "/v1/book/{id}", path)
|
assert.Equal(t, "/v1/book/{id}", path)
|
||||||
b := book.NewFixtureBook()
|
b := book.NewFixtureBook()
|
||||||
service.EXPECT().
|
manager.EXPECT().
|
||||||
Get(b.ID).
|
Get(b.ID).
|
||||||
Return(b, nil)
|
Return(b, nil)
|
||||||
handler := getBook(service)
|
handler := getBook(manager)
|
||||||
r.Handle("/v1/book/{id}", handler)
|
r.Handle("/v1/book/{id}", handler)
|
||||||
ts := httptest.NewServer(r)
|
ts := httptest.NewServer(r)
|
||||||
defer ts.Close()
|
defer ts.Close()
|
||||||
@@ -132,16 +132,16 @@ func Test_getBook(t *testing.T) {
|
|||||||
func Test_deleteBook(t *testing.T) {
|
func Test_deleteBook(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
manager := mock.NewMockManager(controller)
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
n := negroni.New()
|
n := negroni.New()
|
||||||
MakeBookHandlers(r, *n, service)
|
MakeBookHandlers(r, *n, manager)
|
||||||
path, err := r.GetRoute("deleteBook").GetPathTemplate()
|
path, err := r.GetRoute("deleteBook").GetPathTemplate()
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, "/v1/book/{id}", path)
|
assert.Equal(t, "/v1/book/{id}", path)
|
||||||
b := book.NewFixtureBook()
|
b := book.NewFixtureBook()
|
||||||
service.EXPECT().Delete(b.ID).Return(nil)
|
manager.EXPECT().Delete(b.ID).Return(nil)
|
||||||
handler := deleteBook(service)
|
handler := deleteBook(manager)
|
||||||
req, _ := http.NewRequest("DELETE", "/v1/bookmark/"+b.ID.String(), nil)
|
req, _ := http.NewRequest("DELETE", "/v1/bookmark/"+b.ID.String(), nil)
|
||||||
r.Handle("/v1/bookmark/{id}", handler).Methods("DELETE", "OPTIONS")
|
r.Handle("/v1/bookmark/{id}", handler).Methods("DELETE", "OPTIONS")
|
||||||
rr := httptest.NewRecorder()
|
rr := httptest.NewRecorder()
|
||||||
|
|||||||
+11
-11
@@ -6,7 +6,7 @@ import (
|
|||||||
|
|
||||||
"github.com/eminetto/clean-architecture-go-v2/domain/entity/user"
|
"github.com/eminetto/clean-architecture-go-v2/domain/entity/user"
|
||||||
|
|
||||||
"github.com/eminetto/clean-architecture-go-v2/domain/loan"
|
"github.com/eminetto/clean-architecture-go-v2/domain/usecase/loan"
|
||||||
|
|
||||||
"github.com/eminetto/clean-architecture-go-v2/domain"
|
"github.com/eminetto/clean-architecture-go-v2/domain"
|
||||||
|
|
||||||
@@ -17,7 +17,7 @@ import (
|
|||||||
"github.com/gorilla/mux"
|
"github.com/gorilla/mux"
|
||||||
)
|
)
|
||||||
|
|
||||||
func borrowBook(bService book.UseCase, uService user.UseCase, loanService loan.UseCase) http.Handler {
|
func borrowBook(bManager book.Manager, uManager user.Manager, loanUseCase loan.UseCase) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
errorMessage := "Error borrowing book"
|
errorMessage := "Error borrowing book"
|
||||||
vars := mux.Vars(r)
|
vars := mux.Vars(r)
|
||||||
@@ -27,7 +27,7 @@ func borrowBook(bService book.UseCase, uService user.UseCase, loanService loan.U
|
|||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
b, err := bService.Get(bID)
|
b, err := bManager.Get(bID)
|
||||||
if err != nil && err != domain.ErrNotFound {
|
if err != nil && err != domain.ErrNotFound {
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
@@ -44,7 +44,7 @@ func borrowBook(bService book.UseCase, uService user.UseCase, loanService loan.U
|
|||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
u, err := uService.Get(uID)
|
u, err := uManager.Get(uID)
|
||||||
if err != nil && err != domain.ErrNotFound {
|
if err != nil && err != domain.ErrNotFound {
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
@@ -55,7 +55,7 @@ func borrowBook(bService book.UseCase, uService user.UseCase, loanService loan.U
|
|||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
err = loanService.Borrow(u, b)
|
err = loanUseCase.Borrow(u, b)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
fmt.Println(err)
|
fmt.Println(err)
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
@@ -66,7 +66,7 @@ func borrowBook(bService book.UseCase, uService user.UseCase, loanService loan.U
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func returnBook(bService book.UseCase, loanService loan.UseCase) http.Handler {
|
func returnBook(bManager book.Manager, loanUseCase loan.UseCase) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
errorMessage := "Error returning book"
|
errorMessage := "Error returning book"
|
||||||
vars := mux.Vars(r)
|
vars := mux.Vars(r)
|
||||||
@@ -76,7 +76,7 @@ func returnBook(bService book.UseCase, loanService loan.UseCase) http.Handler {
|
|||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
b, err := bService.Get(bID)
|
b, err := bManager.Get(bID)
|
||||||
if err != nil && err != domain.ErrNotFound {
|
if err != nil && err != domain.ErrNotFound {
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
@@ -87,7 +87,7 @@ func returnBook(bService book.UseCase, loanService loan.UseCase) http.Handler {
|
|||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
err = loanService.Return(b)
|
err = loanUseCase.Return(b)
|
||||||
if err != nil && err != domain.ErrNotFound {
|
if err != nil && err != domain.ErrNotFound {
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
@@ -98,12 +98,12 @@ func returnBook(bService book.UseCase, loanService loan.UseCase) http.Handler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//MakeLoanHandlers make url handlers
|
//MakeLoanHandlers make url handlers
|
||||||
func MakeLoanHandlers(r *mux.Router, n negroni.Negroni, bService book.UseCase, uService user.UseCase, loanService loan.UseCase) {
|
func MakeLoanHandlers(r *mux.Router, n negroni.Negroni, bManager book.Manager, uManager user.Manager, loanUseCase loan.UseCase) {
|
||||||
r.Handle("/v1/loan/borrow/{book_id}/{user_id}", n.With(
|
r.Handle("/v1/loan/borrow/{book_id}/{user_id}", n.With(
|
||||||
negroni.Wrap(borrowBook(bService, uService, loanService)),
|
negroni.Wrap(borrowBook(bManager, uManager, loanUseCase)),
|
||||||
)).Methods("GET", "OPTIONS").Name("borrowBook")
|
)).Methods("GET", "OPTIONS").Name("borrowBook")
|
||||||
|
|
||||||
r.Handle("/v1/loan/return/{book_id}", n.With(
|
r.Handle("/v1/loan/return/{book_id}", n.With(
|
||||||
negroni.Wrap(returnBook(bService, loanService)),
|
negroni.Wrap(returnBook(bManager, loanUseCase)),
|
||||||
)).Methods("GET", "OPTIONS").Name("returnBook")
|
)).Methods("GET", "OPTIONS").Name("returnBook")
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ import (
|
|||||||
"github.com/codegangsta/negroni"
|
"github.com/codegangsta/negroni"
|
||||||
bmock "github.com/eminetto/clean-architecture-go-v2/domain/entity/book/mock"
|
bmock "github.com/eminetto/clean-architecture-go-v2/domain/entity/book/mock"
|
||||||
umock "github.com/eminetto/clean-architecture-go-v2/domain/entity/user/mock"
|
umock "github.com/eminetto/clean-architecture-go-v2/domain/entity/user/mock"
|
||||||
lmock "github.com/eminetto/clean-architecture-go-v2/domain/loan/mock"
|
lmock "github.com/eminetto/clean-architecture-go-v2/domain/usecase/loan/mock"
|
||||||
"github.com/golang/mock/gomock"
|
"github.com/golang/mock/gomock"
|
||||||
"github.com/gorilla/mux"
|
"github.com/gorilla/mux"
|
||||||
"github.com/stretchr/testify/assert"
|
"github.com/stretchr/testify/assert"
|
||||||
@@ -25,8 +25,8 @@ import (
|
|||||||
func Test_borrowBook(t *testing.T) {
|
func Test_borrowBook(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
uMock := umock.NewMockUseCase(controller)
|
uMock := umock.NewMockManager(controller)
|
||||||
bMock := bmock.NewMockUseCase(controller)
|
bMock := bmock.NewMockManager(controller)
|
||||||
lMock := lmock.NewMockUseCase(controller)
|
lMock := lmock.NewMockUseCase(controller)
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
n := negroni.New()
|
n := negroni.New()
|
||||||
@@ -74,8 +74,8 @@ func Test_borrowBook(t *testing.T) {
|
|||||||
func Test_returnBook(t *testing.T) {
|
func Test_returnBook(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
uMock := umock.NewMockUseCase(controller)
|
uMock := umock.NewMockManager(controller)
|
||||||
bMock := bmock.NewMockUseCase(controller)
|
bMock := bmock.NewMockManager(controller)
|
||||||
lMock := lmock.NewMockUseCase(controller)
|
lMock := lmock.NewMockUseCase(controller)
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
n := negroni.New()
|
n := negroni.New()
|
||||||
|
|||||||
+14
-14
@@ -18,7 +18,7 @@ import (
|
|||||||
"github.com/gorilla/mux"
|
"github.com/gorilla/mux"
|
||||||
)
|
)
|
||||||
|
|
||||||
func listUsers(service user.UseCase) http.Handler {
|
func listUsers(manager user.Manager) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
errorMessage := "Error reading users"
|
errorMessage := "Error reading users"
|
||||||
var data []*user.User
|
var data []*user.User
|
||||||
@@ -26,9 +26,9 @@ func listUsers(service user.UseCase) http.Handler {
|
|||||||
name := r.URL.Query().Get("name")
|
name := r.URL.Query().Get("name")
|
||||||
switch {
|
switch {
|
||||||
case name == "":
|
case name == "":
|
||||||
data, err = service.List()
|
data, err = manager.List()
|
||||||
default:
|
default:
|
||||||
data, err = service.Search(name)
|
data, err = manager.Search(name)
|
||||||
}
|
}
|
||||||
w.Header().Set("Content-Type", "application/json")
|
w.Header().Set("Content-Type", "application/json")
|
||||||
if err != nil && err != domain.ErrNotFound {
|
if err != nil && err != domain.ErrNotFound {
|
||||||
@@ -58,7 +58,7 @@ func listUsers(service user.UseCase) http.Handler {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func createUser(service user.UseCase) http.Handler {
|
func createUser(manager user.Manager) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
errorMessage := "Error adding user"
|
errorMessage := "Error adding user"
|
||||||
var input struct {
|
var input struct {
|
||||||
@@ -83,7 +83,7 @@ func createUser(service user.UseCase) http.Handler {
|
|||||||
LastName: input.LastName,
|
LastName: input.LastName,
|
||||||
CreatedAt: time.Now(),
|
CreatedAt: time.Now(),
|
||||||
}
|
}
|
||||||
u.ID, err = service.Create(u)
|
u.ID, err = manager.Create(u)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Println(err.Error())
|
log.Println(err.Error())
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
@@ -107,7 +107,7 @@ func createUser(service user.UseCase) http.Handler {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func getUser(service user.UseCase) http.Handler {
|
func getUser(manager user.Manager) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
errorMessage := "Error reading user"
|
errorMessage := "Error reading user"
|
||||||
vars := mux.Vars(r)
|
vars := mux.Vars(r)
|
||||||
@@ -117,7 +117,7 @@ func getUser(service user.UseCase) http.Handler {
|
|||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
data, err := service.Get(id)
|
data, err := manager.Get(id)
|
||||||
w.Header().Set("Content-Type", "application/json")
|
w.Header().Set("Content-Type", "application/json")
|
||||||
if err != nil && err != domain.ErrNotFound {
|
if err != nil && err != domain.ErrNotFound {
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
@@ -143,7 +143,7 @@ func getUser(service user.UseCase) http.Handler {
|
|||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
func deleteUser(service user.UseCase) http.Handler {
|
func deleteUser(manager user.Manager) http.Handler {
|
||||||
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
return http.HandlerFunc(func(w http.ResponseWriter, r *http.Request) {
|
||||||
errorMessage := "Error removing user"
|
errorMessage := "Error removing user"
|
||||||
vars := mux.Vars(r)
|
vars := mux.Vars(r)
|
||||||
@@ -153,7 +153,7 @@ func deleteUser(service user.UseCase) http.Handler {
|
|||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
err = service.Delete(id)
|
err = manager.Delete(id)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
w.WriteHeader(http.StatusInternalServerError)
|
w.WriteHeader(http.StatusInternalServerError)
|
||||||
w.Write([]byte(errorMessage))
|
w.Write([]byte(errorMessage))
|
||||||
@@ -163,20 +163,20 @@ func deleteUser(service user.UseCase) http.Handler {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//MakeUserHandlers make url handlers
|
//MakeUserHandlers make url handlers
|
||||||
func MakeUserHandlers(r *mux.Router, n negroni.Negroni, service user.UseCase) {
|
func MakeUserHandlers(r *mux.Router, n negroni.Negroni, manager user.Manager) {
|
||||||
r.Handle("/v1/user", n.With(
|
r.Handle("/v1/user", n.With(
|
||||||
negroni.Wrap(listUsers(service)),
|
negroni.Wrap(listUsers(manager)),
|
||||||
)).Methods("GET", "OPTIONS").Name("listUsers")
|
)).Methods("GET", "OPTIONS").Name("listUsers")
|
||||||
|
|
||||||
r.Handle("/v1/user", n.With(
|
r.Handle("/v1/user", n.With(
|
||||||
negroni.Wrap(createUser(service)),
|
negroni.Wrap(createUser(manager)),
|
||||||
)).Methods("POST", "OPTIONS").Name("createUser")
|
)).Methods("POST", "OPTIONS").Name("createUser")
|
||||||
|
|
||||||
r.Handle("/v1/user/{id}", n.With(
|
r.Handle("/v1/user/{id}", n.With(
|
||||||
negroni.Wrap(getUser(service)),
|
negroni.Wrap(getUser(manager)),
|
||||||
)).Methods("GET", "OPTIONS").Name("getUser")
|
)).Methods("GET", "OPTIONS").Name("getUser")
|
||||||
|
|
||||||
r.Handle("/v1/user/{id}", n.With(
|
r.Handle("/v1/user/{id}", n.With(
|
||||||
negroni.Wrap(deleteUser(service)),
|
negroni.Wrap(deleteUser(manager)),
|
||||||
)).Methods("DELETE", "OPTIONS").Name("deleteUser")
|
)).Methods("DELETE", "OPTIONS").Name("deleteUser")
|
||||||
}
|
}
|
||||||
|
|||||||
+22
-22
@@ -22,18 +22,18 @@ import (
|
|||||||
func Test_listUsers(t *testing.T) {
|
func Test_listUsers(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
m := mock.NewMockManager(controller)
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
n := negroni.New()
|
n := negroni.New()
|
||||||
MakeUserHandlers(r, *n, service)
|
MakeUserHandlers(r, *n, m)
|
||||||
path, err := r.GetRoute("listUsers").GetPathTemplate()
|
path, err := r.GetRoute("listUsers").GetPathTemplate()
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, "/v1/user", path)
|
assert.Equal(t, "/v1/user", path)
|
||||||
u := user.NewFixtureUser()
|
u := user.NewFixtureUser()
|
||||||
service.EXPECT().
|
m.EXPECT().
|
||||||
List().
|
List().
|
||||||
Return([]*user.User{u}, nil)
|
Return([]*user.User{u}, nil)
|
||||||
ts := httptest.NewServer(listUsers(service))
|
ts := httptest.NewServer(listUsers(m))
|
||||||
defer ts.Close()
|
defer ts.Close()
|
||||||
res, err := http.Get(ts.URL)
|
res, err := http.Get(ts.URL)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
@@ -43,10 +43,10 @@ func Test_listUsers(t *testing.T) {
|
|||||||
func Test_listUsers_NotFound(t *testing.T) {
|
func Test_listUsers_NotFound(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
m := mock.NewMockManager(controller)
|
||||||
ts := httptest.NewServer(listUsers(service))
|
ts := httptest.NewServer(listUsers(m))
|
||||||
defer ts.Close()
|
defer ts.Close()
|
||||||
service.EXPECT().
|
m.EXPECT().
|
||||||
Search("dio").
|
Search("dio").
|
||||||
Return(nil, domain.ErrNotFound)
|
Return(nil, domain.ErrNotFound)
|
||||||
res, err := http.Get(ts.URL + "?name=dio")
|
res, err := http.Get(ts.URL + "?name=dio")
|
||||||
@@ -57,12 +57,12 @@ func Test_listUsers_NotFound(t *testing.T) {
|
|||||||
func Test_listUsers_Search(t *testing.T) {
|
func Test_listUsers_Search(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
m := mock.NewMockManager(controller)
|
||||||
u := user.NewFixtureUser()
|
u := user.NewFixtureUser()
|
||||||
service.EXPECT().
|
m.EXPECT().
|
||||||
Search("ozzy").
|
Search("ozzy").
|
||||||
Return([]*user.User{u}, nil)
|
Return([]*user.User{u}, nil)
|
||||||
ts := httptest.NewServer(listUsers(service))
|
ts := httptest.NewServer(listUsers(m))
|
||||||
defer ts.Close()
|
defer ts.Close()
|
||||||
res, err := http.Get(ts.URL + "?name=ozzy")
|
res, err := http.Get(ts.URL + "?name=ozzy")
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
@@ -72,18 +72,18 @@ func Test_listUsers_Search(t *testing.T) {
|
|||||||
func Test_createUser(t *testing.T) {
|
func Test_createUser(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
m := mock.NewMockManager(controller)
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
n := negroni.New()
|
n := negroni.New()
|
||||||
MakeUserHandlers(r, *n, service)
|
MakeUserHandlers(r, *n, m)
|
||||||
path, err := r.GetRoute("createUser").GetPathTemplate()
|
path, err := r.GetRoute("createUser").GetPathTemplate()
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, "/v1/user", path)
|
assert.Equal(t, "/v1/user", path)
|
||||||
|
|
||||||
service.EXPECT().
|
m.EXPECT().
|
||||||
Create(gomock.Any()).
|
Create(gomock.Any()).
|
||||||
Return(entity.NewID(), nil)
|
Return(entity.NewID(), nil)
|
||||||
h := createUser(service)
|
h := createUser(m)
|
||||||
|
|
||||||
ts := httptest.NewServer(h)
|
ts := httptest.NewServer(h)
|
||||||
defer ts.Close()
|
defer ts.Close()
|
||||||
@@ -105,18 +105,18 @@ func Test_createUser(t *testing.T) {
|
|||||||
func Test_getUser(t *testing.T) {
|
func Test_getUser(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
m := mock.NewMockManager(controller)
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
n := negroni.New()
|
n := negroni.New()
|
||||||
MakeUserHandlers(r, *n, service)
|
MakeUserHandlers(r, *n, m)
|
||||||
path, err := r.GetRoute("getUser").GetPathTemplate()
|
path, err := r.GetRoute("getUser").GetPathTemplate()
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, "/v1/user/{id}", path)
|
assert.Equal(t, "/v1/user/{id}", path)
|
||||||
u := user.NewFixtureUser()
|
u := user.NewFixtureUser()
|
||||||
service.EXPECT().
|
m.EXPECT().
|
||||||
Get(u.ID).
|
Get(u.ID).
|
||||||
Return(u, nil)
|
Return(u, nil)
|
||||||
handler := getUser(service)
|
handler := getUser(m)
|
||||||
r.Handle("/v1/user/{id}", handler)
|
r.Handle("/v1/user/{id}", handler)
|
||||||
ts := httptest.NewServer(r)
|
ts := httptest.NewServer(r)
|
||||||
defer ts.Close()
|
defer ts.Close()
|
||||||
@@ -132,16 +132,16 @@ func Test_getUser(t *testing.T) {
|
|||||||
func Test_deleteUser(t *testing.T) {
|
func Test_deleteUser(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
service := mock.NewMockUseCase(controller)
|
m := mock.NewMockManager(controller)
|
||||||
r := mux.NewRouter()
|
r := mux.NewRouter()
|
||||||
n := negroni.New()
|
n := negroni.New()
|
||||||
MakeUserHandlers(r, *n, service)
|
MakeUserHandlers(r, *n, m)
|
||||||
path, err := r.GetRoute("deleteUser").GetPathTemplate()
|
path, err := r.GetRoute("deleteUser").GetPathTemplate()
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, "/v1/user/{id}", path)
|
assert.Equal(t, "/v1/user/{id}", path)
|
||||||
u := user.NewFixtureUser()
|
u := user.NewFixtureUser()
|
||||||
service.EXPECT().Delete(u.ID).Return(nil)
|
m.EXPECT().Delete(u.ID).Return(nil)
|
||||||
handler := deleteUser(service)
|
handler := deleteUser(m)
|
||||||
req, _ := http.NewRequest("DELETE", "/v1/user/"+u.ID.String(), nil)
|
req, _ := http.NewRequest("DELETE", "/v1/user/"+u.ID.String(), nil)
|
||||||
r.Handle("/v1/user/{id}", handler).Methods("DELETE", "OPTIONS")
|
r.Handle("/v1/user/{id}", handler).Methods("DELETE", "OPTIONS")
|
||||||
rr := httptest.NewRecorder()
|
rr := httptest.NewRecorder()
|
||||||
|
|||||||
+8
-8
@@ -11,7 +11,7 @@ import (
|
|||||||
|
|
||||||
"github.com/eminetto/clean-architecture-go-v2/pkg/password"
|
"github.com/eminetto/clean-architecture-go-v2/pkg/password"
|
||||||
|
|
||||||
"github.com/eminetto/clean-architecture-go-v2/domain/loan"
|
"github.com/eminetto/clean-architecture-go-v2/domain/usecase/loan"
|
||||||
|
|
||||||
"github.com/eminetto/clean-architecture-go-v2/domain/entity/user"
|
"github.com/eminetto/clean-architecture-go-v2/domain/entity/user"
|
||||||
|
|
||||||
@@ -37,13 +37,13 @@ func main() {
|
|||||||
}
|
}
|
||||||
defer db.Close()
|
defer db.Close()
|
||||||
|
|
||||||
bookRepo := book.NewMySQLRepoRepository(db)
|
bookRepo := book.NewMySQLRepository(db)
|
||||||
bookService := book.NewService(bookRepo)
|
bookManager := book.NewManager(bookRepo)
|
||||||
|
|
||||||
userRepo := user.NewMySQLRepoRepository(db)
|
userRepo := user.NewMySQLRepoRepository(db)
|
||||||
userService := user.NewService(userRepo, password.NewService())
|
userManager := user.NewManager(userRepo, password.NewService())
|
||||||
|
|
||||||
loanService := loan.NewService(userService, bookService)
|
loanUseCase := loan.NewUseCase(userManager, bookManager)
|
||||||
|
|
||||||
metricService, err := metric.NewPrometheusService()
|
metricService, err := metric.NewPrometheusService()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -57,13 +57,13 @@ func main() {
|
|||||||
negroni.NewLogger(),
|
negroni.NewLogger(),
|
||||||
)
|
)
|
||||||
//book
|
//book
|
||||||
handler.MakeBookHandlers(r, *n, bookService)
|
handler.MakeBookHandlers(r, *n, bookManager)
|
||||||
|
|
||||||
//user
|
//user
|
||||||
handler.MakeUserHandlers(r, *n, userService)
|
handler.MakeUserHandlers(r, *n, userManager)
|
||||||
|
|
||||||
//loan
|
//loan
|
||||||
handler.MakeLoanHandlers(r, *n, bookService, userService, loanService)
|
handler.MakeLoanHandlers(r, *n, bookManager, userManager, loanUseCase)
|
||||||
|
|
||||||
http.Handle("/", r)
|
http.Handle("/", r)
|
||||||
http.Handle("/metrics", promhttp.Handler())
|
http.Handle("/metrics", promhttp.Handler())
|
||||||
|
|||||||
@@ -10,7 +10,7 @@ import (
|
|||||||
)
|
)
|
||||||
|
|
||||||
//Metrics to prometheus
|
//Metrics to prometheus
|
||||||
func Metrics(mService metric.UseCase) negroni.HandlerFunc {
|
func Metrics(mService metric.Service) negroni.HandlerFunc {
|
||||||
return func(w http.ResponseWriter, r *http.Request, next http.HandlerFunc) {
|
return func(w http.ResponseWriter, r *http.Request, next http.HandlerFunc) {
|
||||||
appMetric := metric.NewHTTP(r.URL.Path, r.Method)
|
appMetric := metric.NewHTTP(r.URL.Path, r.Method)
|
||||||
appMetric.Started()
|
appMetric.Started()
|
||||||
|
|||||||
+3
-3
@@ -40,9 +40,9 @@ func main() {
|
|||||||
log.Fatal(err.Error())
|
log.Fatal(err.Error())
|
||||||
}
|
}
|
||||||
defer db.Close()
|
defer db.Close()
|
||||||
repo := book.NewMySQLRepoRepository(db)
|
repo := book.NewMySQLRepository(db)
|
||||||
service := book.NewService(repo)
|
manager := book.NewManager(repo)
|
||||||
all, err := service.Search(query)
|
all, err := manager.Search(query)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Fatal(err)
|
log.Fatal(err)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -16,14 +16,13 @@ type Writer interface {
|
|||||||
Delete(id entity.ID) error
|
Delete(id entity.ID) error
|
||||||
}
|
}
|
||||||
|
|
||||||
//Repository repository interface
|
//repository interface
|
||||||
type Repository interface {
|
type repository interface {
|
||||||
Reader
|
Reader
|
||||||
Writer
|
Writer
|
||||||
}
|
}
|
||||||
|
|
||||||
//UseCase use case interface
|
//Manager interface
|
||||||
type UseCase interface {
|
type Manager interface {
|
||||||
Reader
|
repository
|
||||||
Writer
|
}
|
||||||
}
|
|
||||||
|
|||||||
@@ -7,42 +7,41 @@ import (
|
|||||||
"github.com/eminetto/clean-architecture-go-v2/domain/entity"
|
"github.com/eminetto/clean-architecture-go-v2/domain/entity"
|
||||||
)
|
)
|
||||||
|
|
||||||
//Service service interface
|
type manager struct {
|
||||||
type Service struct {
|
repo repository
|
||||||
repo Repository
|
|
||||||
}
|
}
|
||||||
|
|
||||||
//NewService create new use case
|
//NewManager create new manager
|
||||||
func NewService(r Repository) *Service {
|
func NewManager(r repository) *manager {
|
||||||
return &Service{
|
return &manager{
|
||||||
repo: r,
|
repo: r,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
//Create a book
|
//Create a book
|
||||||
func (s *Service) Create(e *Book) (entity.ID, error) {
|
func (s *manager) Create(e *Book) (entity.ID, error) {
|
||||||
e.ID = entity.NewID()
|
e.ID = entity.NewID()
|
||||||
e.CreatedAt = time.Now()
|
e.CreatedAt = time.Now()
|
||||||
return s.repo.Create(e)
|
return s.repo.Create(e)
|
||||||
}
|
}
|
||||||
|
|
||||||
//Get a book
|
//Get a book
|
||||||
func (s *Service) Get(id entity.ID) (*Book, error) {
|
func (s *manager) Get(id entity.ID) (*Book, error) {
|
||||||
return s.repo.Get(id)
|
return s.repo.Get(id)
|
||||||
}
|
}
|
||||||
|
|
||||||
//Search books
|
//Search books
|
||||||
func (s *Service) Search(query string) ([]*Book, error) {
|
func (s *manager) Search(query string) ([]*Book, error) {
|
||||||
return s.repo.Search(strings.ToLower(query))
|
return s.repo.Search(strings.ToLower(query))
|
||||||
}
|
}
|
||||||
|
|
||||||
//List books
|
//List books
|
||||||
func (s *Service) List() ([]*Book, error) {
|
func (s *manager) List() ([]*Book, error) {
|
||||||
return s.repo.List()
|
return s.repo.List()
|
||||||
}
|
}
|
||||||
|
|
||||||
//Delete a book
|
//Delete a book
|
||||||
func (s *Service) Delete(id entity.ID) error {
|
func (s *manager) Delete(id entity.ID) error {
|
||||||
_, err := s.Get(id)
|
_, err := s.Get(id)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
@@ -51,6 +50,6 @@ func (s *Service) Delete(id entity.ID) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//Update a book
|
//Update a book
|
||||||
func (s *Service) Update(e *Book) error {
|
func (s *manager) Update(e *Book) error {
|
||||||
return s.repo.Update(e)
|
return s.repo.Update(e)
|
||||||
}
|
}
|
||||||
@@ -10,9 +10,9 @@ import (
|
|||||||
|
|
||||||
func Test_Create(t *testing.T) {
|
func Test_Create(t *testing.T) {
|
||||||
repo := NewInmemRepository()
|
repo := NewInmemRepository()
|
||||||
service := NewService(repo)
|
m := NewManager(repo)
|
||||||
u := NewFixtureBook()
|
u := NewFixtureBook()
|
||||||
id, err := service.Create(u)
|
id, err := m.Create(u)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, u.ID, id)
|
assert.Equal(t, u.ID, id)
|
||||||
assert.False(t, u.CreatedAt.IsZero())
|
assert.False(t, u.CreatedAt.IsZero())
|
||||||
@@ -20,32 +20,32 @@ func Test_Create(t *testing.T) {
|
|||||||
|
|
||||||
func Test_SearchAndFind(t *testing.T) {
|
func Test_SearchAndFind(t *testing.T) {
|
||||||
repo := NewInmemRepository()
|
repo := NewInmemRepository()
|
||||||
service := NewService(repo)
|
m := NewManager(repo)
|
||||||
u1 := NewFixtureBook()
|
u1 := NewFixtureBook()
|
||||||
u2 := NewFixtureBook()
|
u2 := NewFixtureBook()
|
||||||
u2.Title = "Lemmy: Biography"
|
u2.Title = "Lemmy: Biography"
|
||||||
|
|
||||||
uID, _ := service.Create(u1)
|
uID, _ := m.Create(u1)
|
||||||
_, _ = service.Create(u2)
|
_, _ = m.Create(u2)
|
||||||
|
|
||||||
t.Run("search", func(t *testing.T) {
|
t.Run("search", func(t *testing.T) {
|
||||||
c, err := service.Search("ozzy")
|
c, err := m.Search("ozzy")
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, 1, len(c))
|
assert.Equal(t, 1, len(c))
|
||||||
assert.Equal(t, "I Am Ozzy", c[0].Title)
|
assert.Equal(t, "I Am Ozzy", c[0].Title)
|
||||||
|
|
||||||
c, err = service.Search("dio")
|
c, err = m.Search("dio")
|
||||||
assert.Equal(t, domain.ErrNotFound, err)
|
assert.Equal(t, domain.ErrNotFound, err)
|
||||||
assert.Nil(t, c)
|
assert.Nil(t, c)
|
||||||
})
|
})
|
||||||
t.Run("list all", func(t *testing.T) {
|
t.Run("list all", func(t *testing.T) {
|
||||||
all, err := service.List()
|
all, err := m.List()
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, 2, len(all))
|
assert.Equal(t, 2, len(all))
|
||||||
})
|
})
|
||||||
|
|
||||||
t.Run("get", func(t *testing.T) {
|
t.Run("get", func(t *testing.T) {
|
||||||
saved, err := service.Get(uID)
|
saved, err := m.Get(uID)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, u1.Title, saved.Title)
|
assert.Equal(t, u1.Title, saved.Title)
|
||||||
})
|
})
|
||||||
@@ -53,30 +53,30 @@ func Test_SearchAndFind(t *testing.T) {
|
|||||||
|
|
||||||
func Test_Update(t *testing.T) {
|
func Test_Update(t *testing.T) {
|
||||||
repo := NewInmemRepository()
|
repo := NewInmemRepository()
|
||||||
service := NewService(repo)
|
m := NewManager(repo)
|
||||||
u := NewFixtureBook()
|
u := NewFixtureBook()
|
||||||
id, err := service.Create(u)
|
id, err := m.Create(u)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
saved, _ := service.Get(id)
|
saved, _ := m.Get(id)
|
||||||
saved.Title = "Lemmy: Biography"
|
saved.Title = "Lemmy: Biography"
|
||||||
assert.Nil(t, service.Update(saved))
|
assert.Nil(t, m.Update(saved))
|
||||||
updated, err := service.Get(id)
|
updated, err := m.Get(id)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, "Lemmy: Biography", updated.Title)
|
assert.Equal(t, "Lemmy: Biography", updated.Title)
|
||||||
}
|
}
|
||||||
|
|
||||||
func TestDelete(t *testing.T) {
|
func TestDelete(t *testing.T) {
|
||||||
repo := NewInmemRepository()
|
repo := NewInmemRepository()
|
||||||
service := NewService(repo)
|
m := NewManager(repo)
|
||||||
u1 := NewFixtureBook()
|
u1 := NewFixtureBook()
|
||||||
u2 := NewFixtureBook()
|
u2 := NewFixtureBook()
|
||||||
u2ID, _ := service.Create(u2)
|
u2ID, _ := m.Create(u2)
|
||||||
|
|
||||||
err := service.Delete(u1.ID)
|
err := m.Delete(u1.ID)
|
||||||
assert.Equal(t, domain.ErrNotFound, err)
|
assert.Equal(t, domain.ErrNotFound, err)
|
||||||
|
|
||||||
err = service.Delete(u2ID)
|
err = m.Delete(u2ID)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
_, err = service.Get(u2ID)
|
_, err = m.Get(u2ID)
|
||||||
assert.Equal(t, domain.ErrNotFound, err)
|
assert.Equal(t, domain.ErrNotFound, err)
|
||||||
}
|
}
|
||||||
@@ -256,31 +256,31 @@ func (mr *MockRepositoryMockRecorder) Delete(id interface{}) *gomock.Call {
|
|||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockRepository)(nil).Delete), id)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockRepository)(nil).Delete), id)
|
||||||
}
|
}
|
||||||
|
|
||||||
// MockUseCase is a mock of UseCase interface
|
// MockManager is a mock of Manager interface
|
||||||
type MockUseCase struct {
|
type MockManager struct {
|
||||||
ctrl *gomock.Controller
|
ctrl *gomock.Controller
|
||||||
recorder *MockUseCaseMockRecorder
|
recorder *MockManagerMockRecorder
|
||||||
}
|
}
|
||||||
|
|
||||||
// MockUseCaseMockRecorder is the mock recorder for MockUseCase
|
// MockManagerMockRecorder is the mock recorder for MockManager
|
||||||
type MockUseCaseMockRecorder struct {
|
type MockManagerMockRecorder struct {
|
||||||
mock *MockUseCase
|
mock *MockManager
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewMockUseCase creates a new mock instance
|
// NewMockManager creates a new mock instance
|
||||||
func NewMockUseCase(ctrl *gomock.Controller) *MockUseCase {
|
func NewMockManager(ctrl *gomock.Controller) *MockManager {
|
||||||
mock := &MockUseCase{ctrl: ctrl}
|
mock := &MockManager{ctrl: ctrl}
|
||||||
mock.recorder = &MockUseCaseMockRecorder{mock}
|
mock.recorder = &MockManagerMockRecorder{mock}
|
||||||
return mock
|
return mock
|
||||||
}
|
}
|
||||||
|
|
||||||
// EXPECT returns an object that allows the caller to indicate expected use
|
// EXPECT returns an object that allows the caller to indicate expected use
|
||||||
func (m *MockUseCase) EXPECT() *MockUseCaseMockRecorder {
|
func (m *MockManager) EXPECT() *MockManagerMockRecorder {
|
||||||
return m.recorder
|
return m.recorder
|
||||||
}
|
}
|
||||||
|
|
||||||
// Get mocks base method
|
// Get mocks base method
|
||||||
func (m *MockUseCase) Get(id entity.ID) (*book.Book, error) {
|
func (m *MockManager) Get(id entity.ID) (*book.Book, error) {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "Get", id)
|
ret := m.ctrl.Call(m, "Get", id)
|
||||||
ret0, _ := ret[0].(*book.Book)
|
ret0, _ := ret[0].(*book.Book)
|
||||||
@@ -289,13 +289,13 @@ func (m *MockUseCase) Get(id entity.ID) (*book.Book, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Get indicates an expected call of Get
|
// Get indicates an expected call of Get
|
||||||
func (mr *MockUseCaseMockRecorder) Get(id interface{}) *gomock.Call {
|
func (mr *MockManagerMockRecorder) Get(id interface{}) *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*MockUseCase)(nil).Get), id)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*MockManager)(nil).Get), id)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Search mocks base method
|
// Search mocks base method
|
||||||
func (m *MockUseCase) Search(query string) ([]*book.Book, error) {
|
func (m *MockManager) Search(query string) ([]*book.Book, error) {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "Search", query)
|
ret := m.ctrl.Call(m, "Search", query)
|
||||||
ret0, _ := ret[0].([]*book.Book)
|
ret0, _ := ret[0].([]*book.Book)
|
||||||
@@ -304,13 +304,13 @@ func (m *MockUseCase) Search(query string) ([]*book.Book, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Search indicates an expected call of Search
|
// Search indicates an expected call of Search
|
||||||
func (mr *MockUseCaseMockRecorder) Search(query interface{}) *gomock.Call {
|
func (mr *MockManagerMockRecorder) Search(query interface{}) *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Search", reflect.TypeOf((*MockUseCase)(nil).Search), query)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Search", reflect.TypeOf((*MockManager)(nil).Search), query)
|
||||||
}
|
}
|
||||||
|
|
||||||
// List mocks base method
|
// List mocks base method
|
||||||
func (m *MockUseCase) List() ([]*book.Book, error) {
|
func (m *MockManager) List() ([]*book.Book, error) {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "List")
|
ret := m.ctrl.Call(m, "List")
|
||||||
ret0, _ := ret[0].([]*book.Book)
|
ret0, _ := ret[0].([]*book.Book)
|
||||||
@@ -319,13 +319,13 @@ func (m *MockUseCase) List() ([]*book.Book, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// List indicates an expected call of List
|
// List indicates an expected call of List
|
||||||
func (mr *MockUseCaseMockRecorder) List() *gomock.Call {
|
func (mr *MockManagerMockRecorder) List() *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*MockUseCase)(nil).List))
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*MockManager)(nil).List))
|
||||||
}
|
}
|
||||||
|
|
||||||
// Create mocks base method
|
// Create mocks base method
|
||||||
func (m *MockUseCase) Create(e *book.Book) (entity.ID, error) {
|
func (m *MockManager) Create(e *book.Book) (entity.ID, error) {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "Create", e)
|
ret := m.ctrl.Call(m, "Create", e)
|
||||||
ret0, _ := ret[0].(entity.ID)
|
ret0, _ := ret[0].(entity.ID)
|
||||||
@@ -334,13 +334,13 @@ func (m *MockUseCase) Create(e *book.Book) (entity.ID, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Create indicates an expected call of Create
|
// Create indicates an expected call of Create
|
||||||
func (mr *MockUseCaseMockRecorder) Create(e interface{}) *gomock.Call {
|
func (mr *MockManagerMockRecorder) Create(e interface{}) *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*MockUseCase)(nil).Create), e)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*MockManager)(nil).Create), e)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Update mocks base method
|
// Update mocks base method
|
||||||
func (m *MockUseCase) Update(e *book.Book) error {
|
func (m *MockManager) Update(e *book.Book) error {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "Update", e)
|
ret := m.ctrl.Call(m, "Update", e)
|
||||||
ret0, _ := ret[0].(error)
|
ret0, _ := ret[0].(error)
|
||||||
@@ -348,13 +348,13 @@ func (m *MockUseCase) Update(e *book.Book) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Update indicates an expected call of Update
|
// Update indicates an expected call of Update
|
||||||
func (mr *MockUseCaseMockRecorder) Update(e interface{}) *gomock.Call {
|
func (mr *MockManagerMockRecorder) Update(e interface{}) *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*MockUseCase)(nil).Update), e)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*MockManager)(nil).Update), e)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Delete mocks base method
|
// Delete mocks base method
|
||||||
func (m *MockUseCase) Delete(id entity.ID) error {
|
func (m *MockManager) Delete(id entity.ID) error {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "Delete", id)
|
ret := m.ctrl.Call(m, "Delete", id)
|
||||||
ret0, _ := ret[0].(error)
|
ret0, _ := ret[0].(error)
|
||||||
@@ -362,7 +362,7 @@ func (m *MockUseCase) Delete(id entity.ID) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Delete indicates an expected call of Delete
|
// Delete indicates an expected call of Delete
|
||||||
func (mr *MockUseCaseMockRecorder) Delete(id interface{}) *gomock.Call {
|
func (mr *MockManagerMockRecorder) Delete(id interface{}) *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockUseCase)(nil).Delete), id)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockManager)(nil).Delete), id)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -7,27 +7,27 @@ import (
|
|||||||
"github.com/eminetto/clean-architecture-go-v2/domain/entity"
|
"github.com/eminetto/clean-architecture-go-v2/domain/entity"
|
||||||
)
|
)
|
||||||
|
|
||||||
//IRepo in memory repo
|
//iRepo in memory repo
|
||||||
type IRepo struct {
|
type iRepo struct {
|
||||||
m map[entity.ID]*Book
|
m map[entity.ID]*Book
|
||||||
}
|
}
|
||||||
|
|
||||||
//NewInmemRepository create new repository
|
//NewInmemRepository create new repository
|
||||||
func NewInmemRepository() *IRepo {
|
func NewInmemRepository() *iRepo {
|
||||||
var m = map[entity.ID]*Book{}
|
var m = map[entity.ID]*Book{}
|
||||||
return &IRepo{
|
return &iRepo{
|
||||||
m: m,
|
m: m,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
//Create a book
|
//Create a book
|
||||||
func (r *IRepo) Create(e *Book) (entity.ID, error) {
|
func (r *iRepo) Create(e *Book) (entity.ID, error) {
|
||||||
r.m[e.ID] = e
|
r.m[e.ID] = e
|
||||||
return e.ID, nil
|
return e.ID, nil
|
||||||
}
|
}
|
||||||
|
|
||||||
//Get a book
|
//Get a book
|
||||||
func (r *IRepo) Get(id entity.ID) (*Book, error) {
|
func (r *iRepo) Get(id entity.ID) (*Book, error) {
|
||||||
if r.m[id] == nil {
|
if r.m[id] == nil {
|
||||||
return nil, domain.ErrNotFound
|
return nil, domain.ErrNotFound
|
||||||
}
|
}
|
||||||
@@ -35,7 +35,7 @@ func (r *IRepo) Get(id entity.ID) (*Book, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//Update a book
|
//Update a book
|
||||||
func (r *IRepo) Update(e *Book) error {
|
func (r *iRepo) Update(e *Book) error {
|
||||||
_, err := r.Get(e.ID)
|
_, err := r.Get(e.ID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
@@ -45,7 +45,7 @@ func (r *IRepo) Update(e *Book) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//Search books
|
//Search books
|
||||||
func (r *IRepo) Search(query string) ([]*Book, error) {
|
func (r *iRepo) Search(query string) ([]*Book, error) {
|
||||||
var d []*Book
|
var d []*Book
|
||||||
for _, j := range r.m {
|
for _, j := range r.m {
|
||||||
if strings.Contains(strings.ToLower(j.Title), query) {
|
if strings.Contains(strings.ToLower(j.Title), query) {
|
||||||
@@ -60,7 +60,7 @@ func (r *IRepo) Search(query string) ([]*Book, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//List books
|
//List books
|
||||||
func (r *IRepo) List() ([]*Book, error) {
|
func (r *iRepo) List() ([]*Book, error) {
|
||||||
var d []*Book
|
var d []*Book
|
||||||
for _, j := range r.m {
|
for _, j := range r.m {
|
||||||
d = append(d, j)
|
d = append(d, j)
|
||||||
@@ -69,7 +69,7 @@ func (r *IRepo) List() ([]*Book, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//Delete a book
|
//Delete a book
|
||||||
func (r *IRepo) Delete(id entity.ID) error {
|
func (r *iRepo) Delete(id entity.ID) error {
|
||||||
if r.m[id] == nil {
|
if r.m[id] == nil {
|
||||||
return domain.ErrNotFound
|
return domain.ErrNotFound
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -9,20 +9,20 @@ import (
|
|||||||
"github.com/eminetto/clean-architecture-go-v2/domain/entity"
|
"github.com/eminetto/clean-architecture-go-v2/domain/entity"
|
||||||
)
|
)
|
||||||
|
|
||||||
//MySQLRepo mysql repo
|
//mySQLRepo mysql repo
|
||||||
type MySQLRepo struct {
|
type mySQLRepo struct {
|
||||||
db *sql.DB
|
db *sql.DB
|
||||||
}
|
}
|
||||||
|
|
||||||
//NewMySQLRepoRepository create new repository
|
//NewMySQLRepository create new repository
|
||||||
func NewMySQLRepoRepository(db *sql.DB) *MySQLRepo {
|
func NewMySQLRepository(db *sql.DB) *mySQLRepo {
|
||||||
return &MySQLRepo{
|
return &mySQLRepo{
|
||||||
db: db,
|
db: db,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
//Create a book
|
//Create a book
|
||||||
func (r *MySQLRepo) Create(e *Book) (entity.ID, error) {
|
func (r *mySQLRepo) Create(e *Book) (entity.ID, error) {
|
||||||
stmt, err := r.db.Prepare(`
|
stmt, err := r.db.Prepare(`
|
||||||
insert into book (id, title, author, pages, quantity, created_at)
|
insert into book (id, title, author, pages, quantity, created_at)
|
||||||
values(?,?,?,?,?,?)`)
|
values(?,?,?,?,?,?)`)
|
||||||
@@ -48,7 +48,7 @@ func (r *MySQLRepo) Create(e *Book) (entity.ID, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//Get a book
|
//Get a book
|
||||||
func (r *MySQLRepo) Get(id entity.ID) (*Book, error) {
|
func (r *mySQLRepo) Get(id entity.ID) (*Book, error) {
|
||||||
stmt, err := r.db.Prepare(`select id, title, author, pages, quantity, created_at from book where id = ?`)
|
stmt, err := r.db.Prepare(`select id, title, author, pages, quantity, created_at from book where id = ?`)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -65,7 +65,7 @@ func (r *MySQLRepo) Get(id entity.ID) (*Book, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//Update a book
|
//Update a book
|
||||||
func (r *MySQLRepo) Update(e *Book) error {
|
func (r *mySQLRepo) Update(e *Book) error {
|
||||||
e.UpdatedAt = time.Now()
|
e.UpdatedAt = time.Now()
|
||||||
_, err := r.db.Exec("update book set title = ?, author = ?, pages = ?, quantity = ?, updated_at = ? where id = ?", e.Title, e.Author, e.Pages, e.Quantity, e.UpdatedAt.Format("2006-01-02"), e.ID)
|
_, err := r.db.Exec("update book set title = ?, author = ?, pages = ?, quantity = ?, updated_at = ? where id = ?", e.Title, e.Author, e.Pages, e.Quantity, e.UpdatedAt.Format("2006-01-02"), e.ID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
@@ -75,7 +75,7 @@ func (r *MySQLRepo) Update(e *Book) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//Search books
|
//Search books
|
||||||
func (r *MySQLRepo) Search(query string) ([]*Book, error) {
|
func (r *mySQLRepo) Search(query string) ([]*Book, error) {
|
||||||
stmt, err := r.db.Prepare(`select id, title, author, pages, quantity, created_at from book where title like ?`)
|
stmt, err := r.db.Prepare(`select id, title, author, pages, quantity, created_at from book where title like ?`)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -100,7 +100,7 @@ func (r *MySQLRepo) Search(query string) ([]*Book, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//List books
|
//List books
|
||||||
func (r *MySQLRepo) List() ([]*Book, error) {
|
func (r *mySQLRepo) List() ([]*Book, error) {
|
||||||
stmt, err := r.db.Prepare(`select id, title, author, pages, quantity, created_at from book`)
|
stmt, err := r.db.Prepare(`select id, title, author, pages, quantity, created_at from book`)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return nil, err
|
return nil, err
|
||||||
@@ -125,7 +125,7 @@ func (r *MySQLRepo) List() ([]*Book, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//Delete a book
|
//Delete a book
|
||||||
func (r *MySQLRepo) Delete(id entity.ID) error {
|
func (r *mySQLRepo) Delete(id entity.ID) error {
|
||||||
_, err := r.db.Exec("delete from book where id = ?", id)
|
_, err := r.db.Exec("delete from book where id = ?", id)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
|
|||||||
@@ -16,14 +16,13 @@ type Writer interface {
|
|||||||
Delete(id entity.ID) error
|
Delete(id entity.ID) error
|
||||||
}
|
}
|
||||||
|
|
||||||
//Repository repository interface
|
//repository interface
|
||||||
type Repository interface {
|
type repository interface {
|
||||||
Reader
|
Reader
|
||||||
Writer
|
Writer
|
||||||
}
|
}
|
||||||
|
|
||||||
//UseCase use case interface
|
//Manager interface
|
||||||
type UseCase interface {
|
type Manager interface {
|
||||||
Reader
|
repository
|
||||||
Writer
|
}
|
||||||
}
|
|
||||||
|
|||||||
@@ -4,27 +4,29 @@ import (
|
|||||||
"strings"
|
"strings"
|
||||||
"time"
|
"time"
|
||||||
|
|
||||||
|
"github.com/eminetto/clean-architecture-go-v2/domain"
|
||||||
|
|
||||||
"github.com/eminetto/clean-architecture-go-v2/pkg/password"
|
"github.com/eminetto/clean-architecture-go-v2/pkg/password"
|
||||||
|
|
||||||
"github.com/eminetto/clean-architecture-go-v2/domain/entity"
|
"github.com/eminetto/clean-architecture-go-v2/domain/entity"
|
||||||
)
|
)
|
||||||
|
|
||||||
//Service service interface
|
//manager interface
|
||||||
type Service struct {
|
type manager struct {
|
||||||
repo Repository
|
repo repository
|
||||||
pwd password.UseCase
|
pwd password.Service
|
||||||
}
|
}
|
||||||
|
|
||||||
//NewService create new use case
|
//NewManager create new repository
|
||||||
func NewService(r Repository, pwd password.UseCase) *Service {
|
func NewManager(r repository, pwd password.Service) *manager {
|
||||||
return &Service{
|
return &manager{
|
||||||
repo: r,
|
repo: r,
|
||||||
pwd: pwd,
|
pwd: pwd,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
//Create an user
|
//Create an user
|
||||||
func (s *Service) Create(e *User) (entity.ID, error) {
|
func (s *manager) Create(e *User) (entity.ID, error) {
|
||||||
e.ID = entity.NewID()
|
e.ID = entity.NewID()
|
||||||
e.CreatedAt = time.Now()
|
e.CreatedAt = time.Now()
|
||||||
pwd, err := s.pwd.Generate(e.Password)
|
pwd, err := s.pwd.Generate(e.Password)
|
||||||
@@ -36,31 +38,34 @@ func (s *Service) Create(e *User) (entity.ID, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//Get an user
|
//Get an user
|
||||||
func (s *Service) Get(id entity.ID) (*User, error) {
|
func (s *manager) Get(id entity.ID) (*User, error) {
|
||||||
return s.repo.Get(id)
|
return s.repo.Get(id)
|
||||||
}
|
}
|
||||||
|
|
||||||
//Search users
|
//Search users
|
||||||
func (s *Service) Search(query string) ([]*User, error) {
|
func (s *manager) Search(query string) ([]*User, error) {
|
||||||
return s.repo.Search(strings.ToLower(query))
|
return s.repo.Search(strings.ToLower(query))
|
||||||
}
|
}
|
||||||
|
|
||||||
//List users
|
//List users
|
||||||
func (s *Service) List() ([]*User, error) {
|
func (s *manager) List() ([]*User, error) {
|
||||||
return s.repo.List()
|
return s.repo.List()
|
||||||
}
|
}
|
||||||
|
|
||||||
//Delete an user
|
//Delete an user
|
||||||
func (s *Service) Delete(id entity.ID) error {
|
func (s *manager) Delete(id entity.ID) error {
|
||||||
_, err := s.Get(id)
|
u, err := s.Get(id)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
if len(u.Books) > 0 {
|
||||||
|
return domain.ErrCannotBeDeleted
|
||||||
|
}
|
||||||
return s.repo.Delete(id)
|
return s.repo.Delete(id)
|
||||||
}
|
}
|
||||||
|
|
||||||
//Update an user
|
//Update an user
|
||||||
func (s *Service) Update(e *User) error {
|
func (s *manager) Update(e *User) error {
|
||||||
e.UpdatedAt = time.Now()
|
e.UpdatedAt = time.Now()
|
||||||
return s.repo.Update(e)
|
return s.repo.Update(e)
|
||||||
}
|
}
|
||||||
@@ -13,9 +13,9 @@ import (
|
|||||||
|
|
||||||
func Test_Create(t *testing.T) {
|
func Test_Create(t *testing.T) {
|
||||||
repo := NewInmemRepository()
|
repo := NewInmemRepository()
|
||||||
service := NewService(repo, password.NewFakeService())
|
m := NewManager(repo, password.NewFakeService())
|
||||||
u := NewFixtureUser()
|
u := NewFixtureUser()
|
||||||
id, err := service.Create(u)
|
id, err := m.Create(u)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, u.ID, id)
|
assert.Equal(t, u.ID, id)
|
||||||
assert.False(t, u.CreatedAt.IsZero())
|
assert.False(t, u.CreatedAt.IsZero())
|
||||||
@@ -24,32 +24,32 @@ func Test_Create(t *testing.T) {
|
|||||||
|
|
||||||
func Test_SearchAndFind(t *testing.T) {
|
func Test_SearchAndFind(t *testing.T) {
|
||||||
repo := NewInmemRepository()
|
repo := NewInmemRepository()
|
||||||
service := NewService(repo, password.NewFakeService())
|
m := NewManager(repo, password.NewFakeService())
|
||||||
u1 := NewFixtureUser()
|
u1 := NewFixtureUser()
|
||||||
u2 := NewFixtureUser()
|
u2 := NewFixtureUser()
|
||||||
u2.FirstName = "Lemmy"
|
u2.FirstName = "Lemmy"
|
||||||
|
|
||||||
uID, _ := service.Create(u1)
|
uID, _ := m.Create(u1)
|
||||||
_, _ = service.Create(u2)
|
_, _ = m.Create(u2)
|
||||||
|
|
||||||
t.Run("search", func(t *testing.T) {
|
t.Run("search", func(t *testing.T) {
|
||||||
c, err := service.Search("ozzy")
|
c, err := m.Search("ozzy")
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, 1, len(c))
|
assert.Equal(t, 1, len(c))
|
||||||
assert.Equal(t, "Osbourne", c[0].LastName)
|
assert.Equal(t, "Osbourne", c[0].LastName)
|
||||||
|
|
||||||
c, err = service.Search("dio")
|
c, err = m.Search("dio")
|
||||||
assert.Equal(t, domain.ErrNotFound, err)
|
assert.Equal(t, domain.ErrNotFound, err)
|
||||||
assert.Nil(t, c)
|
assert.Nil(t, c)
|
||||||
})
|
})
|
||||||
t.Run("list all", func(t *testing.T) {
|
t.Run("list all", func(t *testing.T) {
|
||||||
all, err := service.List()
|
all, err := m.List()
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, 2, len(all))
|
assert.Equal(t, 2, len(all))
|
||||||
})
|
})
|
||||||
|
|
||||||
t.Run("get", func(t *testing.T) {
|
t.Run("get", func(t *testing.T) {
|
||||||
saved, err := service.Get(uID)
|
saved, err := m.Get(uID)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, u1.FirstName, saved.FirstName)
|
assert.Equal(t, u1.FirstName, saved.FirstName)
|
||||||
})
|
})
|
||||||
@@ -57,15 +57,15 @@ func Test_SearchAndFind(t *testing.T) {
|
|||||||
|
|
||||||
func Test_Update(t *testing.T) {
|
func Test_Update(t *testing.T) {
|
||||||
repo := NewInmemRepository()
|
repo := NewInmemRepository()
|
||||||
service := NewService(repo, password.NewFakeService())
|
m := NewManager(repo, password.NewFakeService())
|
||||||
u := NewFixtureUser()
|
u := NewFixtureUser()
|
||||||
id, err := service.Create(u)
|
id, err := m.Create(u)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
saved, _ := service.Get(id)
|
saved, _ := m.Get(id)
|
||||||
saved.FirstName = "Dio"
|
saved.FirstName = "Dio"
|
||||||
saved.Books = append(saved.Books, entity.NewID())
|
saved.Books = append(saved.Books, entity.NewID())
|
||||||
assert.Nil(t, service.Update(saved))
|
assert.Nil(t, m.Update(saved))
|
||||||
updated, err := service.Get(id)
|
updated, err := m.Get(id)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
assert.Equal(t, "Dio", updated.FirstName)
|
assert.Equal(t, "Dio", updated.FirstName)
|
||||||
assert.False(t, u.UpdatedAt.IsZero())
|
assert.False(t, u.UpdatedAt.IsZero())
|
||||||
@@ -74,16 +74,22 @@ func Test_Update(t *testing.T) {
|
|||||||
|
|
||||||
func TestDelete(t *testing.T) {
|
func TestDelete(t *testing.T) {
|
||||||
repo := NewInmemRepository()
|
repo := NewInmemRepository()
|
||||||
service := NewService(repo, password.NewFakeService())
|
m := NewManager(repo, password.NewFakeService())
|
||||||
u1 := NewFixtureUser()
|
u1 := NewFixtureUser()
|
||||||
u2 := NewFixtureUser()
|
u2 := NewFixtureUser()
|
||||||
u2ID, _ := service.Create(u2)
|
u2ID, _ := m.Create(u2)
|
||||||
|
|
||||||
err := service.Delete(u1.ID)
|
err := m.Delete(u1.ID)
|
||||||
assert.Equal(t, domain.ErrNotFound, err)
|
assert.Equal(t, domain.ErrNotFound, err)
|
||||||
|
|
||||||
err = service.Delete(u2ID)
|
err = m.Delete(u2ID)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
_, err = service.Get(u2ID)
|
_, err = m.Get(u2ID)
|
||||||
assert.Equal(t, domain.ErrNotFound, err)
|
assert.Equal(t, domain.ErrNotFound, err)
|
||||||
|
|
||||||
|
u3 := NewFixtureUser()
|
||||||
|
u3.Books = []entity.ID{entity.NewID()}
|
||||||
|
_, _ = m.Create(u3)
|
||||||
|
err = m.Delete(u3.ID)
|
||||||
|
assert.Equal(t, domain.ErrCannotBeDeleted, err)
|
||||||
}
|
}
|
||||||
@@ -256,31 +256,31 @@ func (mr *MockRepositoryMockRecorder) Delete(id interface{}) *gomock.Call {
|
|||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockRepository)(nil).Delete), id)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockRepository)(nil).Delete), id)
|
||||||
}
|
}
|
||||||
|
|
||||||
// MockUseCase is a mock of UseCase interface
|
// MockManager is a mock of Manager interface
|
||||||
type MockUseCase struct {
|
type MockManager struct {
|
||||||
ctrl *gomock.Controller
|
ctrl *gomock.Controller
|
||||||
recorder *MockUseCaseMockRecorder
|
recorder *MockManagerMockRecorder
|
||||||
}
|
}
|
||||||
|
|
||||||
// MockUseCaseMockRecorder is the mock recorder for MockUseCase
|
// MockManagerMockRecorder is the mock recorder for MockManager
|
||||||
type MockUseCaseMockRecorder struct {
|
type MockManagerMockRecorder struct {
|
||||||
mock *MockUseCase
|
mock *MockManager
|
||||||
}
|
}
|
||||||
|
|
||||||
// NewMockUseCase creates a new mock instance
|
// NewMockManager creates a new mock instance
|
||||||
func NewMockUseCase(ctrl *gomock.Controller) *MockUseCase {
|
func NewMockManager(ctrl *gomock.Controller) *MockManager {
|
||||||
mock := &MockUseCase{ctrl: ctrl}
|
mock := &MockManager{ctrl: ctrl}
|
||||||
mock.recorder = &MockUseCaseMockRecorder{mock}
|
mock.recorder = &MockManagerMockRecorder{mock}
|
||||||
return mock
|
return mock
|
||||||
}
|
}
|
||||||
|
|
||||||
// EXPECT returns an object that allows the caller to indicate expected use
|
// EXPECT returns an object that allows the caller to indicate expected use
|
||||||
func (m *MockUseCase) EXPECT() *MockUseCaseMockRecorder {
|
func (m *MockManager) EXPECT() *MockManagerMockRecorder {
|
||||||
return m.recorder
|
return m.recorder
|
||||||
}
|
}
|
||||||
|
|
||||||
// Get mocks base method
|
// Get mocks base method
|
||||||
func (m *MockUseCase) Get(id entity.ID) (*user.User, error) {
|
func (m *MockManager) Get(id entity.ID) (*user.User, error) {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "Get", id)
|
ret := m.ctrl.Call(m, "Get", id)
|
||||||
ret0, _ := ret[0].(*user.User)
|
ret0, _ := ret[0].(*user.User)
|
||||||
@@ -289,13 +289,13 @@ func (m *MockUseCase) Get(id entity.ID) (*user.User, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Get indicates an expected call of Get
|
// Get indicates an expected call of Get
|
||||||
func (mr *MockUseCaseMockRecorder) Get(id interface{}) *gomock.Call {
|
func (mr *MockManagerMockRecorder) Get(id interface{}) *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*MockUseCase)(nil).Get), id)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Get", reflect.TypeOf((*MockManager)(nil).Get), id)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Search mocks base method
|
// Search mocks base method
|
||||||
func (m *MockUseCase) Search(query string) ([]*user.User, error) {
|
func (m *MockManager) Search(query string) ([]*user.User, error) {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "Search", query)
|
ret := m.ctrl.Call(m, "Search", query)
|
||||||
ret0, _ := ret[0].([]*user.User)
|
ret0, _ := ret[0].([]*user.User)
|
||||||
@@ -304,13 +304,13 @@ func (m *MockUseCase) Search(query string) ([]*user.User, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Search indicates an expected call of Search
|
// Search indicates an expected call of Search
|
||||||
func (mr *MockUseCaseMockRecorder) Search(query interface{}) *gomock.Call {
|
func (mr *MockManagerMockRecorder) Search(query interface{}) *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Search", reflect.TypeOf((*MockUseCase)(nil).Search), query)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Search", reflect.TypeOf((*MockManager)(nil).Search), query)
|
||||||
}
|
}
|
||||||
|
|
||||||
// List mocks base method
|
// List mocks base method
|
||||||
func (m *MockUseCase) List() ([]*user.User, error) {
|
func (m *MockManager) List() ([]*user.User, error) {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "List")
|
ret := m.ctrl.Call(m, "List")
|
||||||
ret0, _ := ret[0].([]*user.User)
|
ret0, _ := ret[0].([]*user.User)
|
||||||
@@ -319,13 +319,13 @@ func (m *MockUseCase) List() ([]*user.User, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// List indicates an expected call of List
|
// List indicates an expected call of List
|
||||||
func (mr *MockUseCaseMockRecorder) List() *gomock.Call {
|
func (mr *MockManagerMockRecorder) List() *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*MockUseCase)(nil).List))
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "List", reflect.TypeOf((*MockManager)(nil).List))
|
||||||
}
|
}
|
||||||
|
|
||||||
// Create mocks base method
|
// Create mocks base method
|
||||||
func (m *MockUseCase) Create(e *user.User) (entity.ID, error) {
|
func (m *MockManager) Create(e *user.User) (entity.ID, error) {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "Create", e)
|
ret := m.ctrl.Call(m, "Create", e)
|
||||||
ret0, _ := ret[0].(entity.ID)
|
ret0, _ := ret[0].(entity.ID)
|
||||||
@@ -334,13 +334,13 @@ func (m *MockUseCase) Create(e *user.User) (entity.ID, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Create indicates an expected call of Create
|
// Create indicates an expected call of Create
|
||||||
func (mr *MockUseCaseMockRecorder) Create(e interface{}) *gomock.Call {
|
func (mr *MockManagerMockRecorder) Create(e interface{}) *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*MockUseCase)(nil).Create), e)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Create", reflect.TypeOf((*MockManager)(nil).Create), e)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Update mocks base method
|
// Update mocks base method
|
||||||
func (m *MockUseCase) Update(e *user.User) error {
|
func (m *MockManager) Update(e *user.User) error {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "Update", e)
|
ret := m.ctrl.Call(m, "Update", e)
|
||||||
ret0, _ := ret[0].(error)
|
ret0, _ := ret[0].(error)
|
||||||
@@ -348,13 +348,13 @@ func (m *MockUseCase) Update(e *user.User) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Update indicates an expected call of Update
|
// Update indicates an expected call of Update
|
||||||
func (mr *MockUseCaseMockRecorder) Update(e interface{}) *gomock.Call {
|
func (mr *MockManagerMockRecorder) Update(e interface{}) *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*MockUseCase)(nil).Update), e)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Update", reflect.TypeOf((*MockManager)(nil).Update), e)
|
||||||
}
|
}
|
||||||
|
|
||||||
// Delete mocks base method
|
// Delete mocks base method
|
||||||
func (m *MockUseCase) Delete(id entity.ID) error {
|
func (m *MockManager) Delete(id entity.ID) error {
|
||||||
m.ctrl.T.Helper()
|
m.ctrl.T.Helper()
|
||||||
ret := m.ctrl.Call(m, "Delete", id)
|
ret := m.ctrl.Call(m, "Delete", id)
|
||||||
ret0, _ := ret[0].(error)
|
ret0, _ := ret[0].(error)
|
||||||
@@ -362,7 +362,7 @@ func (m *MockUseCase) Delete(id entity.ID) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
// Delete indicates an expected call of Delete
|
// Delete indicates an expected call of Delete
|
||||||
func (mr *MockUseCaseMockRecorder) Delete(id interface{}) *gomock.Call {
|
func (mr *MockManagerMockRecorder) Delete(id interface{}) *gomock.Call {
|
||||||
mr.mock.ctrl.T.Helper()
|
mr.mock.ctrl.T.Helper()
|
||||||
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockUseCase)(nil).Delete), id)
|
return mr.mock.ctrl.RecordCallWithMethodType(mr.mock, "Delete", reflect.TypeOf((*MockManager)(nil).Delete), id)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,5 +1,5 @@
|
|||||||
// Code generated by MockGen. DO NOT EDIT.
|
// Code generated by MockGen. DO NOT EDIT.
|
||||||
// Source: domain/loan/interface.go
|
// Source: domain/usecase/loan/interface.go
|
||||||
|
|
||||||
// Package mock is a generated GoMock package.
|
// Package mock is a generated GoMock package.
|
||||||
package mock
|
package mock
|
||||||
@@ -7,27 +7,26 @@ import (
|
|||||||
"github.com/eminetto/clean-architecture-go-v2/domain/entity/user"
|
"github.com/eminetto/clean-architecture-go-v2/domain/entity/user"
|
||||||
)
|
)
|
||||||
|
|
||||||
//Service service interface
|
type usecase struct {
|
||||||
type Service struct {
|
uManager user.Manager
|
||||||
uService user.UseCase
|
bManager book.Manager
|
||||||
bService book.UseCase
|
|
||||||
}
|
}
|
||||||
|
|
||||||
//NewService create new use case
|
//NewUseCase create new use case
|
||||||
func NewService(u user.UseCase, b book.UseCase) *Service {
|
func NewUseCase(u user.Manager, b book.Manager) *usecase {
|
||||||
return &Service{
|
return &usecase{
|
||||||
uService: u,
|
uManager: u,
|
||||||
bService: b,
|
bManager: b,
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
//Borrow borrow a book to an user
|
//Borrow borrow a book to an user
|
||||||
func (s *Service) Borrow(u *user.User, b *book.Book) error {
|
func (s *usecase) Borrow(u *user.User, b *book.Book) error {
|
||||||
u, err := s.uService.Get(u.ID)
|
u, err := s.uManager.Get(u.ID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
b, err = s.bService.Get(b.ID)
|
b, err = s.bManager.Get(b.ID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@@ -40,12 +39,12 @@ func (s *Service) Borrow(u *user.User, b *book.Book) error {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
u.Books = append(u.Books, b.ID)
|
u.Books = append(u.Books, b.ID)
|
||||||
err = s.uService.Update(u)
|
err = s.uManager.Update(u)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
b.Quantity--
|
b.Quantity--
|
||||||
err = s.bService.Update(b)
|
err = s.bManager.Update(b)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@@ -53,13 +52,13 @@ func (s *Service) Borrow(u *user.User, b *book.Book) error {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//Return return a book
|
//Return return a book
|
||||||
func (s *Service) Return(b *book.Book) error {
|
func (s *usecase) Return(b *book.Book) error {
|
||||||
b, err := s.bService.Get(b.ID)
|
b, err := s.bManager.Get(b.ID)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
|
|
||||||
all, err := s.uService.List()
|
all, err := s.uManager.List()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@@ -77,14 +76,14 @@ func (s *Service) Return(b *book.Book) error {
|
|||||||
if !borrowed {
|
if !borrowed {
|
||||||
return domain.ErrBookNotBorrowed
|
return domain.ErrBookNotBorrowed
|
||||||
}
|
}
|
||||||
u, err := s.uService.Get(borrowedBy)
|
u, err := s.uManager.Get(borrowedBy)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
for i, j := range u.Books {
|
for i, j := range u.Books {
|
||||||
if j == b.ID {
|
if j == b.ID {
|
||||||
u.Books = append(u.Books[:i], u.Books[i+1:]...)
|
u.Books = append(u.Books[:i], u.Books[i+1:]...)
|
||||||
err = s.uService.Update(u)
|
err = s.uManager.Update(u)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@@ -92,7 +91,7 @@ func (s *Service) Return(b *book.Book) error {
|
|||||||
}
|
}
|
||||||
}
|
}
|
||||||
b.Quantity++
|
b.Quantity++
|
||||||
err = s.bService.Update(b)
|
err = s.bManager.Update(b)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return err
|
return err
|
||||||
}
|
}
|
||||||
@@ -17,14 +17,14 @@ import (
|
|||||||
func Test_Borrow(t *testing.T) {
|
func Test_Borrow(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
uMock := umock.NewMockUseCase(controller)
|
uMock := umock.NewMockManager(controller)
|
||||||
bMock := bmock.NewMockUseCase(controller)
|
bMock := bmock.NewMockManager(controller)
|
||||||
service := NewService(uMock, bMock)
|
uc := NewUseCase(uMock, bMock)
|
||||||
t.Run("user not found", func(t *testing.T) {
|
t.Run("user not found", func(t *testing.T) {
|
||||||
u := user.NewFixtureUser()
|
u := user.NewFixtureUser()
|
||||||
b := book.NewFixtureBook()
|
b := book.NewFixtureBook()
|
||||||
uMock.EXPECT().Get(u.ID).Return(nil, domain.ErrNotFound)
|
uMock.EXPECT().Get(u.ID).Return(nil, domain.ErrNotFound)
|
||||||
err := service.Borrow(u, b)
|
err := uc.Borrow(u, b)
|
||||||
assert.Equal(t, domain.ErrNotFound, err)
|
assert.Equal(t, domain.ErrNotFound, err)
|
||||||
})
|
})
|
||||||
t.Run("book not found", func(t *testing.T) {
|
t.Run("book not found", func(t *testing.T) {
|
||||||
@@ -32,7 +32,7 @@ func Test_Borrow(t *testing.T) {
|
|||||||
b := book.NewFixtureBook()
|
b := book.NewFixtureBook()
|
||||||
uMock.EXPECT().Get(u.ID).Return(u, nil)
|
uMock.EXPECT().Get(u.ID).Return(u, nil)
|
||||||
bMock.EXPECT().Get(b.ID).Return(nil, domain.ErrNotFound)
|
bMock.EXPECT().Get(b.ID).Return(nil, domain.ErrNotFound)
|
||||||
err := service.Borrow(u, b)
|
err := uc.Borrow(u, b)
|
||||||
assert.Equal(t, domain.ErrNotFound, err)
|
assert.Equal(t, domain.ErrNotFound, err)
|
||||||
})
|
})
|
||||||
t.Run("not enough books to borrow", func(t *testing.T) {
|
t.Run("not enough books to borrow", func(t *testing.T) {
|
||||||
@@ -41,7 +41,7 @@ func Test_Borrow(t *testing.T) {
|
|||||||
b.Quantity = 0
|
b.Quantity = 0
|
||||||
uMock.EXPECT().Get(u.ID).Return(u, nil)
|
uMock.EXPECT().Get(u.ID).Return(u, nil)
|
||||||
bMock.EXPECT().Get(b.ID).Return(b, nil)
|
bMock.EXPECT().Get(b.ID).Return(b, nil)
|
||||||
err := service.Borrow(u, b)
|
err := uc.Borrow(u, b)
|
||||||
assert.Equal(t, domain.ErrNotEnoughBooks, err)
|
assert.Equal(t, domain.ErrNotEnoughBooks, err)
|
||||||
})
|
})
|
||||||
t.Run("book already borrowed", func(t *testing.T) {
|
t.Run("book already borrowed", func(t *testing.T) {
|
||||||
@@ -51,7 +51,7 @@ func Test_Borrow(t *testing.T) {
|
|||||||
b.Quantity = 1
|
b.Quantity = 1
|
||||||
uMock.EXPECT().Get(u.ID).Return(u, nil)
|
uMock.EXPECT().Get(u.ID).Return(u, nil)
|
||||||
bMock.EXPECT().Get(b.ID).Return(b, nil)
|
bMock.EXPECT().Get(b.ID).Return(b, nil)
|
||||||
err := service.Borrow(u, b)
|
err := uc.Borrow(u, b)
|
||||||
assert.Equal(t, domain.ErrBookAlreadyBorrowed, err)
|
assert.Equal(t, domain.ErrBookAlreadyBorrowed, err)
|
||||||
})
|
})
|
||||||
t.Run("sucess", func(t *testing.T) {
|
t.Run("sucess", func(t *testing.T) {
|
||||||
@@ -61,7 +61,7 @@ func Test_Borrow(t *testing.T) {
|
|||||||
bMock.EXPECT().Get(b.ID).Return(b, nil)
|
bMock.EXPECT().Get(b.ID).Return(b, nil)
|
||||||
uMock.EXPECT().Update(u).Return(nil)
|
uMock.EXPECT().Update(u).Return(nil)
|
||||||
bMock.EXPECT().Update(b).Return(nil)
|
bMock.EXPECT().Update(b).Return(nil)
|
||||||
err := service.Borrow(u, b)
|
err := uc.Borrow(u, b)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
@@ -69,13 +69,13 @@ func Test_Borrow(t *testing.T) {
|
|||||||
func Test_Return(t *testing.T) {
|
func Test_Return(t *testing.T) {
|
||||||
controller := gomock.NewController(t)
|
controller := gomock.NewController(t)
|
||||||
defer controller.Finish()
|
defer controller.Finish()
|
||||||
uMock := umock.NewMockUseCase(controller)
|
uMock := umock.NewMockManager(controller)
|
||||||
bMock := bmock.NewMockUseCase(controller)
|
bMock := bmock.NewMockManager(controller)
|
||||||
service := NewService(uMock, bMock)
|
uc := NewUseCase(uMock, bMock)
|
||||||
t.Run("book not found", func(t *testing.T) {
|
t.Run("book not found", func(t *testing.T) {
|
||||||
b := book.NewFixtureBook()
|
b := book.NewFixtureBook()
|
||||||
bMock.EXPECT().Get(b.ID).Return(nil, domain.ErrNotFound)
|
bMock.EXPECT().Get(b.ID).Return(nil, domain.ErrNotFound)
|
||||||
err := service.Return(b)
|
err := uc.Return(b)
|
||||||
assert.Equal(t, domain.ErrNotFound, err)
|
assert.Equal(t, domain.ErrNotFound, err)
|
||||||
})
|
})
|
||||||
t.Run("book not borrowed", func(t *testing.T) {
|
t.Run("book not borrowed", func(t *testing.T) {
|
||||||
@@ -83,7 +83,7 @@ func Test_Return(t *testing.T) {
|
|||||||
b := book.NewFixtureBook()
|
b := book.NewFixtureBook()
|
||||||
bMock.EXPECT().Get(b.ID).Return(b, nil)
|
bMock.EXPECT().Get(b.ID).Return(b, nil)
|
||||||
uMock.EXPECT().List().Return([]*user.User{u}, nil)
|
uMock.EXPECT().List().Return([]*user.User{u}, nil)
|
||||||
err := service.Return(b)
|
err := uc.Return(b)
|
||||||
assert.Equal(t, domain.ErrBookNotBorrowed, err)
|
assert.Equal(t, domain.ErrBookNotBorrowed, err)
|
||||||
})
|
})
|
||||||
t.Run("success", func(t *testing.T) {
|
t.Run("success", func(t *testing.T) {
|
||||||
@@ -95,7 +95,7 @@ func Test_Return(t *testing.T) {
|
|||||||
uMock.EXPECT().List().Return([]*user.User{u}, nil)
|
uMock.EXPECT().List().Return([]*user.User{u}, nil)
|
||||||
uMock.EXPECT().Update(u).Return(nil)
|
uMock.EXPECT().Update(u).Return(nil)
|
||||||
bMock.EXPECT().Update(b).Return(nil)
|
bMock.EXPECT().Update(b).Return(nil)
|
||||||
err := service.Return(b)
|
err := uc.Return(b)
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
@@ -57,8 +57,8 @@ func (h *HTTP) Finished() {
|
|||||||
h.Duration = time.Since(h.StartedAt).Seconds()
|
h.Duration = time.Since(h.StartedAt).Seconds()
|
||||||
}
|
}
|
||||||
|
|
||||||
//UseCase definition
|
//Service definition
|
||||||
type UseCase interface {
|
type Service interface {
|
||||||
SaveCLI(c *CLI) error
|
SaveCLI(c *CLI) error
|
||||||
SaveHTTP(h *HTTP)
|
SaveHTTP(h *HTTP)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -6,14 +6,14 @@ import (
|
|||||||
"github.com/prometheus/client_golang/prometheus/push"
|
"github.com/prometheus/client_golang/prometheus/push"
|
||||||
)
|
)
|
||||||
|
|
||||||
//Service implements UseCase interface
|
//service implements Service interface
|
||||||
type Service struct {
|
type service struct {
|
||||||
pHistogram *prometheus.HistogramVec
|
pHistogram *prometheus.HistogramVec
|
||||||
httpRequestHistogram *prometheus.HistogramVec
|
httpRequestHistogram *prometheus.HistogramVec
|
||||||
}
|
}
|
||||||
|
|
||||||
//NewPrometheusService create a new prometheus service
|
//NewPrometheusService create a new prometheus service
|
||||||
func NewPrometheusService() (*Service, error) {
|
func NewPrometheusService() (*service, error) {
|
||||||
cli := prometheus.NewHistogramVec(prometheus.HistogramOpts{
|
cli := prometheus.NewHistogramVec(prometheus.HistogramOpts{
|
||||||
Namespace: "pushgateway",
|
Namespace: "pushgateway",
|
||||||
Name: "cmd_duration_seconds",
|
Name: "cmd_duration_seconds",
|
||||||
@@ -27,7 +27,7 @@ func NewPrometheusService() (*Service, error) {
|
|||||||
Buckets: prometheus.DefBuckets,
|
Buckets: prometheus.DefBuckets,
|
||||||
}, []string{"handler", "method", "code"})
|
}, []string{"handler", "method", "code"})
|
||||||
|
|
||||||
s := &Service{
|
s := &service{
|
||||||
pHistogram: cli,
|
pHistogram: cli,
|
||||||
httpRequestHistogram: http,
|
httpRequestHistogram: http,
|
||||||
}
|
}
|
||||||
@@ -43,13 +43,13 @@ func NewPrometheusService() (*Service, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
//SaveCLI send metrics to server
|
//SaveCLI send metrics to server
|
||||||
func (s *Service) SaveCLI(c *CLI) error {
|
func (s *service) SaveCLI(c *CLI) error {
|
||||||
gatewayURL := config.PROMETHEUS_PUSHGATEWAY
|
gatewayURL := config.PROMETHEUS_PUSHGATEWAY
|
||||||
s.pHistogram.WithLabelValues(c.Name).Observe(c.Duration)
|
s.pHistogram.WithLabelValues(c.Name).Observe(c.Duration)
|
||||||
return push.New(gatewayURL, "cmd_job").Collector(s.pHistogram).Push()
|
return push.New(gatewayURL, "cmd_job").Collector(s.pHistogram).Push()
|
||||||
}
|
}
|
||||||
|
|
||||||
//SaveHTTP send metrics to server
|
//SaveHTTP send metrics to server
|
||||||
func (s *Service) SaveHTTP(h *HTTP) {
|
func (s *service) SaveHTTP(h *HTTP) {
|
||||||
s.httpRequestHistogram.WithLabelValues(h.Handler, h.Method, h.StatusCode).Observe(h.Duration)
|
s.httpRequestHistogram.WithLabelValues(h.Handler, h.Method, h.StatusCode).Observe(h.Duration)
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -1,7 +1,7 @@
|
|||||||
package password
|
package password
|
||||||
|
|
||||||
//UseCase interface
|
//Service interface
|
||||||
type UseCase interface {
|
type Service interface {
|
||||||
Generate(raw string) (string, error)
|
Generate(raw string) (string, error)
|
||||||
Compare(p1, p2 string) error
|
Compare(p1, p2 string) error
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user