fix: 間違えてpostEntityをデシリアライズしていたので変換するように

This commit is contained in:
usbharu 2023-04-21 21:35:16 +09:00
parent 6f31908215
commit 98c2c88fa4
1 changed files with 11 additions and 2 deletions

View File

@ -11,6 +11,7 @@ import dev.usbharu.hideout.service.job.JobQueueParentService
import io.ktor.client.*
import kjob.core.job.JobProps
import org.slf4j.LoggerFactory
import java.time.Instant
class ActivityPubNoteServiceImpl(
private val httpClient: HttpClient,
@ -36,9 +37,17 @@ class ActivityPubNoteServiceImpl(
override suspend fun createNoteJob(props: JobProps<DeliverPostJob>) {
val actor = props[DeliverPostJob.actor]
val note = Config.configData.objectMapper.readValue<Note>(props[DeliverPostJob.post])
val postEntity = Config.configData.objectMapper.readValue<PostEntity>(props[DeliverPostJob.post])
val note = Note(
name = "Note",
id = postEntity.url,
attributedTo = actor,
content = postEntity.text,
published = Instant.ofEpochMilli(postEntity.createdAt).toString(),
to = listOf("https://www.w3.org/ns/activitystreams#Public", actor + "/followers")
)
val inbox = props[DeliverPostJob.inbox]
logger.debug("createNoteJob: actor={}, note={}, inbox={}", actor, note, inbox)
logger.debug("createNoteJob: actor={}, note={}, inbox={}", actor, postEntity, inbox)
httpClient.postAp(
urlString = inbox,
username = "$actor#pubkey",