fix: create RandomGenerator interface and struct for testing purpose #181

This commit is contained in:
2024-10-05 13:49:43 +02:00
parent d36f880a01
commit 6b033e2c2e
6 changed files with 125 additions and 55 deletions

View File

@@ -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:

View File

@@ -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)

View File

@@ -2,7 +2,6 @@ package service
import ( import (
"context" "context"
"crypto/rand"
"crypto/subtle" "crypto/subtle"
"database/sql" "database/sql"
"errors" "errors"
@@ -26,10 +25,10 @@ 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")
) )
type User struct { type User struct {
@@ -53,16 +52,18 @@ type ServiceAuth interface {
} }
type ServiceAuthImpl struct { type ServiceAuthImpl struct {
dbAuth db.DbAuth dbAuth db.DbAuth
serverSettings *types.ServerSettings randomGenerator RandomGenerator
mailService MailService serverSettings *types.ServerSettings
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,
serverSettings: serverSettings, randomGenerator: randomGenerator,
mailService: NewMailService(serverSettings), serverSettings: 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
} }
} }

View File

@@ -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)
}
})
}

View 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()
}

View File

@@ -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
}