Merge pull request #193 from MrXiaoM/fix-group-ban

支持全员禁言通知事件
This commit is contained in:
白池 2024-01-07 15:13:43 +08:00 committed by GitHub
commit f47ae69653
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 18 additions and 9 deletions

View File

@ -61,7 +61,7 @@ class ProtoMap(
var curMap = value
tags.forEachIndexed { index, tag ->
if (index == tags.size - 1) {
return curMap[tag] ?: error("Tag $tag not found")
return curMap[tag] ?: error("pb[${tags.joinToString(", ")}][$index] Tag $tag not found")
}
curMap[tag]?.let { v ->
if (v is ProtoMap) {
@ -69,7 +69,7 @@ class ProtoMap(
} else {
return v
}
} ?: error("Tag $tag not found")
} ?: error("pb[${tags.joinToString(", ")}][$index] Tag $tag not found")
}
error("Instance is not ProtoMap for get(${tags.first()})")
}

View File

@ -305,6 +305,7 @@ internal object GlobalEventTransmitter: BaseSvc() {
suspend fun transGroupBan(
msgTime: Long,
subType: NoticeSubType,
operation: Long,
target: Long,
groupCode: Long,
@ -315,7 +316,7 @@ internal object GlobalEventTransmitter: BaseSvc() {
selfId = app.longAccountUin,
postType = PostType.Notice,
type = NoticeType.GroupBan,
subType = if (duration == 0) NoticeSubType.LiftBan else NoticeSubType.Ban,
subType = subType,
operatorId = operation,
userId = target,
senderId = operation,

View File

@ -452,14 +452,22 @@ internal object PrimitiveListener {
private suspend fun onGroupBan(msgTime: Long, pb: ProtoMap) {
val groupCode = pb[1, 3, 2, 1].asULong
val operatorUid = pb[1, 3, 2, 4].asUtf8String
val targetUid = pb[1, 3, 2, 5, 3, 1].asUtf8String
val duration = pb[1, 3, 2, 5, 3, 2].asInt
val operation = ContactHelper.getUinByUidAsync(operatorUid).toLong()
val target = ContactHelper.getUinByUidAsync(targetUid).toLong()
LogCenter.log("群禁言($groupCode): $operation -> $target, 时长 = ${duration}s")
val wholeBan = !pb.has(1, 3, 2, 5, 3, 1)
val targetUid = if (wholeBan) "" else pb[1, 3, 2, 5, 3, 1].asUtf8String
val rawDuration = pb[1, 3, 2, 5, 3, 2].asInt
val operation = ContactHelper.getUinByUidAsync(operatorUid).toLong()
val duration = if (wholeBan) -1 else rawDuration
val target = if (wholeBan) 0 else ContactHelper.getUinByUidAsync(targetUid).toLong()
val subType = if (rawDuration == 0) NoticeSubType.LiftBan else NoticeSubType.Ban
if (wholeBan) {
LogCenter.log("群全员禁言($groupCode): $operation -> ${if (subType == NoticeSubType.Ban) "开启" else "关闭"}")
} else {
LogCenter.log("群禁言($groupCode): $operation -> $target, 时长 = ${duration}s")
}
if (!GlobalEventTransmitter.GroupNoticeTransmitter
.transGroupBan(msgTime, operation, target, groupCode, duration)
.transGroupBan(msgTime, subType, operation, target, groupCode, duration)
) {
LogCenter.log("群禁言推送失败!", Level.WARN)
}