fix: create RandomGenerator interface and struct for testing purpose #181
Some checks failed
Build Docker Image / Explore-Gitea-Actions (push) Has been cancelled
Some checks failed
Build Docker Image / Explore-Gitea-Actions (push) Has been cancelled
This commit is contained in:
@@ -2,6 +2,9 @@ with-expecter: True
|
|||||||
dir: mocks/
|
dir: mocks/
|
||||||
outpkg: mocks
|
outpkg: mocks
|
||||||
packages:
|
packages:
|
||||||
|
me-fit/service:
|
||||||
|
interfaces:
|
||||||
|
RandomGenerator:
|
||||||
me-fit/db:
|
me-fit/db:
|
||||||
interfaces:
|
interfaces:
|
||||||
DbAuth:
|
DbAuth:
|
||||||
|
|||||||
@@ -15,8 +15,9 @@ func GetHandler(d *sql.DB, serverSettings *types.ServerSettings) http.Handler {
|
|||||||
|
|
||||||
router.HandleFunc("/", service.HandleIndexAnd404(d, serverSettings))
|
router.HandleFunc("/", service.HandleIndexAnd404(d, serverSettings))
|
||||||
|
|
||||||
|
randomGenerator := service.NewRandomGeneratorImpl()
|
||||||
dbAuth := db.NewDbAuthSqlite(d)
|
dbAuth := db.NewDbAuthSqlite(d)
|
||||||
serviceAuth := service.NewServiceAuthImpl(dbAuth, serverSettings)
|
serviceAuth := service.NewServiceAuthImpl(dbAuth, randomGenerator, serverSettings)
|
||||||
handlerAuth := NewHandlerAuth(d, serviceAuth, serverSettings)
|
handlerAuth := NewHandlerAuth(d, serviceAuth, serverSettings)
|
||||||
|
|
||||||
// Serve static files (CSS, JS and images)
|
// Serve static files (CSS, JS and images)
|
||||||
|
|||||||
@@ -2,7 +2,6 @@ package service
|
|||||||
|
|
||||||
import (
|
import (
|
||||||
"context"
|
"context"
|
||||||
"crypto/rand"
|
|
||||||
"crypto/subtle"
|
"crypto/subtle"
|
||||||
"database/sql"
|
"database/sql"
|
||||||
"errors"
|
"errors"
|
||||||
@@ -27,7 +26,7 @@ import (
|
|||||||
|
|
||||||
var (
|
var (
|
||||||
ErrInvaidCredentials = errors.New("Invalid email or password")
|
ErrInvaidCredentials = errors.New("Invalid email or password")
|
||||||
ErrPasswordComplexity = errors.New("Password needs to be 8 characters long, contain at least one number, one special, one uppercase and one lowercase character")
|
ErrInvalidPassword = errors.New("Password needs to be 8 characters long, contain at least one number, one special, one uppercase and one lowercase character")
|
||||||
ErrInvalidEmail = errors.New("Invalid email")
|
ErrInvalidEmail = errors.New("Invalid email")
|
||||||
ErrAccountExists = errors.New("Account already exists")
|
ErrAccountExists = errors.New("Account already exists")
|
||||||
)
|
)
|
||||||
@@ -54,13 +53,15 @@ type ServiceAuth interface {
|
|||||||
|
|
||||||
type ServiceAuthImpl struct {
|
type ServiceAuthImpl struct {
|
||||||
dbAuth db.DbAuth
|
dbAuth db.DbAuth
|
||||||
|
randomGenerator RandomGenerator
|
||||||
serverSettings *types.ServerSettings
|
serverSettings *types.ServerSettings
|
||||||
mailService MailService
|
mailService MailService
|
||||||
}
|
}
|
||||||
|
|
||||||
func NewServiceAuthImpl(dbAuth db.DbAuth, serverSettings *types.ServerSettings) *ServiceAuthImpl {
|
func NewServiceAuthImpl(dbAuth db.DbAuth, randomGenerator RandomGenerator, serverSettings *types.ServerSettings) *ServiceAuthImpl {
|
||||||
return &ServiceAuthImpl{
|
return &ServiceAuthImpl{
|
||||||
dbAuth: dbAuth,
|
dbAuth: dbAuth,
|
||||||
|
randomGenerator: randomGenerator,
|
||||||
serverSettings: serverSettings,
|
serverSettings: serverSettings,
|
||||||
mailService: NewMailService(serverSettings),
|
mailService: NewMailService(serverSettings),
|
||||||
}
|
}
|
||||||
@@ -91,9 +92,8 @@ func (service ServiceAuthImpl) SignUp(email string, password string) (*User, err
|
|||||||
return nil, ErrInvalidEmail
|
return nil, ErrInvalidEmail
|
||||||
}
|
}
|
||||||
|
|
||||||
err = checkPassword(password)
|
if !isPasswordValid(password) {
|
||||||
if err != nil {
|
return nil, ErrInvalidPassword
|
||||||
return nil, err
|
|
||||||
}
|
}
|
||||||
|
|
||||||
userId, err := uuid.NewRandom()
|
userId, err := uuid.NewRandom()
|
||||||
@@ -102,10 +102,8 @@ func (service ServiceAuthImpl) SignUp(email string, password string) (*User, err
|
|||||||
return nil, types.ErrInternal
|
return nil, types.ErrInternal
|
||||||
}
|
}
|
||||||
|
|
||||||
salt := make([]byte, 16)
|
salt, err := service.randomGenerator.Bytes(16)
|
||||||
_, err = rand.Read(salt)
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.LogError("Could not generate salt", err)
|
|
||||||
return nil, types.ErrInternal
|
return nil, types.ErrInternal
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -134,9 +132,8 @@ func (service ServiceAuthImpl) SendVerificationMail(user *User) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
if token == "" {
|
if token == "" {
|
||||||
token, err := utils.RandomToken()
|
token, err := service.randomGenerator.String(32)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.LogError("Could not generate token", err)
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -407,9 +404,8 @@ func HandleChangePasswordComp(db *sql.DB) http.HandlerFunc {
|
|||||||
currPass := r.FormValue("current-password")
|
currPass := r.FormValue("current-password")
|
||||||
newPass := r.FormValue("new-password")
|
newPass := r.FormValue("new-password")
|
||||||
|
|
||||||
err := checkPassword(newPass)
|
if !isPasswordValid(newPass) {
|
||||||
if err != nil {
|
utils.TriggerToast(w, r, "error", ErrInvalidPassword.Error())
|
||||||
utils.TriggerToast(w, r, "error", err.Error())
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -423,7 +419,7 @@ func HandleChangePasswordComp(db *sql.DB) http.HandlerFunc {
|
|||||||
salt []byte
|
salt []byte
|
||||||
)
|
)
|
||||||
|
|
||||||
err = db.QueryRow("SELECT password, salt FROM user WHERE user_uuid = ?", user.Id).Scan(&storedHash, &salt)
|
err := db.QueryRow("SELECT password, salt FROM user WHERE user_uuid = ?", user.Id).Scan(&storedHash, &salt)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.LogError("Could not get password", err)
|
utils.LogError("Could not get password", err)
|
||||||
utils.TriggerToast(w, r, "error", "Internal Server Error")
|
utils.TriggerToast(w, r, "error", "Internal Server Error")
|
||||||
@@ -467,9 +463,8 @@ func HandleActualResetPasswordComp(db *sql.DB) http.HandlerFunc {
|
|||||||
|
|
||||||
newPass := r.FormValue("new-password")
|
newPass := r.FormValue("new-password")
|
||||||
|
|
||||||
err = checkPassword(newPass)
|
if !isPasswordValid(newPass) {
|
||||||
if err != nil {
|
utils.TriggerToast(w, r, "error", ErrInvalidPassword.Error())
|
||||||
utils.TriggerToast(w, r, "error", err.Error())
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -511,6 +506,7 @@ func HandleActualResetPasswordComp(db *sql.DB) http.HandlerFunc {
|
|||||||
utils.TriggerToast(w, r, "success", "Password changed")
|
utils.TriggerToast(w, r, "success", "Password changed")
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func HandleResetPasswordComp(db *sql.DB, serverSettings *types.ServerSettings) http.HandlerFunc {
|
func HandleResetPasswordComp(db *sql.DB, serverSettings *types.ServerSettings) http.HandlerFunc {
|
||||||
mailService := NewMailService(serverSettings)
|
mailService := NewMailService(serverSettings)
|
||||||
return func(w http.ResponseWriter, r *http.Request) {
|
return func(w http.ResponseWriter, r *http.Request) {
|
||||||
@@ -521,9 +517,8 @@ func HandleResetPasswordComp(db *sql.DB, serverSettings *types.ServerSettings) h
|
|||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
token, err := utils.RandomToken()
|
token, err := NewRandomGeneratorImpl().String(32)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.LogError("Could not generate token", err)
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -562,9 +557,8 @@ func HandleResetPasswordComp(db *sql.DB, serverSettings *types.ServerSettings) h
|
|||||||
}
|
}
|
||||||
|
|
||||||
func TryCreateSessionAndSetCookie(r *http.Request, w http.ResponseWriter, db *sql.DB, user_uuid uuid.UUID) error {
|
func TryCreateSessionAndSetCookie(r *http.Request, w http.ResponseWriter, db *sql.DB, user_uuid uuid.UUID) error {
|
||||||
sessionId, err := utils.RandomToken()
|
sessionId, err := NewRandomGeneratorImpl().String(32)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
utils.LogError("Could not generate session ID", err)
|
|
||||||
return types.ErrInternal
|
return types.ErrInternal
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -599,15 +593,15 @@ func GetHashPassword(password string, salt []byte) []byte {
|
|||||||
return argon2.IDKey([]byte(password), salt, 1, 64*1024, 1, 16)
|
return argon2.IDKey([]byte(password), salt, 1, 64*1024, 1, 16)
|
||||||
}
|
}
|
||||||
|
|
||||||
func checkPassword(password string) error {
|
func isPasswordValid(password string) bool {
|
||||||
|
|
||||||
if len(password) < 8 ||
|
if len(password) < 8 ||
|
||||||
!strings.ContainsAny(password, "0123456789") ||
|
!strings.ContainsAny(password, "0123456789") ||
|
||||||
!strings.ContainsAny(password, "ABCDEFGHIJKLMNOPQRSTUVWXYZ") ||
|
!strings.ContainsAny(password, "ABCDEFGHIJKLMNOPQRSTUVWXYZ") ||
|
||||||
!strings.ContainsAny(password, "abcdefghijklmnopqrstuvwxyz") ||
|
!strings.ContainsAny(password, "abcdefghijklmnopqrstuvwxyz") ||
|
||||||
!strings.ContainsAny(password, "!@#$%^&*()_+-=[]{}\\|;:'\",.<>/?") {
|
!strings.ContainsAny(password, "!@#$%^&*()_+-=[]{}\\|;:'\",.<>/?") {
|
||||||
return ErrPasswordComplexity
|
return false
|
||||||
} else {
|
} else {
|
||||||
return nil
|
return true
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
@@ -32,8 +32,9 @@ func TestSignIn(t *testing.T) {
|
|||||||
|
|
||||||
mockDbAuth := mocks.NewMockDbAuth(t)
|
mockDbAuth := mocks.NewMockDbAuth(t)
|
||||||
mockDbAuth.EXPECT().GetUser("test@test.de").Return(user, nil)
|
mockDbAuth.EXPECT().GetUser("test@test.de").Return(user, nil)
|
||||||
|
mockRandom := mocks.NewMockRandomGenerator(t)
|
||||||
|
|
||||||
underTest := NewServiceAuthImpl(mockDbAuth, &types.ServerSettings{})
|
underTest := NewServiceAuthImpl(mockDbAuth, mockRandom, &types.ServerSettings{})
|
||||||
|
|
||||||
actualUser, err := underTest.SignIn(user.Email, "password")
|
actualUser, err := underTest.SignIn(user.Email, "password")
|
||||||
assert.Nil(t, err)
|
assert.Nil(t, err)
|
||||||
@@ -65,8 +66,9 @@ func TestSignIn(t *testing.T) {
|
|||||||
|
|
||||||
mockDbAuth := mocks.NewMockDbAuth(t)
|
mockDbAuth := mocks.NewMockDbAuth(t)
|
||||||
mockDbAuth.EXPECT().GetUser(user.Email).Return(user, nil)
|
mockDbAuth.EXPECT().GetUser(user.Email).Return(user, nil)
|
||||||
|
mockRandom := mocks.NewMockRandomGenerator(t)
|
||||||
|
|
||||||
underTest := NewServiceAuthImpl(mockDbAuth, &types.ServerSettings{})
|
underTest := NewServiceAuthImpl(mockDbAuth, mockRandom, &types.ServerSettings{})
|
||||||
|
|
||||||
_, err := underTest.SignIn("test@test.de", "wrong password")
|
_, err := underTest.SignIn("test@test.de", "wrong password")
|
||||||
|
|
||||||
@@ -77,8 +79,9 @@ func TestSignIn(t *testing.T) {
|
|||||||
|
|
||||||
mockDbAuth := mocks.NewMockDbAuth(t)
|
mockDbAuth := mocks.NewMockDbAuth(t)
|
||||||
mockDbAuth.EXPECT().GetUser("test").Return(nil, db.ErrUserNotFound)
|
mockDbAuth.EXPECT().GetUser("test").Return(nil, db.ErrUserNotFound)
|
||||||
|
mockRandom := mocks.NewMockRandomGenerator(t)
|
||||||
|
|
||||||
underTest := NewServiceAuthImpl(mockDbAuth, &types.ServerSettings{})
|
underTest := NewServiceAuthImpl(mockDbAuth, mockRandom, &types.ServerSettings{})
|
||||||
|
|
||||||
_, err := underTest.SignIn("test", "test")
|
_, err := underTest.SignIn("test", "test")
|
||||||
assert.Equal(t, ErrInvaidCredentials, err)
|
assert.Equal(t, ErrInvaidCredentials, err)
|
||||||
@@ -88,11 +91,48 @@ func TestSignIn(t *testing.T) {
|
|||||||
|
|
||||||
mockDbAuth := mocks.NewMockDbAuth(t)
|
mockDbAuth := mocks.NewMockDbAuth(t)
|
||||||
mockDbAuth.EXPECT().GetUser("test").Return(nil, errors.New("Some undefined error"))
|
mockDbAuth.EXPECT().GetUser("test").Return(nil, errors.New("Some undefined error"))
|
||||||
|
mockRandom := mocks.NewMockRandomGenerator(t)
|
||||||
|
|
||||||
underTest := NewServiceAuthImpl(mockDbAuth, &types.ServerSettings{})
|
underTest := NewServiceAuthImpl(mockDbAuth, mockRandom, &types.ServerSettings{})
|
||||||
|
|
||||||
_, err := underTest.SignIn("test", "test")
|
_, err := underTest.SignIn("test", "test")
|
||||||
|
|
||||||
assert.Equal(t, types.ErrInternal, err)
|
assert.Equal(t, types.ErrInternal, err)
|
||||||
})
|
})
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func TestSignUp(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
t.Run("should check for correct email address", func(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
|
||||||
|
mockDbAuth := mocks.NewMockDbAuth(t)
|
||||||
|
mockRandom := mocks.NewMockRandomGenerator(t)
|
||||||
|
|
||||||
|
underTest := NewServiceAuthImpl(mockDbAuth, mockRandom, &types.ServerSettings{})
|
||||||
|
|
||||||
|
_, err := underTest.SignUp("invalid email address", "SomeStrongPassword123!")
|
||||||
|
|
||||||
|
assert.Equal(t, ErrInvalidEmail, err)
|
||||||
|
})
|
||||||
|
t.Run("should check for password complexity", func(t *testing.T) {
|
||||||
|
t.Parallel()
|
||||||
|
|
||||||
|
mockDbAuth := mocks.NewMockDbAuth(t)
|
||||||
|
mockRandom := mocks.NewMockRandomGenerator(t)
|
||||||
|
|
||||||
|
underTest := NewServiceAuthImpl(mockDbAuth, mockRandom, &types.ServerSettings{})
|
||||||
|
|
||||||
|
weakPasswords := []string{
|
||||||
|
"123!ab", // too short
|
||||||
|
"no_upper_case_123",
|
||||||
|
"NO_LOWER_CASE_123",
|
||||||
|
"noSpecialChar123",
|
||||||
|
}
|
||||||
|
|
||||||
|
for _, password := range weakPasswords {
|
||||||
|
_, err := underTest.SignUp("some@valid.email", password)
|
||||||
|
assert.Equal(t, ErrInvalidPassword, err)
|
||||||
|
}
|
||||||
|
})
|
||||||
|
}
|
||||||
|
|||||||
48
service/random_generator.go
Normal file
48
service/random_generator.go
Normal file
@@ -0,0 +1,48 @@
|
|||||||
|
package service
|
||||||
|
|
||||||
|
import (
|
||||||
|
"me-fit/types"
|
||||||
|
|
||||||
|
"crypto/rand"
|
||||||
|
"encoding/base64"
|
||||||
|
"log/slog"
|
||||||
|
|
||||||
|
"github.com/google/uuid"
|
||||||
|
)
|
||||||
|
|
||||||
|
type RandomGenerator interface {
|
||||||
|
Bytes(size int) ([]byte, error)
|
||||||
|
String(size int) (string, error)
|
||||||
|
UUID() (uuid.UUID, error)
|
||||||
|
}
|
||||||
|
|
||||||
|
type RandomGeneratorImpl struct {
|
||||||
|
}
|
||||||
|
|
||||||
|
func NewRandomGeneratorImpl() *RandomGeneratorImpl {
|
||||||
|
return &RandomGeneratorImpl{}
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *RandomGeneratorImpl) Bytes(size int) ([]byte, error) {
|
||||||
|
b := make([]byte, 32)
|
||||||
|
_, err := rand.Read(b)
|
||||||
|
if err != nil {
|
||||||
|
slog.Error("Error generating random bytes: " + err.Error())
|
||||||
|
return []byte{}, types.ErrInternal
|
||||||
|
}
|
||||||
|
|
||||||
|
return b, nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *RandomGeneratorImpl) String(size int) (string, error) {
|
||||||
|
bytes, err := r.Bytes(size)
|
||||||
|
if err != nil {
|
||||||
|
return "", types.ErrInternal
|
||||||
|
}
|
||||||
|
|
||||||
|
return base64.StdEncoding.EncodeToString(bytes), nil
|
||||||
|
}
|
||||||
|
|
||||||
|
func (r *RandomGeneratorImpl) UUID() (uuid.UUID, error) {
|
||||||
|
return uuid.NewRandom()
|
||||||
|
}
|
||||||
@@ -1,16 +0,0 @@
|
|||||||
package utils
|
|
||||||
|
|
||||||
import (
|
|
||||||
"crypto/rand"
|
|
||||||
"encoding/base64"
|
|
||||||
)
|
|
||||||
|
|
||||||
func RandomToken() (string, error) {
|
|
||||||
b := make([]byte, 32)
|
|
||||||
_, err := rand.Read(b)
|
|
||||||
if err != nil {
|
|
||||||
return "", err
|
|
||||||
}
|
|
||||||
|
|
||||||
return base64.StdEncoding.EncodeToString(b), nil
|
|
||||||
}
|
|
||||||
Reference in New Issue
Block a user