Commit 2f416a5d authored by Him188's avatar Him188

Rename MessageEventPacket to MessagePacket

parent 7b8ddd2c
...@@ -7,16 +7,16 @@ import net.mamoe.mirai.message.Message ...@@ -7,16 +7,16 @@ import net.mamoe.mirai.message.Message
import net.mamoe.mirai.message.any import net.mamoe.mirai.message.any
import net.mamoe.mirai.network.protocol.tim.packet.event.FriendMessage import net.mamoe.mirai.network.protocol.tim.packet.event.FriendMessage
import net.mamoe.mirai.network.protocol.tim.packet.event.GroupMessage import net.mamoe.mirai.network.protocol.tim.packet.event.GroupMessage
import net.mamoe.mirai.network.protocol.tim.packet.event.MessageEventPacket import net.mamoe.mirai.network.protocol.tim.packet.event.MessagePacket
import kotlin.jvm.JvmName import kotlin.jvm.JvmName
/** /**
* 订阅来自所有 [Bot] 的所有联系人的消息事件. 联系人可以是任意群或任意好友或临时会话. * 订阅来自所有 [Bot] 的所有联系人的消息事件. 联系人可以是任意群或任意好友或临时会话.
*/ */
@MessageDsl @MessageDsl
suspend inline fun subscribeMessages(crossinline listeners: suspend MessageSubscribersBuilder<MessageEventPacket<*>>.() -> Unit) { suspend inline fun subscribeMessages(crossinline listeners: suspend MessageSubscribersBuilder<MessagePacket<*>>.() -> Unit) {
MessageSubscribersBuilder<MessageEventPacket<*>> { listener -> MessageSubscribersBuilder<MessagePacket<*>> { listener ->
subscribeAlways<MessageEventPacket<*>> { subscribeAlways<MessagePacket<*>> {
listener(it) listener(it)
} }
}.apply { listeners() } }.apply { listeners() }
...@@ -50,9 +50,9 @@ suspend inline fun subscribeFriendMessages(crossinline listeners: suspend Messag ...@@ -50,9 +50,9 @@ suspend inline fun subscribeFriendMessages(crossinline listeners: suspend Messag
* 订阅来自这个 [Bot] 的所有联系人的消息事件. 联系人可以是任意群或任意好友或临时会话. * 订阅来自这个 [Bot] 的所有联系人的消息事件. 联系人可以是任意群或任意好友或临时会话.
*/ */
@MessageDsl @MessageDsl
suspend inline fun Bot.subscribeMessages(crossinline listeners: suspend MessageSubscribersBuilder<MessageEventPacket<*>>.() -> Unit) { suspend inline fun Bot.subscribeMessages(crossinline listeners: suspend MessageSubscribersBuilder<MessagePacket<*>>.() -> Unit) {
MessageSubscribersBuilder<MessageEventPacket<*>> { listener -> MessageSubscribersBuilder<MessagePacket<*>> { listener ->
this.subscribeAlways<MessageEventPacket<*>> { this.subscribeAlways<MessagePacket<*>> {
listener(it) listener(it)
} }
}.apply { listeners() } }.apply { listeners() }
...@@ -86,11 +86,11 @@ internal typealias MessageReplier<T> = @MessageDsl suspend T.(String) -> Message ...@@ -86,11 +86,11 @@ internal typealias MessageReplier<T> = @MessageDsl suspend T.(String) -> Message
internal typealias StringReplier<T> = @MessageDsl suspend T.(String) -> String internal typealias StringReplier<T> = @MessageDsl suspend T.(String) -> String
internal suspend inline operator fun <T : MessageEventPacket<*>> (@MessageDsl suspend T.(String) -> Unit).invoke(t: T) = internal suspend inline operator fun <T : MessagePacket<*>> (@MessageDsl suspend T.(String) -> Unit).invoke(t: T) =
this.invoke(t, t.message.stringValue) this.invoke(t, t.message.stringValue)
@JvmName("invoke1") //Avoid Platform declaration clash @JvmName("invoke1") //Avoid Platform declaration clash
internal suspend inline operator fun <T : MessageEventPacket<*>> StringReplier<T>.invoke(t: T): String = internal suspend inline operator fun <T : MessagePacket<*>> StringReplier<T>.invoke(t: T): String =
this.invoke(t, t.message.stringValue) this.invoke(t, t.message.stringValue)
/** /**
...@@ -101,7 +101,7 @@ internal suspend inline operator fun <T : MessageEventPacket<*>> StringReplier<T ...@@ -101,7 +101,7 @@ internal suspend inline operator fun <T : MessageEventPacket<*>> StringReplier<T
*/ */
@Suppress("unused") @Suppress("unused")
@MessageDsl @MessageDsl
class MessageSubscribersBuilder<T : MessageEventPacket<*>>( class MessageSubscribersBuilder<T : MessagePacket<*>>(
inline val subscriber: suspend (@MessageDsl suspend T.(String) -> Unit) -> Unit inline val subscriber: suspend (@MessageDsl suspend T.(String) -> Unit) -> Unit
) { ) {
/** /**
......
...@@ -51,7 +51,7 @@ object EventPacketFactory : PacketFactory<Packet, SessionKey>(SessionKey) { ...@@ -51,7 +51,7 @@ object EventPacketFactory : PacketFactory<Packet, SessionKey>(SessionKey) {
discardExact(2) discardExact(2)
return with(matchEventPacketFactory(readUShort())) { parse(handler.bot, eventIdentity) }.also { return with(matchEventPacketFactory(readUShort())) { parse(handler.bot, eventIdentity) }.also {
if (it is MessageEventPacket<*>) { if (it is MessagePacket<*>) {
it.botVar = handler.bot it.botVar = handler.bot
} }
......
...@@ -25,7 +25,7 @@ import net.mamoe.mirai.utils.io.readUShortLVByteArray ...@@ -25,7 +25,7 @@ import net.mamoe.mirai.utils.io.readUShortLVByteArray
import net.mamoe.mirai.utils.sendTo import net.mamoe.mirai.utils.sendTo
import net.mamoe.mirai.utils.upload import net.mamoe.mirai.utils.upload
sealed class MessageEventPacket<TSubject : Contact> : EventPacket, BotEvent() { sealed class MessagePacket<TSubject : Contact> : EventPacket, BotEvent() {
internal lateinit var botVar: Bot internal lateinit var botVar: Bot
override val bot: Bot get() = botVar override val bot: Bot get() = botVar
...@@ -82,7 +82,7 @@ data class GroupMessage( ...@@ -82,7 +82,7 @@ data class GroupMessage(
val permission: MemberPermission, val permission: MemberPermission,
override val sender: QQ, override val sender: QQ,
override val message: MessageChain = NullMessageChain override val message: MessageChain = NullMessageChain
) : MessageEventPacket<Group>() { ) : MessagePacket<Group>() {
override val subject: Group get() = group override val subject: Group get() = group
} }
...@@ -143,7 +143,7 @@ data class FriendMessage( ...@@ -143,7 +143,7 @@ data class FriendMessage(
val isPrevious: Boolean, val isPrevious: Boolean,
override val sender: QQ, override val sender: QQ,
override val message: MessageChain override val message: MessageChain
) : MessageEventPacket<QQ>() { ) : MessagePacket<QQ>() {
override val subject: QQ get() = sender override val subject: QQ get() = sender
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment