feat: BAC-39 Authentication (#114)
Reviewed-on: #114 Co-authored-by: Janis <janis.e.20@gmx.de> Co-committed-by: Janis <janis.e.20@gmx.de>
This commit is contained in:
161
knockoutwhistweb/app/logic/user/impl/HibernateUserManager.scala
Normal file
161
knockoutwhistweb/app/logic/user/impl/HibernateUserManager.scala
Normal file
@@ -0,0 +1,161 @@
|
||||
package logic.user.impl
|
||||
|
||||
import com.typesafe.config.Config
|
||||
import jakarta.inject.Inject
|
||||
import jakarta.persistence.EntityManager
|
||||
import logic.user.UserManager
|
||||
import model.users.{User, UserEntity}
|
||||
import services.OpenIDUserInfo
|
||||
import util.UserHash
|
||||
|
||||
import javax.inject.Singleton
|
||||
import scala.jdk.CollectionConverters.*
|
||||
|
||||
@Singleton
|
||||
class HibernateUserManager @Inject()(em: EntityManager, config: Config) extends UserManager {
|
||||
|
||||
override def addUser(name: String, password: String): Boolean = {
|
||||
try {
|
||||
// Check if user already exists
|
||||
val existing = em.createQuery("SELECT u FROM UserEntity u WHERE u.username = :username", classOf[UserEntity])
|
||||
.setParameter("username", name)
|
||||
.getResultList
|
||||
|
||||
if (!existing.isEmpty) {
|
||||
return false
|
||||
}
|
||||
|
||||
// Create new user
|
||||
val userEntity = UserEntity.fromUser(User(
|
||||
internalId = 0L, // Will be set by database
|
||||
id = java.util.UUID.randomUUID(),
|
||||
name = name,
|
||||
passwordHash = UserHash.hashPW(password)
|
||||
))
|
||||
|
||||
em.persist(userEntity)
|
||||
em.flush()
|
||||
true
|
||||
} catch {
|
||||
case _: Exception => false
|
||||
}
|
||||
}
|
||||
|
||||
override def addOpenIDUser(name: String, userInfo: OpenIDUserInfo): Boolean = {
|
||||
try {
|
||||
// Check if user already exists
|
||||
val existing = em.createQuery("SELECT u FROM UserEntity u WHERE u.username = :username", classOf[UserEntity])
|
||||
.setParameter("username", name)
|
||||
.getResultList
|
||||
|
||||
if (!existing.isEmpty) {
|
||||
return false
|
||||
}
|
||||
|
||||
// Check if OpenID user already exists
|
||||
val existingOpenID = em.createQuery(
|
||||
"SELECT u FROM UserEntity u WHERE u.openidProvider = :provider AND u.openidProviderId = :providerId",
|
||||
classOf[UserEntity]
|
||||
)
|
||||
.setParameter("provider", userInfo.provider)
|
||||
.setParameter("providerId", userInfo.id)
|
||||
.getResultList
|
||||
|
||||
if (!existingOpenID.isEmpty) {
|
||||
return false
|
||||
}
|
||||
|
||||
// Create new OpenID user
|
||||
val userEntity = UserEntity.fromOpenIDUser(name, userInfo)
|
||||
|
||||
em.persist(userEntity)
|
||||
em.flush()
|
||||
true
|
||||
} catch {
|
||||
case _: Exception => false
|
||||
}
|
||||
}
|
||||
|
||||
override def authenticate(name: String, password: String): Option[User] = {
|
||||
try {
|
||||
val users = em.createQuery("SELECT u FROM UserEntity u WHERE u.username = :username", classOf[UserEntity])
|
||||
.setParameter("username", name)
|
||||
.getResultList
|
||||
|
||||
if (users.isEmpty) {
|
||||
return None
|
||||
}
|
||||
|
||||
val userEntity = users.get(0)
|
||||
if (UserHash.verifyUser(password, userEntity.toUser)) {
|
||||
Some(userEntity.toUser)
|
||||
} else {
|
||||
None
|
||||
}
|
||||
} catch {
|
||||
case _: Exception => None
|
||||
}
|
||||
}
|
||||
|
||||
override def authenticateOpenID(provider: String, providerId: String): Option[User] = {
|
||||
try {
|
||||
val users = em.createQuery(
|
||||
"SELECT u FROM UserEntity u WHERE u.openidProvider = :provider AND u.openidProviderId = :providerId",
|
||||
classOf[UserEntity]
|
||||
)
|
||||
.setParameter("provider", provider)
|
||||
.setParameter("providerId", providerId)
|
||||
.getResultList
|
||||
|
||||
if (users.isEmpty) {
|
||||
None
|
||||
} else {
|
||||
Some(users.get(0).toUser)
|
||||
}
|
||||
} catch {
|
||||
case _: Exception => None
|
||||
}
|
||||
}
|
||||
|
||||
override def userExists(name: String): Option[User] = {
|
||||
try {
|
||||
val users = em.createQuery("SELECT u FROM UserEntity u WHERE u.username = :username", classOf[UserEntity])
|
||||
.setParameter("username", name)
|
||||
.getResultList
|
||||
|
||||
if (users.isEmpty) {
|
||||
None
|
||||
} else {
|
||||
Some(users.get(0).toUser)
|
||||
}
|
||||
} catch {
|
||||
case _: Exception => None
|
||||
}
|
||||
}
|
||||
|
||||
override def userExistsById(id: Long): Option[User] = {
|
||||
try {
|
||||
Option(em.find(classOf[UserEntity], id)).map(_.toUser)
|
||||
} catch {
|
||||
case _: Exception => None
|
||||
}
|
||||
}
|
||||
|
||||
override def removeUser(name: String): Boolean = {
|
||||
try {
|
||||
val users = em.createQuery("SELECT u FROM UserEntity u WHERE u.username = :username", classOf[UserEntity])
|
||||
.setParameter("username", name)
|
||||
.getResultList
|
||||
|
||||
if (users.isEmpty) {
|
||||
false
|
||||
} else {
|
||||
em.remove(users.get(0))
|
||||
em.flush()
|
||||
true
|
||||
}
|
||||
} catch {
|
||||
case _: Exception => false
|
||||
}
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user