mirror of https://github.com/usbharu/Hideout.git
105 lines
3.7 KiB
Kotlin
105 lines
3.7 KiB
Kotlin
package dev.usbharu.hideout.service.impl
|
|
|
|
import dev.usbharu.hideout.config.Config
|
|
import dev.usbharu.hideout.domain.model.hideout.dto.RemoteUserCreateDto
|
|
import dev.usbharu.hideout.domain.model.hideout.dto.UserCreateDto
|
|
import dev.usbharu.hideout.domain.model.hideout.entity.User
|
|
import dev.usbharu.hideout.exception.UserNotFoundException
|
|
import dev.usbharu.hideout.repository.IUserRepository
|
|
import dev.usbharu.hideout.service.IUserAuthService
|
|
import java.lang.Integer.min
|
|
import java.time.Instant
|
|
|
|
class UserService(private val userRepository: IUserRepository, private val userAuthService: IUserAuthService) {
|
|
|
|
private val maxLimit = 100
|
|
suspend fun findAll(limit: Int? = maxLimit, offset: Long? = 0): List<User> {
|
|
|
|
return userRepository.findAllByLimitAndByOffset(
|
|
min(limit ?: maxLimit, maxLimit),
|
|
offset ?: 0
|
|
)
|
|
}
|
|
|
|
suspend fun findById(id: Long): User {
|
|
return userRepository.findById(id) ?: throw UserNotFoundException("$id was not found.")
|
|
}
|
|
|
|
suspend fun findByIds(ids: List<Long>): List<User> {
|
|
return userRepository.findByIds(ids)
|
|
}
|
|
|
|
suspend fun findByName(name: String): List<User> {
|
|
return userRepository.findByName(name)
|
|
}
|
|
|
|
suspend fun findByNameLocalUser(name: String): User {
|
|
return userRepository.findByNameAndDomain(name, Config.configData.domain)
|
|
?: throw UserNotFoundException("$name was not found.")
|
|
}
|
|
|
|
suspend fun findByNameAndDomains(names: List<Pair<String, String>>): List<User> {
|
|
return userRepository.findByNameAndDomains(names)
|
|
}
|
|
|
|
suspend fun findByUrl(url: String): User {
|
|
return userRepository.findByUrl(url) ?: throw UserNotFoundException("$url was not found.")
|
|
}
|
|
|
|
suspend fun findByUrls(urls: List<String>): List<User> {
|
|
return userRepository.findByUrls(urls)
|
|
}
|
|
|
|
suspend fun usernameAlreadyUse(username: String): Boolean {
|
|
val findByNameAndDomain = userRepository.findByNameAndDomain(username, Config.configData.domain)
|
|
return findByNameAndDomain != null
|
|
}
|
|
|
|
suspend fun createLocalUser(user: UserCreateDto): User {
|
|
val nextId = userRepository.nextId()
|
|
val HashedPassword = userAuthService.hash(user.password)
|
|
val keyPair = userAuthService.generateKeyPair()
|
|
val userEntity = User(
|
|
id = nextId,
|
|
name = user.name,
|
|
domain = Config.configData.domain,
|
|
screenName = user.screenName,
|
|
description = user.description,
|
|
password = HashedPassword,
|
|
inbox = "${Config.configData.url}/users/$nextId/inbox",
|
|
outbox = "${Config.configData.url}/users/$nextId/outbox",
|
|
url = "${Config.configData.url}/users/$nextId",
|
|
publicKey = keyPair.public.toPem(),
|
|
privateKey = keyPair.private.toString(),
|
|
Instant.now()
|
|
)
|
|
return userRepository.save(userEntity)
|
|
}
|
|
|
|
suspend fun createRemoteUser(user: RemoteUserCreateDto): User {
|
|
val nextId = userRepository.nextId()
|
|
val userEntity = User(
|
|
id = nextId,
|
|
name = user.name,
|
|
domain = user.domain,
|
|
screenName = user.screenName,
|
|
description = user.description,
|
|
inbox = user.inbox,
|
|
outbox = user.outbox,
|
|
url = user.url,
|
|
publicKey = user.publicKey,
|
|
createdAt = Instant.now()
|
|
)
|
|
return userRepository.save(userEntity)
|
|
}
|
|
|
|
suspend fun findFollowersById(id: Long): List<User> {
|
|
return userRepository.findFollowersById(id)
|
|
}
|
|
|
|
suspend fun addFollowers(id: Long, follower: Long) {
|
|
return userRepository.createFollower(id, follower)
|
|
}
|
|
|
|
}
|