mirror of https://github.com/usbharu/Hideout.git
feat: Signatrueヘッダーを変更
This commit is contained in:
parent
0e4313bde8
commit
97db6745f3
|
@ -58,6 +58,7 @@ dependencies {
|
||||||
implementation("io.ktor:ktor-client-core:$ktor_version")
|
implementation("io.ktor:ktor-client-core:$ktor_version")
|
||||||
implementation("io.ktor:ktor-client-cio:$ktor_version")
|
implementation("io.ktor:ktor-client-cio:$ktor_version")
|
||||||
implementation("io.ktor:ktor-client-content-negotiation:$ktor_version")
|
implementation("io.ktor:ktor-client-content-negotiation:$ktor_version")
|
||||||
|
testImplementation("io.ktor:ktor-client-mock:$ktor_version")
|
||||||
|
|
||||||
implementation("tech.barbero.http-messages-signing:http-messages-signing-core:1.0.0")
|
implementation("tech.barbero.http-messages-signing:http-messages-signing-core:1.0.0")
|
||||||
|
|
||||||
|
|
|
@ -122,7 +122,8 @@ val httpSignaturePlugin = createClientPlugin("HttpSign", ::HttpSignaturePluginCo
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun addHeader(name: String?, value: String?) {
|
override fun addHeader(name: String?, value: String?) {
|
||||||
name?.let { request.header(it, "\"${value?.trim(',')}\"") }
|
val split = value?.split("=").orEmpty()
|
||||||
|
name?.let { request.header(it, split.get(0)+"=\""+split.get(1).trim('"')+"\"") }
|
||||||
}
|
}
|
||||||
|
|
||||||
override fun method(): String {
|
override fun method(): String {
|
||||||
|
|
|
@ -0,0 +1,122 @@
|
||||||
|
package dev.usbharu.hideout.plugins
|
||||||
|
|
||||||
|
import dev.usbharu.hideout.ap.JsonLd
|
||||||
|
import dev.usbharu.hideout.domain.model.User
|
||||||
|
import dev.usbharu.hideout.domain.model.UserAuthentication
|
||||||
|
import dev.usbharu.hideout.domain.model.UserAuthenticationEntity
|
||||||
|
import dev.usbharu.hideout.domain.model.UserEntity
|
||||||
|
import dev.usbharu.hideout.repository.IUserAuthRepository
|
||||||
|
import dev.usbharu.hideout.repository.IUserRepository
|
||||||
|
import dev.usbharu.hideout.service.UserAuthService
|
||||||
|
import io.ktor.client.*
|
||||||
|
import io.ktor.client.engine.mock.*
|
||||||
|
import io.ktor.client.plugins.logging.*
|
||||||
|
import kotlinx.coroutines.runBlocking
|
||||||
|
import org.junit.jupiter.api.Test
|
||||||
|
import java.security.KeyPairGenerator
|
||||||
|
import java.security.interfaces.RSAPrivateKey
|
||||||
|
import java.security.interfaces.RSAPublicKey
|
||||||
|
import java.util.*
|
||||||
|
|
||||||
|
class ActivityPubKtTest {
|
||||||
|
@Test
|
||||||
|
fun HttpSignTest(): Unit = runBlocking {
|
||||||
|
|
||||||
|
val ktorKeyMap = KtorKeyMap(UserAuthService(object : IUserRepository {
|
||||||
|
override suspend fun create(user: User): UserEntity {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun findById(id: Long): UserEntity? {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun findByName(name: String): UserEntity? {
|
||||||
|
return UserEntity(1, "test", "localhost", "test", "")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun update(userEntity: UserEntity) {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun delete(id: Long) {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun findAll(): List<User> {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun findAllByLimitAndByOffset(limit: Int, offset: Long): List<UserEntity> {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun createFollower(id: Long, follower: Long) {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun deleteFollower(id: Long, follower: Long) {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun findFollowersById(id: Long): List<UserEntity> {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
}, object : IUserAuthRepository {
|
||||||
|
override suspend fun create(userAuthentication: UserAuthentication): UserAuthenticationEntity {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun findById(id: Long): UserAuthenticationEntity? {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun update(userAuthenticationEntity: UserAuthenticationEntity) {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun delete(id: Long) {
|
||||||
|
TODO("Not yet implemented")
|
||||||
|
}
|
||||||
|
|
||||||
|
override suspend fun findByUserId(id: Long): UserAuthenticationEntity? {
|
||||||
|
val keyPairGenerator = KeyPairGenerator.getInstance("RSA")
|
||||||
|
keyPairGenerator.initialize(1024)
|
||||||
|
val generateKeyPair = keyPairGenerator.generateKeyPair()
|
||||||
|
return UserAuthenticationEntity(
|
||||||
|
1, 1, "test", (generateKeyPair.public as RSAPublicKey).toPem(),
|
||||||
|
(generateKeyPair.private as RSAPrivateKey).toPem()
|
||||||
|
)
|
||||||
|
}
|
||||||
|
}))
|
||||||
|
|
||||||
|
val httpClient = HttpClient(MockEngine { httpRequestData ->
|
||||||
|
respondOk()
|
||||||
|
}) {
|
||||||
|
install(httpSignaturePlugin) {
|
||||||
|
keyMap = ktorKeyMap
|
||||||
|
}
|
||||||
|
install(Logging) {
|
||||||
|
logger = Logger.DEFAULT
|
||||||
|
level = LogLevel.ALL
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
||||||
|
httpClient.postAp("https://localhost", "test", JsonLd(emptyList()))
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
fun RSAPublicKey.toPem(): String {
|
||||||
|
return "-----BEGIN RSA PUBLIC KEY-----" +
|
||||||
|
Base64.getEncoder().encodeToString(encoded) +
|
||||||
|
"-----END RSA PUBLIC KEY-----"
|
||||||
|
}
|
||||||
|
|
||||||
|
fun RSAPrivateKey.toPem(): String {
|
||||||
|
return "-----BEGIN RSA PRIVATE KEY-----" +
|
||||||
|
Base64.getEncoder().encodeToString(encoded) +
|
||||||
|
"-----END RSA PRIVATE KEY-----"
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue