72 lines
1.8 KiB
Go
72 lines
1.8 KiB
Go
package services
|
|
|
|
import (
|
|
"database/sql"
|
|
"errors"
|
|
"time"
|
|
|
|
"git.jamestombleson.com/jtom38/go-cook/internal/domain"
|
|
"git.jamestombleson.com/jtom38/go-cook/internal/repositories"
|
|
"github.com/google/uuid"
|
|
)
|
|
|
|
type RefreshToken interface {
|
|
Create(username string, expiresAt time.Time) (string, error)
|
|
GetByName(name string) (domain.RefreshTokenEntity, error)
|
|
Delete(id int64) (int64, error)
|
|
IsRequestValid(username, refreshToken string, jwtExpiresAt time.Time) error
|
|
}
|
|
|
|
type RefreshTokenService struct {
|
|
table repositories.RefreshTokenTable
|
|
}
|
|
|
|
func NewRefreshTokenService(conn *sql.DB) RefreshTokenService {
|
|
return RefreshTokenService{
|
|
table: repositories.NewRefreshTokenRepository(conn),
|
|
}
|
|
}
|
|
|
|
func (rt RefreshTokenService) Create(username string, expiresAt time.Time) (string, error) {
|
|
token, err := uuid.NewV7()
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
rows, err := rt.table.Create(username, token.String(), expiresAt)
|
|
if err != nil {
|
|
return "", err
|
|
}
|
|
|
|
if rows != 1 {
|
|
return "", errors.New("expected one row but got none")
|
|
}
|
|
return token.String(), nil
|
|
}
|
|
|
|
// Find the saved refresh token for a user and return it if it exists
|
|
func (rt RefreshTokenService) GetByName(name string) (domain.RefreshTokenEntity, error) {
|
|
return rt.table.GetByUsername(name)
|
|
}
|
|
|
|
// This will request that a object is removed from the database
|
|
func (rt RefreshTokenService) Delete(id int64) (int64, error) {
|
|
return rt.table.DeleteById(id)
|
|
}
|
|
|
|
func (rt RefreshTokenService) IsRequestValid(username, refreshToken string, jwtExpiresAt time.Time) error {
|
|
token, err := rt.GetByName(username)
|
|
if err != nil {
|
|
return err
|
|
}
|
|
|
|
if (token.Token != refreshToken) {
|
|
return errors.New("the refresh token given does not match")
|
|
}
|
|
|
|
if (token.ExpiresAt != jwtExpiresAt) {
|
|
return errors.New("the time when the jwt token expires does not match what was given")
|
|
}
|
|
|
|
return nil
|
|
} |