in src/main/kotlin/org/jetbrains/slackUnfurls/spaceUnfurlsInSlack/SpaceUnfurlsInSlack.kt [136:147]
suspend fun processDeferredLinkSharedEvents(slackTeamId: String, slackUserId: String, spaceOrgId: String) {
withSlackLogContext(slackTeamId, slackUserId, spaceOrgId) {
db.deferredSlackLinkUnfurlEvents
.getOnce(slackTeamId = slackTeamId, slackUserId = slackUserId, spaceOrgId = spaceOrgId, limit = 10)
.also {
log.info("Enqueued ${it.size} deferred link unfurl events from Slack to process after user authenticated in Space")
}
.forEach {
processUnfurlsChannel.send(gson.fromJson(it, LinkSharedPayload::class.java))
}
}
}