spend-sparrow/db/auth_test.go

package db

import (
	"database/sql"
	"me-fit/types"
	"testing"
	"time"

	"github.com/google/uuid"
	"github.com/stretchr/testify/assert"
)

func setupDb(t *testing.T) *sql.DB {
	db, err := sql.Open("sqlite3", ":memory:")
	if err != nil {
		t.Fatalf("Error opening database: %v", err)
	}
	t.Cleanup(func() {
		db.Close()
	})

	err = RunMigrations(db, "../")
	if err != nil {
		t.Fatalf("Error running migrations: %v", err)
	}

	return db
}

func TestUser(t *testing.T) {
	t.Parallel()

	t.Run("should insert and get the same", func(t *testing.T) {
		t.Parallel()
		db := setupDb(t)

		underTest := AuthSqlite{db: db}

		verifiedAt := time.Date(2020, 1, 5, 13, 0, 0, 0, time.UTC)
		createAt := time.Date(2020, 1, 5, 12, 0, 0, 0, time.UTC)
		expected := NewUser(uuid.New(), "some@email.de", true, &verifiedAt, false, []byte("somePass"), []byte("someSalt"), createAt)

		err := underTest.InsertUser(expected)
		assert.Nil(t, err)

		actual, err := underTest.GetUser(expected.Id)
		assert.Nil(t, err)
		assert.Equal(t, expected, actual)

		actual, err = underTest.GetUserByEmail(expected.Email)
		assert.Nil(t, err)
		assert.Equal(t, expected, actual)
	})
	t.Run("should return ErrNotFound", func(t *testing.T) {
		t.Parallel()
		db := setupDb(t)

		underTest := AuthSqlite{db: db}

		_, err := underTest.GetUserByEmail("nonExistentEmail")
		assert.Equal(t, ErrNotFound, err)
	})
	t.Run("should return ErrUserExist", func(t *testing.T) {
		t.Parallel()
		db := setupDb(t)

		underTest := AuthSqlite{db: db}

		verifiedAt := time.Date(2020, 1, 5, 13, 0, 0, 0, time.UTC)
		createAt := time.Date(2020, 1, 5, 12, 0, 0, 0, time.UTC)
		user := NewUser(uuid.New(), "some@email.de", true, &verifiedAt, false, []byte("somePass"), []byte("someSalt"), createAt)

		err := underTest.InsertUser(user)
		assert.Nil(t, err)

		err = underTest.InsertUser(user)
		assert.Equal(t, ErrAlreadyExists, err)
	})
	t.Run("should return ErrInternal on missing NOT NULL fields", func(t *testing.T) {
		t.Parallel()
		db := setupDb(t)

		underTest := AuthSqlite{db: db}

		createAt := time.Date(2020, 1, 5, 12, 0, 0, 0, time.UTC)
		user := NewUser(uuid.New(), "some@email.de", false, nil, false, []byte("somePass"), nil, createAt)

		err := underTest.InsertUser(user)
		assert.Equal(t, types.ErrInternal, err)
	})
}

func TestToken(t *testing.T) {
	t.Parallel()

	t.Run("should insert and get the same", func(t *testing.T) {
		t.Parallel()
		db := setupDb(t)

		underTest := AuthSqlite{db: db}

		createAt := time.Date(2020, 1, 5, 12, 0, 0, 0, time.UTC)
		expiresAt := createAt.Add(24 * time.Hour)
		expected := NewToken(uuid.New(), "sessionId", "token", TokenTypeCsrf, createAt, expiresAt)

		err := underTest.InsertToken(expected)
		assert.Nil(t, err)

		actual, err := underTest.GetToken(expected.Token)
		assert.Nil(t, err)
		assert.Equal(t, expected, actual)

		expected.SessionId = ""
		actuals, err := underTest.GetTokensByUserIdAndType(expected.UserId, expected.Type)
		assert.Nil(t, err)
		assert.Equal(t, []*Token{expected}, actuals)

		expected.SessionId = "sessionId"
		expected.UserId = uuid.Nil
		actuals, err = underTest.GetTokensBySessionIdAndType(expected.SessionId, expected.Type)
		assert.Nil(t, err)
		assert.Equal(t, []*Token{expected}, actuals)
	})
	t.Run("should insert and return multiple tokens", func(t *testing.T) {
		t.Parallel()
		db := setupDb(t)

		underTest := AuthSqlite{db: db}

		createAt := time.Date(2020, 1, 5, 12, 0, 0, 0, time.UTC)
		expiresAt := createAt.Add(24 * time.Hour)
		userId := uuid.New()
		expected1 := NewToken(userId, "sessionId", "token1", TokenTypeCsrf, createAt, expiresAt)
		expected2 := NewToken(userId, "sessionId", "token2", TokenTypeCsrf, createAt, expiresAt)

		err := underTest.InsertToken(expected1)
		assert.Nil(t, err)
		err = underTest.InsertToken(expected2)
		assert.Nil(t, err)

		expected1.UserId = uuid.Nil
		expected2.UserId = uuid.Nil
		actuals, err := underTest.GetTokensBySessionIdAndType(expected1.SessionId, expected1.Type)
		assert.Nil(t, err)
		assert.Equal(t, []*Token{expected1, expected2}, actuals)

		expected1.SessionId = ""
		expected2.SessionId = ""
		expected1.UserId = userId
		expected2.UserId = userId
		actuals, err = underTest.GetTokensByUserIdAndType(userId, expected1.Type)
		assert.Nil(t, err)
		assert.Equal(t, []*Token{expected1, expected2}, actuals)

	})
	t.Run("should return ErrNotFound", func(t *testing.T) {
		t.Parallel()
		db := setupDb(t)

		underTest := AuthSqlite{db: db}

		_, err := underTest.GetToken("nonExistent")
		assert.Equal(t, ErrNotFound, err)

		_, err = underTest.GetTokensByUserIdAndType(uuid.New(), TokenTypeEmailVerify)
		assert.Equal(t, ErrNotFound, err)

		_, err = underTest.GetTokensBySessionIdAndType("sessionId", TokenTypeEmailVerify)
		assert.Equal(t, ErrNotFound, err)
	})
	t.Run("should return ErrAlreadyExists", func(t *testing.T) {
		t.Parallel()
		db := setupDb(t)

		underTest := AuthSqlite{db: db}

		verifiedAt := time.Date(2020, 1, 5, 13, 0, 0, 0, time.UTC)
		createAt := time.Date(2020, 1, 5, 12, 0, 0, 0, time.UTC)
		user := NewUser(uuid.New(), "some@email.de", true, &verifiedAt, false, []byte("somePass"), []byte("someSalt"), createAt)

		err := underTest.InsertUser(user)
		assert.Nil(t, err)

		err = underTest.InsertUser(user)
		assert.Equal(t, ErrAlreadyExists, err)
	})
	t.Run("should return ErrInternal on missing NOT NULL fields", func(t *testing.T) {
		t.Parallel()
		db := setupDb(t)

		underTest := AuthSqlite{db: db}

		createAt := time.Date(2020, 1, 5, 12, 0, 0, 0, time.UTC)
		user := NewUser(uuid.New(), "some@email.de", false, nil, false, []byte("somePass"), nil, createAt)

		err := underTest.InsertUser(user)
		assert.Equal(t, types.ErrInternal, err)
	})
}