Compare commits
No commits in common. "spring-configuration" and "master" have entirely different histories.
spring-con
...
master
12 changed files with 85 additions and 198 deletions
|
@ -21,7 +21,7 @@ repositories {
|
||||||
val exposedVersion = "0.41.1"
|
val exposedVersion = "0.41.1"
|
||||||
val postgresVersion = "42.5.4"
|
val postgresVersion = "42.5.4"
|
||||||
val telegramBotVersion = "6.5.0"
|
val telegramBotVersion = "6.5.0"
|
||||||
val springBootVersion = "2.7.14"
|
val springBootVersion = "3.1.0"
|
||||||
val serializationVersion = "1.5.0"
|
val serializationVersion = "1.5.0"
|
||||||
val loggingVersion = "3.0.5"
|
val loggingVersion = "3.0.5"
|
||||||
val securityTestVersion = "6.0.2"
|
val securityTestVersion = "6.0.2"
|
||||||
|
@ -34,9 +34,16 @@ dependencies {
|
||||||
implementation("org.telegram:telegrambotsextensions:$telegramBotVersion")
|
implementation("org.telegram:telegrambotsextensions:$telegramBotVersion")
|
||||||
implementation("org.telegram:telegrambots-spring-boot-starter:$telegramBotVersion")
|
implementation("org.telegram:telegrambots-spring-boot-starter:$telegramBotVersion")
|
||||||
|
|
||||||
implementation("org.springframework.boot:spring-boot-starter:$springBootVersion")
|
implementation("org.springframework.boot:spring-boot-starter:$springBootVersion") {
|
||||||
implementation("org.springframework.boot:spring-boot-starter-web:$springBootVersion")
|
exclude("org.springframework.boot:spring-boot-starter-tomcat")
|
||||||
implementation("org.springframework.boot:spring-boot-starter-security:$springBootVersion")
|
}
|
||||||
|
implementation("org.springframework.boot:spring-boot-starter-web:$springBootVersion") {
|
||||||
|
exclude("org.springframework.boot:spring-boot-starter-tomcat")
|
||||||
|
}
|
||||||
|
implementation("org.springframework.boot:spring-boot-starter-security:$springBootVersion") {
|
||||||
|
exclude("org.springframework.boot:spring-boot-starter-tomcat")
|
||||||
|
}
|
||||||
|
implementation("org.springframework.boot:spring-boot-starter-jetty:$springBootVersion")
|
||||||
implementation("com.fasterxml.jackson.module:jackson-module-kotlin:$jacksonVersion")
|
implementation("com.fasterxml.jackson.module:jackson-module-kotlin:$jacksonVersion")
|
||||||
|
|
||||||
implementation("org.jetbrains.kotlin:kotlin-reflect")
|
implementation("org.jetbrains.kotlin:kotlin-reflect")
|
||||||
|
@ -51,6 +58,16 @@ dependencies {
|
||||||
testImplementation("org.springframework.boot:spring-boot-starter-test:$springBootVersion")
|
testImplementation("org.springframework.boot:spring-boot-starter-test:$springBootVersion")
|
||||||
}
|
}
|
||||||
|
|
||||||
|
configurations.all {
|
||||||
|
resolutionStrategy {
|
||||||
|
eachDependency {
|
||||||
|
if (requested.group == "jakarta.servlet") {
|
||||||
|
useVersion("5.0.0")
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
tasks.withType<KotlinCompile> {
|
tasks.withType<KotlinCompile> {
|
||||||
kotlinOptions {
|
kotlinOptions {
|
||||||
freeCompilerArgs = listOf("-Xjsr305=strict")
|
freeCompilerArgs = listOf("-Xjsr305=strict")
|
||||||
|
|
|
@ -3,18 +3,19 @@ package ru.sicamp.sicamphelper.api.command
|
||||||
import kotlinx.coroutines.runBlocking
|
import kotlinx.coroutines.runBlocking
|
||||||
import mu.KLogging
|
import mu.KLogging
|
||||||
import org.telegram.telegrambots.extensions.bots.commandbot.commands.BotCommand
|
import org.telegram.telegrambots.extensions.bots.commandbot.commands.BotCommand
|
||||||
|
import org.telegram.telegrambots.meta.api.methods.send.SendMessage
|
||||||
import org.telegram.telegrambots.meta.api.objects.Chat
|
import org.telegram.telegrambots.meta.api.objects.Chat
|
||||||
|
import org.telegram.telegrambots.meta.api.objects.User
|
||||||
import org.telegram.telegrambots.meta.bots.AbsSender
|
import org.telegram.telegrambots.meta.bots.AbsSender
|
||||||
import ru.sicamp.sicamphelper.db.entity.User
|
|
||||||
import ru.sicamp.sicamphelper.db.table.Users
|
|
||||||
import ru.sicamp.sicamphelper.model.metadata.RequestSource
|
import ru.sicamp.sicamphelper.model.metadata.RequestSource
|
||||||
|
import ru.sicamp.sicamphelper.db.table.Users
|
||||||
import ru.sicamp.sicamphelper.model.request.Request
|
import ru.sicamp.sicamphelper.model.request.Request
|
||||||
import ru.sicamp.sicamphelper.model.request.RequestWrapper
|
import ru.sicamp.sicamphelper.model.request.RequestWrapper
|
||||||
|
import ru.sicamp.sicamphelper.model.response.Response
|
||||||
import ru.sicamp.sicamphelper.model.response.ResponseWrapper
|
import ru.sicamp.sicamphelper.model.response.ResponseWrapper
|
||||||
import ru.sicamp.sicamphelper.model.response.TelegramResponse
|
import ru.sicamp.sicamphelper.model.response.TelegramResponse
|
||||||
import ru.sicamp.sicamphelper.service.UserService
|
import ru.sicamp.sicamphelper.service.UserService
|
||||||
import ru.sicamp.sicamphelper.util.Extractor
|
import ru.sicamp.sicamphelper.util.Extractor
|
||||||
import ru.sicamp.sicamphelper.util.TgUser
|
|
||||||
|
|
||||||
abstract class Command<REQ : Request, RES : TelegramResponse>(
|
abstract class Command<REQ : Request, RES : TelegramResponse>(
|
||||||
private val command: Commands
|
private val command: Commands
|
||||||
|
@ -23,7 +24,7 @@ abstract class Command<REQ : Request, RES : TelegramResponse>(
|
||||||
|
|
||||||
protected abstract suspend fun executeRequest(request: RequestWrapper<REQ>): ResponseWrapper<RES>
|
protected abstract suspend fun executeRequest(request: RequestWrapper<REQ>): ResponseWrapper<RES>
|
||||||
|
|
||||||
override fun execute(absSender: AbsSender?, user: TgUser?, chat: Chat?, arguments: Array<out String>?) {
|
override fun execute(absSender: AbsSender?, user: User?, chat: Chat?, arguments: Array<out String>?) {
|
||||||
val internalUser = authorizeCommand(user) ?: TODO("Respond unauthorized request")
|
val internalUser = authorizeCommand(user) ?: TODO("Respond unauthorized request")
|
||||||
val request = try {
|
val request = try {
|
||||||
RequestWrapper(
|
RequestWrapper(
|
||||||
|
@ -48,7 +49,7 @@ abstract class Command<REQ : Request, RES : TelegramResponse>(
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
private fun authorizeCommand(user: TgUser?): User? = userService.findUserByTgUser(
|
private fun authorizeCommand(user: User?): ru.sicamp.sicamphelper.db.entity.User? = userService.findUserByTgUser(
|
||||||
user ?: error("No user provided for command $commandIdentifier")
|
user ?: error("No user provided for command $commandIdentifier")
|
||||||
).let {
|
).let {
|
||||||
if (it == null) {
|
if (it == null) {
|
||||||
|
|
|
@ -1,25 +1,31 @@
|
||||||
package ru.sicamp.sicamphelper.api.controller
|
package ru.sicamp.sicamphelper.api.controller
|
||||||
|
|
||||||
|
import com.fasterxml.jackson.databind.ObjectMapper
|
||||||
|
import com.fasterxml.jackson.module.kotlin.convertValue
|
||||||
import mu.KLogging
|
import mu.KLogging
|
||||||
import org.springframework.web.bind.annotation.*
|
import org.springframework.web.bind.annotation.*
|
||||||
import ru.sicamp.sicamphelper.model.dto.UserDto
|
import ru.sicamp.sicamphelper.model.dto.UserDto
|
||||||
import ru.sicamp.sicamphelper.model.info.UserInfo
|
|
||||||
import ru.sicamp.sicamphelper.service.UserService
|
import ru.sicamp.sicamphelper.service.UserService
|
||||||
|
|
||||||
@RestController
|
@RestController
|
||||||
class UsersController(
|
class UsersController(
|
||||||
private val userService: UserService,
|
private val userService: UserService,
|
||||||
|
private val objectMapper: ObjectMapper,
|
||||||
) {
|
) {
|
||||||
@PostMapping("/user/create")
|
@PostMapping("/user/create")
|
||||||
fun create(@RequestParam dto: UserDto): UserInfo {
|
fun create(@RequestParam dto: UserDto): String {
|
||||||
return userService.createUser(dto)
|
val user = userService.createUser(dto)
|
||||||
|
return user.toString()
|
||||||
}
|
}
|
||||||
|
|
||||||
@GetMapping("/user/find/{login}")
|
@GetMapping("/custom/users/find/{login}")
|
||||||
fun getUser(@PathVariable(name = "login", required = true) login: String): UserInfo {
|
fun getUser(@PathVariable(name = "login", required = true) login: String): String {
|
||||||
logger.info("Getting user with username: $login")
|
logger.info("Getting user with username: $login!!!!!")
|
||||||
return userService.findUserInfoByLogin(login)
|
return objectMapper.convertValue(userService.loadUserByUsername(login))
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@GetMapping("/test")
|
||||||
|
fun test() = "test"
|
||||||
|
|
||||||
companion object : KLogging()
|
companion object : KLogging()
|
||||||
}
|
}
|
|
@ -1,7 +1,5 @@
|
||||||
package ru.sicamp.sicamphelper.model.data
|
package ru.sicamp.sicamphelper.model.data
|
||||||
|
|
||||||
import ru.sicamp.sicamphelper.util.TgUser
|
|
||||||
|
|
||||||
/**Class extracts user from user input. Also used to represent user in views. Format: @tgUsername|$gateLogin|#userId */
|
/**Class extracts user from user input. Also used to represent user in views. Format: @tgUsername|$gateLogin|#userId */
|
||||||
class UserInput(
|
class UserInput(
|
||||||
input: String
|
input: String
|
||||||
|
@ -21,6 +19,6 @@ class UserInput(
|
||||||
}
|
}
|
||||||
|
|
||||||
companion object {
|
companion object {
|
||||||
fun fromTgUser(tgUser: TgUser) = UserInput(Type.TG_USERNAME.prefix + tgUser.userName)
|
fun fromTgUser(tgUser: org.telegram.telegrambots.meta.api.objects.User) = UserInput(Type.TG_USERNAME.prefix + tgUser.userName)
|
||||||
}
|
}
|
||||||
}
|
}
|
|
@ -1,7 +0,0 @@
|
||||||
package ru.sicamp.sicamphelper.model.info
|
|
||||||
|
|
||||||
data class EntityRef(
|
|
||||||
val type: Info.Type,
|
|
||||||
val id: Long,
|
|
||||||
val name: String
|
|
||||||
)
|
|
|
@ -1,10 +0,0 @@
|
||||||
package ru.sicamp.sicamphelper.model.info
|
|
||||||
|
|
||||||
sealed class Info {
|
|
||||||
abstract val id: Long
|
|
||||||
abstract val type: Type
|
|
||||||
|
|
||||||
enum class Type {
|
|
||||||
USER, GROUP, ROOM //TODO add entities
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,48 +0,0 @@
|
||||||
package ru.sicamp.sicamphelper.model.info
|
|
||||||
|
|
||||||
import ru.sicamp.sicamphelper.db.entity.User
|
|
||||||
import ru.sicamp.sicamphelper.db.table.Users
|
|
||||||
|
|
||||||
data class UserInfo(
|
|
||||||
override val id: Long,
|
|
||||||
override val type: Type,
|
|
||||||
var login: String,
|
|
||||||
var name: String,
|
|
||||||
var supervisor: EntityRef?,
|
|
||||||
var tgId: Long?,
|
|
||||||
var tgUsername: String?,
|
|
||||||
var role: Users.Role,
|
|
||||||
var group: EntityRef,
|
|
||||||
var sex: Users.Sex,
|
|
||||||
var age: Int,
|
|
||||||
var enabled: Boolean,
|
|
||||||
) : Info() {
|
|
||||||
companion object {
|
|
||||||
fun from(user: User?) = user?.let {
|
|
||||||
UserInfo(
|
|
||||||
user.id.value,
|
|
||||||
Type.USER,
|
|
||||||
user.login,
|
|
||||||
user.name,
|
|
||||||
user.supervisor?.let {
|
|
||||||
EntityRef(
|
|
||||||
type = Type.USER,
|
|
||||||
id = it.id.value,
|
|
||||||
name = it.name
|
|
||||||
)
|
|
||||||
},
|
|
||||||
user.tgId,
|
|
||||||
user.tgUsername,
|
|
||||||
user.role,
|
|
||||||
EntityRef(
|
|
||||||
type = Type.GROUP,
|
|
||||||
id = user.group.id.value,
|
|
||||||
name = user.group.name
|
|
||||||
),
|
|
||||||
user.sex,
|
|
||||||
user.age,
|
|
||||||
user.enabled
|
|
||||||
)
|
|
||||||
}
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,70 +0,0 @@
|
||||||
package ru.sicamp.sicamphelper.repository
|
|
||||||
|
|
||||||
import mu.KLogging
|
|
||||||
import org.jetbrains.exposed.dao.load
|
|
||||||
import org.jetbrains.exposed.dao.with
|
|
||||||
import org.jetbrains.exposed.sql.and
|
|
||||||
import org.jetbrains.exposed.sql.transactions.transaction
|
|
||||||
import org.springframework.security.core.userdetails.UsernameNotFoundException
|
|
||||||
import org.springframework.security.crypto.password.PasswordEncoder
|
|
||||||
import org.springframework.stereotype.Repository
|
|
||||||
import ru.sicamp.sicamphelper.db.entity.User
|
|
||||||
import ru.sicamp.sicamphelper.db.table.Users
|
|
||||||
import ru.sicamp.sicamphelper.model.dto.UserDto
|
|
||||||
import java.time.Duration
|
|
||||||
import java.time.LocalDateTime
|
|
||||||
|
|
||||||
@Repository
|
|
||||||
class UserRepository(
|
|
||||||
private val passwordEncoder: PasswordEncoder
|
|
||||||
) {
|
|
||||||
fun findUserByTgUsernameAndId(id: Long, userName: String) = transaction {
|
|
||||||
User.find {
|
|
||||||
(Users.tgId eq id) and
|
|
||||||
(Users.tgUsername eq userName)
|
|
||||||
}.with(
|
|
||||||
User::supervisor,
|
|
||||||
User::group
|
|
||||||
).firstOrNull()
|
|
||||||
}
|
|
||||||
|
|
||||||
fun findUserByUsername(username: String) = transaction {
|
|
||||||
User.find {
|
|
||||||
Users.login eq username
|
|
||||||
}.with(
|
|
||||||
User::supervisor,
|
|
||||||
User::group
|
|
||||||
).firstOrNull() ?: throw UsernameNotFoundException("Not found user with username $username")
|
|
||||||
}
|
|
||||||
|
|
||||||
fun findUserById(id: Long) = transaction {
|
|
||||||
User.findById(id)?.load(
|
|
||||||
User::supervisor,
|
|
||||||
User::group
|
|
||||||
)
|
|
||||||
}
|
|
||||||
|
|
||||||
fun createUser(userDto: UserDto): User = transaction {
|
|
||||||
val now = LocalDateTime.now()
|
|
||||||
logger.info("Creating new user at $now")
|
|
||||||
return@transaction User.new {
|
|
||||||
login = userDto.login
|
|
||||||
_password = passwordEncoder.encode(userDto.password)
|
|
||||||
role = userDto.role
|
|
||||||
name = userDto.name
|
|
||||||
sex = userDto.sex
|
|
||||||
age = userDto.age
|
|
||||||
tgId = userDto.tgId
|
|
||||||
tgUsername = userDto.tgUsername
|
|
||||||
locked = false
|
|
||||||
enabled = userDto.enabled
|
|
||||||
accountExpiration = now + userExpirationTime
|
|
||||||
credentialsExpiration = now + credentialsExpirationTime
|
|
||||||
}
|
|
||||||
}
|
|
||||||
|
|
||||||
companion object : KLogging() {
|
|
||||||
private val userExpirationTime = Duration.ofDays(60)
|
|
||||||
private val credentialsExpirationTime = Duration.ofDays(30)
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -1,16 +0,0 @@
|
||||||
package ru.sicamp.sicamphelper.security
|
|
||||||
|
|
||||||
import org.springframework.security.core.userdetails.UserDetailsService
|
|
||||||
import org.springframework.stereotype.Service
|
|
||||||
import ru.sicamp.sicamphelper.db.entity.User
|
|
||||||
import ru.sicamp.sicamphelper.repository.UserRepository
|
|
||||||
import ru.sicamp.sicamphelper.util.badArgument
|
|
||||||
|
|
||||||
@Service
|
|
||||||
class UserDetailsServiceImpl(
|
|
||||||
private val userRepository: UserRepository
|
|
||||||
) : UserDetailsService {
|
|
||||||
override fun loadUserByUsername(username: String?): User = userRepository.findUserByUsername(
|
|
||||||
username = username ?: badArgument("Username shouldn't be null")
|
|
||||||
)
|
|
||||||
}
|
|
|
@ -1,32 +1,53 @@
|
||||||
package ru.sicamp.sicamphelper.service
|
package ru.sicamp.sicamphelper.service
|
||||||
|
|
||||||
|
import org.jetbrains.exposed.sql.and
|
||||||
|
import org.jetbrains.exposed.sql.transactions.transaction
|
||||||
|
import org.springframework.security.core.userdetails.UserDetailsService
|
||||||
|
import org.springframework.security.crypto.password.PasswordEncoder
|
||||||
import org.springframework.stereotype.Service
|
import org.springframework.stereotype.Service
|
||||||
|
import ru.sicamp.sicamphelper.api.controller.UsersController
|
||||||
import ru.sicamp.sicamphelper.db.entity.User
|
import ru.sicamp.sicamphelper.db.entity.User
|
||||||
|
import ru.sicamp.sicamphelper.db.table.Users
|
||||||
import ru.sicamp.sicamphelper.model.dto.UserDto
|
import ru.sicamp.sicamphelper.model.dto.UserDto
|
||||||
import ru.sicamp.sicamphelper.model.info.UserInfo
|
import java.time.Duration
|
||||||
import ru.sicamp.sicamphelper.repository.UserRepository
|
import java.time.LocalDateTime
|
||||||
import ru.sicamp.sicamphelper.util.TgUser
|
|
||||||
import ru.sicamp.sicamphelper.util.badArgument
|
|
||||||
|
|
||||||
@Service
|
@Service
|
||||||
class UserService(
|
class UserService(
|
||||||
private val userRepository: UserRepository
|
private val passwordEncoder: PasswordEncoder
|
||||||
) {
|
) : UserDetailsService {
|
||||||
fun findUserByTgUser(user: TgUser): User? = userRepository.findUserByTgUsernameAndId(
|
private val userExpirationTime = Duration.ofDays(60)
|
||||||
id = user.id,
|
private val credentialsExpirationTime = Duration.ofDays(30)
|
||||||
userName = user.userName
|
|
||||||
)
|
|
||||||
|
|
||||||
fun findUserInfoByLogin(login: String) = UserInfo.from(
|
fun findUserByTgUser(user: org.telegram.telegrambots.meta.api.objects.User): User? = transaction {
|
||||||
userRepository.findUserByUsername(login)
|
User.find {
|
||||||
) ?: badArgument("Not found user with login=$login")
|
(Users.tgId eq user.id) and
|
||||||
|
(Users.tgUsername eq user.userName)
|
||||||
|
}.firstOrNull()
|
||||||
|
}
|
||||||
|
|
||||||
fun findUserInfoById(id: Long) = UserInfo.from(
|
override fun loadUserByUsername(username: String?): User = transaction {
|
||||||
userRepository.findUserById(id)
|
username?.let {
|
||||||
)
|
User.find { Users.login eq it }.firstOrNull()
|
||||||
|
} ?: error("Not found user with username $username")
|
||||||
fun createUser(userDto: UserDto): UserInfo = UserInfo.from(
|
}
|
||||||
userRepository.createUser(userDto)
|
|
||||||
) ?: error("Failed to create user with login=${userDto.login}")
|
|
||||||
|
|
||||||
|
fun createUser(userDto: UserDto): User {
|
||||||
|
val now = LocalDateTime.now()
|
||||||
|
UsersController.logger.info("Creating new user at $now")
|
||||||
|
return User.new {
|
||||||
|
login = userDto.login
|
||||||
|
_password = passwordEncoder.encode(userDto.password)
|
||||||
|
role = userDto.role
|
||||||
|
name = userDto.name
|
||||||
|
sex = userDto.sex
|
||||||
|
age = userDto.age
|
||||||
|
tgId = userDto.tgId
|
||||||
|
tgUsername = userDto.tgUsername
|
||||||
|
locked = false
|
||||||
|
enabled = userDto.enabled
|
||||||
|
accountExpiration = now + userExpirationTime
|
||||||
|
credentialsExpiration = now + credentialsExpirationTime
|
||||||
|
}
|
||||||
|
}
|
||||||
}
|
}
|
|
@ -1,3 +0,0 @@
|
||||||
package ru.sicamp.sicamphelper.util
|
|
||||||
|
|
||||||
typealias TgUser = org.telegram.telegrambots.meta.api.objects.User
|
|
|
@ -3,5 +3,3 @@ package ru.sicamp.sicamphelper.util
|
||||||
fun <R, T> R.ifNotNull(obj: T?, block: R.(T) -> R): R = if (obj != null) block(obj) else this
|
fun <R, T> R.ifNotNull(obj: T?, block: R.(T) -> R): R = if (obj != null) block(obj) else this
|
||||||
|
|
||||||
fun <R, T> R.ifNotEmpty(list: List<T>, block: R.(List<T>) -> R): R = if (list.isNotEmpty()) block(list) else this
|
fun <R, T> R.ifNotEmpty(list: List<T>, block: R.(List<T>) -> R): R = if (list.isNotEmpty()) block(list) else this
|
||||||
|
|
||||||
fun badArgument(message: String): Nothing = throw IllegalArgumentException(message)
|
|
Loading…
Reference in a new issue