[db] Patch cache problem
continuous-integration/drone/push Build is passing Details

pull/13/head
luevard 11 months ago
parent f2a84adfcc
commit 1c3fb9a7f3

@ -40,15 +40,17 @@ class PostgresUserDataSource(private val database: Database) : UserDataSource {
database.users.removeIf { (it.username eq username) or (it.email eq username) } > 0 database.users.removeIf { (it.username eq username) or (it.email eq username) } > 0
override fun addCoins(username: String, amount: Int) { override fun addCoins(username: String, amount: Int) {
database.users database.update(UsersEntity) {
.find { it.username eq username } set(it.nbCoins, it.nbCoins + amount)
?.set(UsersEntity.nbCoins.name, UsersEntity.nbCoins + amount) where { it.username eq username }
}
} }
override fun removeCoins(username: String, amount: Int) { override fun removeCoins(username: String, amount: Int) {
database.users database.update(UsersEntity) {
.find { it.username eq username } set(it.nbCoins, it.nbCoins - amount)
?.set(UsersEntity.nbCoins.name, UsersEntity.nbCoins - amount) where { it.username eq username }
}
} }
override fun userExists(username: String) = override fun userExists(username: String) =

@ -56,24 +56,25 @@ fun Application.userRouter() {
if (RegexCheckerUser.isEmailInvalid(tempUser.email)) { if (RegexCheckerUser.isEmailInvalid(tempUser.email)) {
call.respond(HttpStatusCode.Forbidden, ApiMessage.INVALID_MAIL) call.respond(HttpStatusCode.Forbidden, ApiMessage.INVALID_MAIL)
} }
if (userDataSource.userExists(tempUser.username)) { else if (userDataSource.userExists(tempUser.username)) {
call.respond(HttpStatusCode.Conflict, ApiMessage.USER_ALREADY_EXISTS) call.respond(HttpStatusCode.Conflict, ApiMessage.USER_ALREADY_EXISTS)
} }
if(userDataSource.emailExists(tempUser.email)){ else if (userDataSource.emailExists(tempUser.email)) {
call.respond(HttpStatusCode.Conflict, ApiMessage.MAIL_ALREADY_EXISTS) call.respond(HttpStatusCode.Conflict, ApiMessage.MAIL_ALREADY_EXISTS)
} else {
val user = User(
id = UUID.randomUUID().toString(),
username = tempUser.username,
email = tempUser.email,
password = tempUser.password,
nbCoins = DEFAULT_COINS,
token = null
)
CryptManagerUser.passwordCrypt(user)
user.token = tokenManagerUser.generateOrReplaceJWTToken(user)
userDataSource.addUser(user)
call.respond(HttpStatusCode.Created, user)
} }
val user = User(
id = UUID.randomUUID().toString(),
username = tempUser.username,
email = tempUser.email,
password = tempUser.password,
nbCoins = DEFAULT_COINS,
token = null
)
CryptManagerUser.passwordCrypt(user)
user.token = tokenManagerUser.generateOrReplaceJWTToken(user)
userDataSource.addUser(user)
call.respond(HttpStatusCode.Created, user)
} }
post("/users/login", { post("/users/login", {

Loading…
Cancel
Save