From ef4f4c78cb8944aca5b34153c22929d4d8a7ecd4 Mon Sep 17 00:00:00 2001 From: particle-box Date: Fri, 23 Jan 2026 00:48:55 +0530 Subject: [PATCH] fix: build errors --- .../impl/messaging/PreventMessageSending.kt | 29 ++++++++++--------- 1 file changed, 16 insertions(+), 13 deletions(-) diff --git a/core/src/main/kotlin/me/eternal/purrfectsnap/core/features/impl/messaging/PreventMessageSending.kt b/core/src/main/kotlin/me/eternal/purrfectsnap/core/features/impl/messaging/PreventMessageSending.kt index 886d4bca..7874904d 100644 --- a/core/src/main/kotlin/me/eternal/purrfectsnap/core/features/impl/messaging/PreventMessageSending.kt +++ b/core/src/main/kotlin/me/eternal/purrfectsnap/core/features/impl/messaging/PreventMessageSending.kt @@ -45,21 +45,24 @@ class PreventMessageSending : Feature("Prevent message sending") { return false } - arrayOf(NativeUnaryCallEvent::class, UnaryCallEvent::class).forEach { eventClass -> - context.event.subscribe(eventClass) { event -> - val unaryEvent = when (event) { - is NativeUnaryCallEvent -> event - is UnaryCallEvent -> event - else -> return@subscribe - } - val uri = unaryEvent.uri - if (!uri.startsWith("/messagingcoreservice.MessagingCoreService/")) return@subscribe + context.event.subscribe(NativeUnaryCallEvent::class) { event -> + val uri = event.uri + if (!uri.startsWith("/messagingcoreservice.MessagingCoreService/")) return@subscribe - if (handleCreateContentMessage(uri, unaryEvent.buffer)) { - unaryEvent.canceled = true - } - handleUpdateContentMessage(uri, unaryEvent.buffer)?.let { unaryEvent.buffer = it } + if (handleCreateContentMessage(uri, event.buffer)) { + event.canceled = true } + handleUpdateContentMessage(uri, event.buffer)?.let { event.buffer = it } + } + + context.event.subscribe(UnaryCallEvent::class) { event -> + val uri = event.uri + if (!uri.startsWith("/messagingcoreservice.MessagingCoreService/")) return@subscribe + + if (handleCreateContentMessage(uri, event.buffer)) { + event.canceled = true + } + handleUpdateContentMessage(uri, event.buffer)?.let { event.buffer = it } } context.classCache.conversationManager.hook("updateMessage", HookStage.BEFORE) { param ->