github-repos/mirai
1
0
Fork 0
mirror of https://github.com/mamoe/mirai.git synced 2025-01-24 06:50:08 +08:00
Code Issues Packages Projects Releases Wiki Activity

Add utils for send packet

Browse Source
This commit is contained in:
Him188 2021-01-31 13:10:18 +08:00
parent 3643d8d4fd
commit e8dc06ebad
1 changed files with 39 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
mirai-core/src/commonMain/kotlin/network/protocol/packet/OutgoingPacketAndroid.kt
View File

@ -14,7 +14,9 @@ import kotlinx.io.core.BytePacketBuilder
import kotlinx.io.core.ByteReadPacket
import kotlinx.io.core.buildPacket
import kotlinx.io.core.writeFully
import net.mamoe.mirai.internal.QQAndroidBot
import net.mamoe.mirai.internal.network.Packet
import net.mamoe.mirai.internal.network.QQAndroidBotNetworkHandler
import net.mamoe.mirai.internal.network.QQAndroidClient
import net.mamoe.mirai.internal.utils.io.encryptAndWrite
import net.mamoe.mirai.internal.utils.io.writeHex
@ -37,6 +39,43 @@ internal open class OutgoingPacket constructor(
val name: String = name ?: commandName
}
internal suspend inline fun <E : Packet> OutgoingPacketWithRespType<E>.sendAndExpect(
network: QQAndroidBotNetworkHandler,
timeoutMillis: Long = 5000,
retry: Int = 2
): E = network.run {
return (this@sendAndExpect as OutgoingPacket).sendAndExpect(timeoutMillis, retry)
}
@Suppress("INVISIBLE_MEMBER", "INVISIBLE_REFERENCE")
@kotlin.internal.LowPriorityInOverloadResolution
internal suspend inline fun <E : Packet> OutgoingPacket.sendAndExpect(
network: QQAndroidBotNetworkHandler,
timeoutMillis: Long = 5000,
retry: Int = 2
): E = network.run {
return this@sendAndExpect.sendAndExpect(timeoutMillis, retry)
}
internal suspend inline fun <E : Packet> OutgoingPacketWithRespType<E>.sendAndExpect(
bot: QQAndroidBot,
timeoutMillis: Long = 5000,
retry: Int = 2
): E = bot.network.run {
return (this@sendAndExpect as OutgoingPacket).sendAndExpect(timeoutMillis, retry)
}
@Suppress("INVISIBLE_MEMBER", "INVISIBLE_REFERENCE")
@kotlin.internal.LowPriorityInOverloadResolution
internal suspend inline fun <E : Packet> OutgoingPacket.sendAndExpect(
bot: QQAndroidBot,
timeoutMillis: Long = 5000,
retry: Int = 2
): E = bot.network.run {
return this@sendAndExpect.sendAndExpect(timeoutMillis, retry)
}
internal val KEY_16_ZEROS = ByteArray(16)
internal val EMPTY_BYTE_ARRAY = ByteArray(0)