fix /get_group_root_files

README.md

@@ -23,6 +23,8 @@
 > Riru可能导致封禁，请减少使用。
 > 如有违反法律，请联系删除。
 > 请勿在任何平台宣传，宣扬，转发本项目，请勿恶意修改企业安装包造成相关企业产生损失，如有违背，必将追责到底。
+> 
+> 社区地址：[discord](https://discord.gg/MKR2wz863h)
 
 ## 兼容|迁移|替代 说明
 

app/src/main/java/moe/fuqiuluo/shamrock/ui/fragment/DashboardFragment.kt

@@ -162,7 +162,7 @@ private fun FunctionCard(
 
             Function(
                 title = "主动RPC",
-                desc = "Kritor协议实现RPC",
+                desc = "Kritor协议实现RPC，由Shamrock放出rpc服务",
                 isSwitch = ShamrockConfig[ctx, ActiveRPC]
             ) {
                 ShamrockConfig[ctx, ActiveRPC] = it
@@ -171,7 +171,7 @@ private fun FunctionCard(
 
             Function(
                 title = "被动RPC",
-                desc = "Kritor协议实现RPC",
+                desc = "Kritor协议实现RPC，由客户端提供反向的rpc服务",
                 isSwitch = ShamrockConfig[ctx, PassiveRPC]
             ) {
                 ShamrockConfig[ctx, PassiveRPC] = it

protobuf/src/main/java/protobuf/oidb/TrpcOidb.kt

@@ -8,7 +8,9 @@ import moe.fuqiuluo.symbols.Protobuf
 data class TrpcOidb(
     @ProtoNumber(1) val cmd: Int = Int.MIN_VALUE,
     @ProtoNumber(2) val service: Int = Int.MIN_VALUE,
-    @ProtoNumber(4) val buffer: ByteArray,
+    @ProtoNumber(3) val result: UInt? = null,
+    @ProtoNumber(4) val buffer: ByteArray? = null,
+    @ProtoNumber(5) val msg: String? = null,
     //@ProtoNumber(11) val traceParams: Map<String, String> = mapOf(),
     @ProtoNumber(12) val flag: Int = Int.MIN_VALUE,
 ): Protobuf<TrpcOidb>

qqinterface/src/main/java/com/tencent/qqnt/kernel/nativeinterface/GProGuildTopFeedMsg.java

@@ -0,0 +1,4 @@
+package com.tencent.qqnt.kernel.nativeinterface;
+
+public class GProGuildTopFeedMsg {
+}

qqinterface/src/main/java/com/tencent/qqnt/kernel/nativeinterface/IKernelMsgListener.java

@@ -18,7 +18,7 @@ public interface IKernelMsgListener {
 
     void onCustomWithdrawConfigUpdate(CustomWithdrawConfig customWithdrawConfig);
 
-    void onDraftUpdate(Contact contact, ArrayList<MsgElement> arrayList, long j2);
+    void onDraftUpdate(Contact contact, ArrayList<MsgElement> arrayList, long j);
 
     void onEmojiDownloadComplete(EmojiNotifyInfo emojiNotifyInfo);
 
@@ -32,7 +32,7 @@ public interface IKernelMsgListener {
 
     void onFirstViewGroupGuildMapping(ArrayList<FirstViewGroupGuildInfo> arrayList);
 
-    void onGrabPasswordRedBag(int i2, String str, int i3, RecvdOrder recvdOrder, MsgRecord msgRecord);
+    void onGrabPasswordRedBag(int i, String str, int i2, RecvdOrder recvdOrder, MsgRecord msgRecord);
 
     void onGroupFileInfoAdd(GroupItem groupItem);
 
@@ -50,6 +50,8 @@ public interface IKernelMsgListener {
 
     void onGuildNotificationAbstractUpdate(GuildNotificationAbstractInfo guildNotificationAbstractInfo);
 
+    void onGuildTopFeedUpdate(GProGuildTopFeedMsg gProGuildTopFeedMsg);
+
     void onHitCsRelatedEmojiResult(DownloadRelateEmojiResultInfo downloadRelateEmojiResultInfo);
 
     void onHitEmojiKeywordResult(HitRelatedEmojiWordsResult hitRelatedEmojiWordsResult);
@@ -64,7 +66,7 @@ public interface IKernelMsgListener {
 
     void onLineDev(ArrayList<DevInfo> arrayList);
 
-    void onLogLevelChanged(long j2);
+    void onLogLevelChanged(long j);
 
     void onMsgAbstractUpdate(ArrayList<MsgAbstract> arrayList);
 
@@ -78,14 +80,16 @@ public interface IKernelMsgListener {
 
     void onMsgInfoListUpdate(ArrayList<MsgRecord> arrayList);
 
-    void onMsgQRCodeStatusChanged(int i2);
+    void onMsgQRCodeStatusChanged(int i);
 
-    void onMsgRecall(int i2, String str, long j2);
+    void onMsgRecall(int i, String str, long j);
 
     void onMsgSecurityNotify(MsgRecord msgRecord);
 
     void onMsgSettingUpdate(MsgSetting msgSetting);
 
+    void onMsgWithRichLinkInfoUpdate(ArrayList<MsgRecord> arrayList);
+
     void onNtFirstViewMsgSyncEnd();
 
     void onNtMsgSyncEnd();
@@ -94,11 +98,11 @@ public interface IKernelMsgListener {
 
     void onReadFeedEventUpdate(FirstViewDirectMsgNotifyInfo firstViewDirectMsgNotifyInfo);
 
-    void onRecvGroupGuildFlag(int i2);
+    void onRecvGroupGuildFlag(int i);
 
     void onRecvMsg(ArrayList<MsgRecord> arrayList);
 
-    void onRecvMsgSvrRspTransInfo(long j2, Contact contact, int i2, int i3, String str, byte[] bArr);
+    void onRecvMsgSvrRspTransInfo(long j, Contact contact, int i, int i2, String str, byte[] bArr);
 
     void onRecvOnlineFileMsg(ArrayList<MsgRecord> arrayList);
 
@@ -106,7 +110,9 @@ public interface IKernelMsgListener {
 
     void onRecvSysMsg(ArrayList<Byte> arrayList);
 
-    void onRecvUDCFlag(int i2);
+    void onRecvUDCFlag(int i);
+
+    void onRedTouchChanged();
 
     void onRichMediaDownloadComplete(FileTransNotifyInfo fileTransNotifyInfo);
 
@@ -116,9 +122,9 @@ public interface IKernelMsgListener {
 
     void onSearchGroupFileInfoUpdate(SearchGroupFileResult searchGroupFileResult);
 
-    void onSendMsgError(long j2, Contact contact, int i2, String str);
+    void onSendMsgError(long j, Contact contact, int i, String str);
 
-    void onSysMsgNotification(int i2, long j2, long j3, boolean z, ArrayList<Byte> arrayList);
+    void onSysMsgNotification(int i, long j, long j2, boolean z, ArrayList<Byte> arrayList);
 
     void onTempChatInfoUpdate(TempChatInfo tempChatInfo);
 
@@ -130,9 +136,11 @@ public interface IKernelMsgListener {
 
     void onUserOnlineStatusChanged(boolean z);
 
+    void onUserSecQualityChanged(QueryUserSecQualityRsp queryUserSecQualityRsp);
+
     void onUserTabStatusChanged(ArrayList<TabStatusInfo> arrayList);
 
-    void onlineStatusBigIconDownloadPush(int i2, long j2, String str);
+    void onlineStatusBigIconDownloadPush(int i, long j, String str);
 
-    void onlineStatusSmallIconDownloadPush(int i2, long j2, String str);
+    void onlineStatusSmallIconDownloadPush(int i, long j, String str);
 }

qqinterface/src/main/java/com/tencent/qqnt/kernel/nativeinterface/QueryUserSecQualityRsp.java

@@ -0,0 +1,4 @@
+package com.tencent.qqnt.kernel.nativeinterface;
+
+public class QueryUserSecQualityRsp {
+}

xposed/src/main/java/kritor/service/FriendService.kt

@@ -156,8 +156,8 @@ internal object FriendService : FriendServiceGrpcKt.FriendServiceCoroutineImplBa
         val bundle = Bundle()
         val service = QQInterfaces.app
             .getRuntimeService(IProfileProtocolService::class.java, "all")
-        if (request.hasNickName()) {
-            bundle.putString(IProfileProtocolConst.KEY_NICK, request.nickName)
+        if (request.hasNick()) {
+            bundle.putString(IProfileProtocolConst.KEY_NICK, request.nick)
         }
         if (request.hasCompany()) {
             bundle.putString(IProfileProtocolConst.KEY_COMPANY, request.company)

xposed/src/main/java/kritor/service/GroupService.kt

@@ -259,12 +259,12 @@ internal object GroupService : GroupServiceGrpcKt.GroupServiceCoroutineImplBase(
                     .ifNullOrEmpty { memberInfo.friendnick } ?: ""
                 age = memberInfo.age.toInt()
                 uniqueTitle = memberInfo.mUniqueTitle ?: ""
-                uniqueTitleExpireTime = memberInfo.mUniqueTitleExpire
+                uniqueTitleExpireTime = memberInfo.mUniqueTitleExpire.toLong()
                 card = memberInfo.troopnick.ifNullOrEmpty { memberInfo.friendnick } ?: ""
                 joinTime = memberInfo.join_time
                 lastActiveTime = memberInfo.last_active_time
                 level = memberInfo.level
-                shutUpTimestamp = memberInfo.gagTimeStamp
+                shutUpTime = memberInfo.gagTimeStamp
 
                 distance = memberInfo.distance
                 addAllHonors((memberInfo.honorList ?: "")
@@ -295,12 +295,12 @@ internal object GroupService : GroupServiceGrpcKt.GroupServiceCoroutineImplBase(
                     nick = memberInfo.nick ?: ""
                     age = 0
                     uniqueTitle = memberInfo.memberSpecialTitle ?: ""
-                    uniqueTitleExpireTime = memberInfo.specialTitleExpireTime.toInt()
+                    uniqueTitleExpireTime = memberInfo.specialTitleExpireTime
                     card = memberInfo.cardName.ifNullOrEmpty { memberInfo.nick } ?: ""
                     joinTime = memberInfo.joinTime.toLong()
                     lastActiveTime = memberInfo.lastSpeakTime.toLong()
                     level = memberInfo.memberLevel
-                    shutUpTimestamp = memberInfo.shutUpTime.toLong()
+                    shutUpTime = memberInfo.shutUpTime.toLong()
 
                     distance = 0
                     addAllHonors(memberInfo.groupHonor.let { bytes ->
@@ -327,7 +327,7 @@ internal object GroupService : GroupServiceGrpcKt.GroupServiceCoroutineImplBase(
                 this.addProhibitedUsersInfo(ProhibitedUserInfo.newBuilder().apply {
                     uid = ContactHelper.getUidByUinAsync(it.memberUin)
                     uin = it.memberUin
-                    prohibitedTime = it.shutuptimestap
+                    prohibitedTime = it.shutuptimestap.toLong()
                 })
             }
         }.build()
@@ -360,7 +360,7 @@ internal object GroupService : GroupServiceGrpcKt.GroupServiceCoroutineImplBase(
                 maxMemberCount = groupInfo.maxMember
                 memberCount = groupInfo.memberCount
                 groupDesc = groupInfo.groupDesc
-                createTime = groupInfo.createTime.toInt()
+                createTime = groupInfo.createTime
                 groupFlag = groupInfo.groupFlag
                 groupFlagExt = groupInfo.groupFlagExt
             }.build()

xposed/src/main/java/kritor/service/MessageService.kt

@@ -315,7 +315,7 @@ internal object MessageService : MessageServiceGrpcKt.MessageServiceCoroutineImp
                     throw StatusRuntimeException(Status.INTERNAL.withCause(it))
                 }.getOrThrow().map { detail ->
                     PushMessageBody.newBuilder().apply {
-                        this.time = detail.time
+                        this.time = detail.time.toLong()
                         this.messageId = detail.qqMsgId.toString()
                         this.messageSeq = detail.msgSeq
                         this.contact = io.kritor.common.Contact.newBuilder().apply {
@@ -398,10 +398,10 @@ internal object MessageService : MessageServiceGrpcKt.MessageServiceCoroutineImp
                         this.messageId = it.msgId.toString()
                     }
                     this.messageSeq = it.messageSeq
-                    this.messageTime = it.senderTime.toInt()
+                    this.messageTime = it.senderTime
                     this.senderNick = it.senderNick
                     this.senderUin = it.senderId
-                    this.operationTime = it.operatorTime.toInt()
+                    this.operationTime = it.operatorTime
                     this.operatorNick = it.operatorNick
                     this.operatorUin = it.operatorId
                     this.jsonElements = it.messageContent.toString()

xposed/src/main/java/moe/fuqiuluo/shamrock/config/ShamrockConfig.kt

@@ -20,6 +20,7 @@ private val configKeys = setOf(
     ResourceGroup,
     RPCAddress,
     RPCPort,
+    AliveReply,
 )
 
 internal object ShamrockConfig: Properties() {

xposed/src/main/java/moe/fuqiuluo/shamrock/internals/GlobalEventTransmitter.kt

@@ -42,7 +42,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
             elements: ArrayList<MsgElement>,
         ): Boolean {
             transMessageEvent(record, PushMessageBody.newBuilder().apply {
-                this.time = record.msgTime.toInt()
+                this.time = record.msgTime
                 this.messageId = record.msgId.toString()
                 this.messageSeq = record.msgSeq
                 this.contact = Contact.newBuilder().apply {
@@ -65,7 +65,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
             elements: ArrayList<MsgElement>,
         ): Boolean {
             transMessageEvent(record, PushMessageBody.newBuilder().apply {
-                this.time = record.msgTime.toInt()
+                this.time = record.msgTime
                 this.messageId = record.msgId.toString()
                 this.messageSeq = record.msgSeq
                 this.contact = Contact.newBuilder().apply {
@@ -90,7 +90,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
             fromNick: String,
         ): Boolean {
             transMessageEvent(record, PushMessageBody.newBuilder().apply {
-                this.time = record.msgTime.toInt()
+                this.time = record.msgTime
                 this.messageId = record.msgId.toString()
                 this.messageSeq = record.msgSeq
                 this.contact = Contact.newBuilder().apply  {
@@ -113,7 +113,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
             elements: ArrayList<MsgElement>,
         ): Boolean {
             transMessageEvent(record, PushMessageBody.newBuilder().apply {
-                this.time = record.msgTime.toInt()
+                this.time = record.msgTime
                 this.messageId = record.msgId.toString()
                 this.messageSeq = record.msgSeq
                 this.contact = Contact.newBuilder().apply {
@@ -152,16 +152,16 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.PRIVATE_FILE_UPLOADED
-                this.time = msgTime.toInt()
+                this.time = msgTime
                 this.privateFileUploaded = PrivateFileUploadedNotice.newBuilder().apply {
                     this.fileId = fileId
                     this.fileName = fileName
                     this.operatorUid = senderUid
                     this.operatorUin = senderUin
                     this.fileSize = fileSize
-                    this.expireTime = expireTime.toInt()
-                    this.fileSubId = fileSubId
-                    this.url = url
+                    this.expireTime = expireTime
+                    this.fileSubId = fileSubId.toInt() // todo(这玩意真的是一个数字？)
+                    this.fileUrl = url
                 }.build()
             }.build())
             return true
@@ -183,7 +183,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_FILE_UPLOADED
-                this.time = msgTime.toInt()
+                this.time = msgTime
                 this.groupFileUploaded = GroupFileUploadedNotice.newBuilder().apply {
                     this.groupId = groupId
                     this.operatorUid = senderUid
@@ -191,7 +191,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
                     this.fileId = uuid
                     this.fileName = fileName
                     this.fileSize = fileSize
-                    this.busId = bizId
+                    this.fileSubId = bizId
                     this.fileUrl = url
                 }.build()
             }.build())
@@ -212,7 +212,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_SIGN_IN
-                this.time = time.toInt()
+                this.time = time
                 this.groupSignIn = GroupSignInNotice.newBuilder().apply {
                     this.groupId = groupCode
                     this.targetUid = ContactHelper.getUidByUinAsync(target)
@@ -235,7 +235,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_POKE
-                this.time = time.toInt()
+                this.time = time
                 this.groupPoke = GroupPokeNotice.newBuilder().apply {
                     this.groupId = groupCode
                     this.action = action
@@ -261,7 +261,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_MEMBER_INCREASE
-                this.time = time.toInt()
+                this.time = time
                 this.groupMemberIncrease = GroupMemberIncreasedNotice.newBuilder().apply {
                     this.groupId = groupCode
                     this.operatorUid = operatorUid
@@ -285,7 +285,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_MEMBER_DECREASE
-                this.time = time.toInt()
+                this.time = time
                 this.groupMemberDecrease = GroupMemberDecreasedNotice.newBuilder().apply {
                     this.groupId = groupCode
                     this.operatorUid = operatorUid
@@ -307,7 +307,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_ADMIN_CHANGED
-                this.time = msgTime.toInt()
+                this.time = msgTime
                 this.groupAdminChanged = GroupAdminChangedNotice.newBuilder().apply {
                     this.groupId = groupCode
                     this.targetUid = targetUid
@@ -327,7 +327,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_WHOLE_BAN
-                this.time = msgTime.toInt()
+                this.time = msgTime
                 this.groupWholeBan = GroupWholeBanNotice.newBuilder().apply {
                     this.groupId = groupCode
                     this.isBan = isOpen
@@ -349,7 +349,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_MEMBER_BAN
-                this.time = msgTime.toInt()
+                this.time = msgTime
                 this.groupMemberBan = GroupMemberBanNotice.newBuilder().apply {
                     this.groupId = groupCode
                     this.operatorUid = operatorUid
@@ -376,7 +376,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_RECALL
-                this.time = time.toInt()
+                this.time = time
                 this.groupRecall = GroupRecallNotice.newBuilder().apply {
                     this.groupId = groupCode
                     this.operatorUid = operatorUid
@@ -398,7 +398,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_CARD_CHANGED
-                this.time = time.toInt()
+                this.time = time
                 this.groupCardChanged = GroupCardChangedNotice.newBuilder().apply {
                     this.groupId = groupId
                     this.targetUin = targetId
@@ -416,7 +416,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_MEMBER_UNIQUE_TITLE_CHANGED
-                this.time = time.toInt()
+                this.time = time
                 this.groupMemberUniqueTitleChanged = GroupUniqueTitleChangedNotice.newBuilder().apply {
                     this.groupId = groupId
                     this.targetUid = ContactHelper.getUidByUinAsync(targetUin)
@@ -437,7 +437,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.GROUP_ESSENCE_CHANGED
-                this.time = time.toInt()
+                this.time = time
                 this.groupEssenceChanged = GroupEssenceMessageNotice.newBuilder().apply {
                     this.groupId = groupId
                     this.messageId = msgId.toString()
@@ -465,7 +465,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.PRIVATE_POKE
-                this.time = msgTime.toInt()
+                this.time = msgTime
                 this.privatePoke = PrivatePokeNotice.newBuilder().apply {
                     this.action = action ?: ""
                     this.operatorUid = ContactHelper.getUidByUinAsync(operator)
@@ -480,7 +480,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         suspend fun transPrivateRecall(time: Long, operator: Long, msgId: Long, tipText: String): Boolean {
             pushNotice(NoticeEvent.newBuilder().apply {
                 this.type = NoticeEvent.NoticeType.PRIVATE_RECALL
-                this.time = time.toInt()
+                this.time = time
                 this.privateRecall = PrivateRecallNotice.newBuilder().apply {
                     this.operatorUin = operator
                     this.messageId = msgId.toString()
@@ -499,7 +499,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         suspend fun transFriendApp(time: Long, applierUid: String, operator: Long, tipText: String, flag: String): Boolean {
             pushRequest(RequestEvent.newBuilder().apply {
                 this.type = RequestEvent.RequestType.FRIEND_APPLY
-                this.time = time.toInt()
+                this.time = time
                 this.requestId = flag
                 this.friendApply = FriendApplyRequest.newBuilder().apply {
                     this.applierUid = applierUid
@@ -520,7 +520,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushRequest(RequestEvent.newBuilder().apply {
                 this.type = RequestEvent.RequestType.GROUP_APPLY
-                this.time = time.toInt()
+                this.time = time
                 this.requestId = flag
                 this.groupApply = GroupApplyRequest.newBuilder().apply {
                     this.applierUid = applierUid
@@ -541,7 +541,7 @@ internal object GlobalEventTransmitter : QQInterfaces() {
         ): Boolean {
             pushRequest(RequestEvent.newBuilder().apply {
                 this.type = RequestEvent.RequestType.GROUP_APPLY
-                this.time = time.toInt()
+                this.time = time
                 this.requestId = flag
                 this.invitedGroup = InvitedJoinGroupRequest.newBuilder().apply {
                     this.inviterUid = inviterUid

xposed/src/main/java/moe/fuqiuluo/shamrock/utils/PlatformUtils.kt

@@ -6,15 +6,18 @@ import android.content.Context
 import android.content.Context.BATTERY_SERVICE
 import android.content.Intent
 import android.content.IntentFilter
+import android.content.pm.ApplicationInfo
 import android.content.pm.PackageInfo
 import android.os.BatteryManager
 import android.os.Build
 import android.os.Process
 import android.provider.Settings
 import kotlinx.serialization.Serializable
+import moe.fuqiuluo.shamrock.tools.ShamrockVersion
 import mqq.app.MobileQQ
 import kotlin.random.Random
 
+
 internal object PlatformUtils {
     const val QQ_9_0_8_VER = 5540
 
@@ -69,6 +72,15 @@ internal object PlatformUtils {
         return MobileQQ.getMobileQQ().qqProcessName == "com.tencent.tim"
     }
 
+    fun isApkInDebug(context: Context): Boolean {
+        try {
+            val info = context.applicationInfo
+            return (info.flags and ApplicationInfo.FLAG_DEBUGGABLE) != 0
+        } catch (e: Exception) {
+            return false
+        }
+    }
+
     fun killProcess(context: Context, processName: String) {
         for (processInfo in (context.getSystemService(Context.ACTIVITY_SERVICE) as ActivityManager).runningAppProcesses) {
             if (processInfo.processName == processName) {

xposed/src/main/java/qq/service/bdh/NtV2RichMediaSvc.kt

@@ -355,7 +355,16 @@ internal object NtV2RichMediaSvc: QQInterfaces() {
             if (fromServiceMsg == null || fromServiceMsg.wupBuffer == null) {
                 return Result.failure(Exception("unable to get multimedia pic info: ${fromServiceMsg?.wupBuffer}"))
             }
-            fromServiceMsg.wupBuffer.decodeProtobuf<TrpcOidb>().buffer.decodeProtobuf<NtV2RichMediaRsp>().download?.rkeyParam?.let {
+            val trpc = kotlin.runCatching {
+                fromServiceMsg.wupBuffer.decodeProtobuf<TrpcOidb>()
+            }.getOrElse {
+                fromServiceMsg.wupBuffer.slice(4).decodeProtobuf<TrpcOidb>()
+            }
+            if (trpc.buffer == null) {
+                return Result.failure(Exception("unable to get multimedia pic info: ${trpc.msg}"))
+            }
+
+            trpc.buffer?.decodeProtobuf<NtV2RichMediaRsp>()?.download?.rkeyParam?.let {
                 return Result.success(it)
             }
         }.onFailure {
@@ -448,8 +457,15 @@ internal object NtV2RichMediaSvc: QQInterfaces() {
         if (fromServiceMsg == null || fromServiceMsg.wupBuffer == null) {
             return Result.failure(Exception("unable to request upload nt pic"))
         }
-        val rspBuffer = fromServiceMsg.wupBuffer.decodeProtobuf<TrpcOidb>().buffer
-        val rsp = rspBuffer.decodeProtobuf<NtV2RichMediaRsp>()
+        val trpc = kotlin.runCatching {
+            fromServiceMsg.wupBuffer.decodeProtobuf<TrpcOidb>()
+        }.getOrElse {
+            fromServiceMsg.wupBuffer.slice(4).decodeProtobuf<TrpcOidb>()
+        }
+        if (trpc.buffer == null) {
+            return Result.failure(Exception("unable to request upload nt pic: ${trpc.msg}"))
+        }
+        val rsp = trpc.buffer!!.decodeProtobuf<NtV2RichMediaRsp>()
         if (rsp.upload == null) {
             return Result.failure(Exception("unable to request upload nt pic: ${rsp.head}"))
         }

xposed/src/main/java/qq/service/file/GroupFileHelper.kt

@@ -10,6 +10,7 @@ import moe.fuqiuluo.shamrock.helper.Level
 import moe.fuqiuluo.shamrock.helper.LogCenter
 import moe.fuqiuluo.shamrock.tools.EMPTY_BYTE_ARRAY
 import moe.fuqiuluo.shamrock.tools.slice
+import moe.fuqiuluo.shamrock.tools.toHexString
 import moe.fuqiuluo.shamrock.utils.DeflateTools
 import qq.service.QQInterfaces
 import tencent.im.oidb.cmd0x6d8.oidb_0x6d8
@@ -31,12 +32,18 @@ internal object GroupFileHelper: QQInterfaces() {
         val fileCnt: Int
         val limitCnt: Int
         if (fromServiceMsg.wupBuffer != null) {
-            oidb_0x6d8.RspBody().mergeFrom(
-                oidb_sso.OIDBSSOPkg()
-                .mergeFrom(fromServiceMsg.wupBuffer.slice(4))
-                .bytes_bodybuffer.get()
-                .toByteArray()
-            ).group_file_cnt_rsp.apply {
+            val oidb1 = kotlin.runCatching {
+                oidb_sso.OIDBSSOPkg().mergeFrom(fromServiceMsg.wupBuffer.let {
+                    if (it[0] == 0x78.toByte()) DeflateTools.uncompress(it) else it
+                })
+            }.getOrElse {
+                LogCenter.log("unable to parse oidb response(OidbSvc.0x6d8_1): ${fromServiceMsg.wupBuffer.toHexString()}, ${it.stackTraceToString()}", Level.ERROR)
+                oidb_sso.OIDBSSOPkg().mergeFrom(fromServiceMsg.wupBuffer.slice(4).let {
+                    if (it[0] == 0x78.toByte()) DeflateTools.uncompress(it) else it
+                })
+            }
+
+            oidb_0x6d8.RspBody().mergeFrom(oidb1.bytes_bodybuffer.get().toByteArray()).group_file_cnt_rsp.apply {
                 fileCnt = uint32_all_file_count.get()
                 limitCnt = uint32_limit_count.get()
             }
@@ -53,11 +60,19 @@ internal object GroupFileHelper: QQInterfaces() {
         val totalSpace: Long
         val usedSpace: Long
         if (fromServiceMsg2.isSuccess && fromServiceMsg2.wupBuffer != null) {
-            oidb_0x6d8.RspBody().mergeFrom(
-                oidb_sso.OIDBSSOPkg()
-                .mergeFrom(fromServiceMsg2.wupBuffer.slice(4))
-                .bytes_bodybuffer.get()
-                .toByteArray()).group_space_rsp.apply {
+            val oidb2 = kotlin.runCatching {
+                oidb_sso.OIDBSSOPkg().mergeFrom(fromServiceMsg2.wupBuffer.let {
+                    if (it[0] == 0x78.toByte()) DeflateTools.uncompress(it) else it
+                })
+            }.onFailure {
+                LogCenter.log("unable to parse oidb response(OidbSvc.0x6d8_1): ${fromServiceMsg2.wupBuffer.toHexString()}, ${it.stackTraceToString()}", Level.ERROR)
+            }.getOrElse {
+                oidb_sso.OIDBSSOPkg().mergeFrom(fromServiceMsg2.wupBuffer.slice(4).let {
+                    if (it[0] == 0x78.toByte()) DeflateTools.uncompress(it) else it
+                })
+            }
+
+            oidb_0x6d8.RspBody().mergeFrom(oidb2.bytes_bodybuffer.get().toByteArray()).group_space_rsp.apply {
                 totalSpace = uint64_total_space.get()
                 usedSpace = uint64_used_space.get()
             }
@@ -95,16 +110,24 @@ internal object GroupFileHelper: QQInterfaces() {
 
                 uint32_show_onlinedoc_folder.set(0)
             })
-        }.toByteArray(), timeout = 15.seconds) ?: throw StatusRuntimeException(Status.INTERNAL.withDescription("unable to send oidb request"))
+        }.toByteArray(), timeout = 30.seconds) ?: throw StatusRuntimeException(Status.INTERNAL.withDescription("unable to send oidb request"))
         if (fromServiceMsg.wupBuffer == null) {
             throw StatusRuntimeException(Status.INTERNAL.withDescription("oidb request failed"))
         }
         val files = arrayListOf<File>()
         val folders = arrayListOf<Folder>()
         if (fromServiceMsg.wupBuffer != null) {
-            val oidb = oidb_sso.OIDBSSOPkg().mergeFrom(fromServiceMsg.wupBuffer.slice(4).let {
-                if (it[0] == 0x78.toByte()) DeflateTools.uncompress(it) else it
-            })
+            val oidb = kotlin.runCatching {
+                oidb_sso.OIDBSSOPkg().mergeFrom(fromServiceMsg.wupBuffer.slice(4).let {
+                    if (it[0] == 0x78.toByte()) DeflateTools.uncompress(it) else it
+                })
+            }.onFailure {
+                LogCenter.log("unable to parse oidb response: ${fromServiceMsg.wupBuffer.toHexString()}", Level.ERROR)
+            }.getOrElse {
+                oidb_sso.OIDBSSOPkg().mergeFrom(fromServiceMsg.wupBuffer.let {
+                    if (it[0] == 0x78.toByte()) DeflateTools.uncompress(it) else it
+                })
+            }
 
             oidb_0x6d8.RspBody().mergeFrom(oidb.bytes_bodybuffer.get().toByteArray())
                 .file_list_info_rsp.apply {
@@ -116,9 +139,9 @@ internal object GroupFileHelper: QQInterfaces() {
                                 this.fileName = fileInfo.str_file_name.get()
                                 this.fileSize = fileInfo.uint64_file_size.get()
                                 this.busId = fileInfo.uint32_bus_id.get()
-                                this.uploadTime = fileInfo.uint32_upload_time.get()
-                                this.expireTime = fileInfo.uint32_dead_time.get()
-                                this.modifyTime = fileInfo.uint32_modify_time.get()
+                                this.uploadTime = fileInfo.uint32_upload_time.get().toLong()
+                                this.expireTime = fileInfo.uint32_dead_time.get().toLong()
+                                this.modifyTime = fileInfo.uint32_modify_time.get().toLong()
                                 this.downloadTimes = fileInfo.uint32_download_times.get()
                                 this.uploader = fileInfo.uint64_uploader_uin.get()
                                 this.uploaderName = fileInfo.str_uploader_name.get()
@@ -133,7 +156,7 @@ internal object GroupFileHelper: QQInterfaces() {
                                 this.folderId = folderInfo.str_folder_id.get()
                                 this.folderName = folderInfo.str_folder_name.get()
                                 this.totalFileCount = folderInfo.uint32_total_file_count.get()
-                                this.createTime = folderInfo.uint32_create_time.get()
+                                this.createTime = folderInfo.uint32_create_time.get().toLong()
                                 this.creator = folderInfo.uint64_create_uin.get()
                                 this.creatorName = folderInfo.str_creator_name.get()
                             }.build())

xposed/src/main/java/qq/service/internals/AioListener.kt

@@ -3,14 +3,21 @@
 package qq.service.internals
 
 import com.tencent.qqnt.kernel.nativeinterface.MsgConstant
+import com.tencent.qqnt.kernel.nativeinterface.MsgElement
 import com.tencent.qqnt.kernel.nativeinterface.MsgRecord
+import com.tencent.qqnt.kernel.nativeinterface.TextElement
 import kotlinx.coroutines.DelicateCoroutinesApi
 import kotlinx.coroutines.GlobalScope
 import kotlinx.coroutines.launch
+import moe.fuqiuluo.shamrock.config.AliveReply
+import moe.fuqiuluo.shamrock.config.get
 import moe.fuqiuluo.shamrock.helper.Level
 import moe.fuqiuluo.shamrock.helper.LogCenter
 import moe.fuqiuluo.shamrock.internals.GlobalEventTransmitter
+import moe.fuqiuluo.shamrock.utils.PlatformUtils
 import qq.service.bdh.RichProtoSvc
+import qq.service.file.GroupFileHelper
+import qq.service.group.GroupHelper
 import qq.service.kernel.SimpleKernelMsgListener
 import qq.service.msg.MessageHelper
 
@@ -28,6 +35,49 @@ object AioListener : SimpleKernelMsgListener() {
     }
 
     private suspend fun onMsg(record: MsgRecord) {
+        if (AliveReply.get()) {
+            val texts = record.elements.filter { it.elementType == MsgConstant.KELEMTYPETEXT }
+            val text = texts.joinToString { it.textElement.content }
+            if (texts.isNotEmpty() && text == "ping") {
+                val contact = MessageHelper.generateContact(record)
+                MessageHelper.sendMessage(contact, arrayListOf(
+                    MsgElement().apply {
+                        elementType = MsgConstant.KELEMTYPETEXT
+                        textElement = TextElement().apply {
+                            content = "pong"
+                        }
+                    }
+                ), 3, MessageHelper.generateMsgId(record.chatType))
+                return
+            }
+
+            if (record.chatType == MsgConstant.KCHATTYPEGROUP && text == ".shamrock.members") {
+                val contact = MessageHelper.generateContact(record)
+                GroupHelper.getGroupMemberList(record.peerUin, true).onSuccess {
+                    MessageHelper.sendMessage(contact, arrayListOf(
+                        MsgElement().apply {
+                            elementType = MsgConstant.KELEMTYPETEXT
+                            textElement = TextElement().apply {
+                                content = "memberCount: ${it.size}"
+                            }
+                        }
+                    ), 3, MessageHelper.generateMsgId(record.chatType))
+                }.onFailure {
+                    LogCenter.log("获取群成员列表失败: $it", Level.ERROR)
+                }
+            } else if (record.chatType == MsgConstant.KCHATTYPEGROUP && text == ".shamrock.root_files") {
+                val contact = MessageHelper.generateContact(record)
+                val files = GroupFileHelper.getGroupFiles(record.peerUin)
+                MessageHelper.sendMessage(contact, arrayListOf(
+                    MsgElement().apply {
+                        elementType = MsgConstant.KELEMTYPETEXT
+                        textElement = TextElement().apply {
+                            content = "foldersCount: ${files.foldersCount}\nfilesCount: ${files.filesCount}"
+                        }
+                    }
+                ), 3, MessageHelper.generateMsgId(record.chatType))
+            }
+        }
         when (record.chatType) {
             MsgConstant.KCHATTYPEGROUP -> {
                 if (record.senderUin == 0L) return

xposed/src/main/java/qq/service/internals/PrimitiveListener.kt

@@ -216,6 +216,9 @@ internal object PrimitiveListener {
             }.decodeProtobuf<GroupCommonTipsEvent>()
         }
         val groupId = event.groupCode.toLong()
+        if (event.uniqueTitleChangeDetail == null) {
+            return
+        }
         val detail = event.uniqueTitleChangeDetail!!.first()
 
         // todo 贴表情也走的 732 16 这里

xposed/src/main/java/qq/service/kernel/SimpleKernelMsgListener.kt

@@ -12,6 +12,7 @@ import com.tencent.qqnt.kernel.nativeinterface.FileTransNotifyInfo
 import com.tencent.qqnt.kernel.nativeinterface.FirstViewDirectMsgNotifyInfo
 import com.tencent.qqnt.kernel.nativeinterface.FirstViewGroupGuildInfo
 import com.tencent.qqnt.kernel.nativeinterface.FreqLimitInfo
+import com.tencent.qqnt.kernel.nativeinterface.GProGuildTopFeedMsg
 import com.tencent.qqnt.kernel.nativeinterface.GroupFileListResult
 import com.tencent.qqnt.kernel.nativeinterface.GroupGuildNotifyInfo
 import com.tencent.qqnt.kernel.nativeinterface.GroupItem
@@ -27,6 +28,7 @@ import com.tencent.qqnt.kernel.nativeinterface.MsgAbstract
 import com.tencent.qqnt.kernel.nativeinterface.MsgElement
 import com.tencent.qqnt.kernel.nativeinterface.MsgRecord
 import com.tencent.qqnt.kernel.nativeinterface.MsgSetting
+import com.tencent.qqnt.kernel.nativeinterface.QueryUserSecQualityRsp
 import com.tencent.qqnt.kernel.nativeinterface.RecvdOrder
 import com.tencent.qqnt.kernel.nativeinterface.RelatedWordEmojiInfo
 import com.tencent.qqnt.kernel.nativeinterface.SearchGroupFileResult
@@ -135,7 +137,10 @@ abstract class SimpleKernelMsgListener: IKernelMsgListener {
         
     }
 
-    override fun onHitCsRelatedEmojiResult(downloadRelateEmojiResultInfo: DownloadRelateEmojiResultInfo?) {
+     override fun onGuildTopFeedUpdate(gProGuildTopFeedMsg: GProGuildTopFeedMsg?) {
+     }
+
+     override fun onHitCsRelatedEmojiResult(downloadRelateEmojiResultInfo: DownloadRelateEmojiResultInfo?) {
         
     }
 
@@ -207,7 +212,10 @@ abstract class SimpleKernelMsgListener: IKernelMsgListener {
         
     }
 
-    override fun onNtFirstViewMsgSyncEnd() {
+     override fun onMsgWithRichLinkInfoUpdate(arrayList: ArrayList<MsgRecord>?) {
+     }
+
+     override fun onNtFirstViewMsgSyncEnd() {
         
     }
 
@@ -258,7 +266,10 @@ abstract class SimpleKernelMsgListener: IKernelMsgListener {
         
     }
 
-    override fun onRichMediaDownloadComplete(fileTransNotifyInfo: FileTransNotifyInfo?) {
+     override fun onRedTouchChanged() {
+     }
+
+     override fun onRichMediaDownloadComplete(fileTransNotifyInfo: FileTransNotifyInfo?) {
         
     }
 
@@ -308,7 +319,10 @@ abstract class SimpleKernelMsgListener: IKernelMsgListener {
         
     }
 
-    override fun onUserTabStatusChanged(arrayList: ArrayList<TabStatusInfo>?) {
+     override fun onUserSecQualityChanged(queryUserSecQualityRsp: QueryUserSecQualityRsp?) {
+     }
+
+     override fun onUserTabStatusChanged(arrayList: ArrayList<TabStatusInfo>?) {
         
     }
 

xposed/src/main/java/qq/service/msg/MsgConvertor.kt

@@ -78,7 +78,7 @@ private object MsgConvertor {
             elem.type = ElementType.POKE
             elem.setPoke(PokeElement.newBuilder().apply {
                 this.id = face.vaspokeId
-                this.type = face.pokeType
+                this.pokeType = face.pokeType
                 this.strength = face.pokeStrength
             })
         } else {
@@ -195,7 +195,7 @@ private object MsgConvertor {
 
                 else -> throw UnsupportedOperationException("Not supported chat type: ${record.chatType}")
             }
-            this.type =
+            this.fileType =
                 if (image.isFlashPic == true) ImageElement.ImageType.FLASH else if (image.original) ImageElement.ImageType.ORIGIN else ImageElement.ImageType.COMMON
             this.subType = image.picSubType
         })

xposed/src/main/java/qq/service/msg/MultiConvertor.kt

@@ -65,7 +65,7 @@ suspend fun List<Elem>.toKritorResponseMessages(contact: Contact): ArrayList<Ele
                 this.type = ElementType.IMAGE
                 this.image = ImageElement.newBuilder().apply {
                     this.fileMd5 = md5
-                    this.type = if (customFace.origin == true) ImageType.ORIGIN else ImageType.COMMON
+                    this.fileType = if (customFace.origin == true) ImageType.ORIGIN else ImageType.COMMON
                     this.fileUrl = when (contact.chatType) {
                         MsgConstant.KCHATTYPEDISC, MsgConstant.KCHATTYPEGROUP -> RichProtoSvc.getGroupPicDownUrl(
                             origUrl,
@@ -85,7 +85,7 @@ suspend fun List<Elem>.toKritorResponseMessages(contact: Contact): ArrayList<Ele
                 this.type = ElementType.IMAGE
                 this.image = ImageElement.newBuilder().apply {
                     this.fileMd5 = md5
-                    this.type = if (element.notOnlineImage?.original == true) ImageType.ORIGIN else ImageType.COMMON
+                    this.fileType = if (element.notOnlineImage?.original == true) ImageType.ORIGIN else ImageType.COMMON
                     this.fileUrl = when (contact.chatType) {
                         MsgConstant.KCHATTYPEDISC, MsgConstant.KCHATTYPEGROUP -> RichProtoSvc.getGroupPicDownUrl(
                             origUrl,

xposed/src/main/java/qq/service/msg/NtMsgConvertor.kt

@@ -254,8 +254,8 @@ object NtMsgConvertor {
     }
 
     private suspend fun imageConvertor(contact: Contact, msgId: Long, sourceImage: Element): Result<MsgElement> {
-        val isOriginal = sourceImage.image.type == ImageType.ORIGIN
-        val isFlash = sourceImage.image.type == ImageType.FLASH
+        val isOriginal = sourceImage.image.fileType == ImageType.ORIGIN
+        val isFlash = sourceImage.image.fileType == ImageType.FLASH
         val file = when (sourceImage.image.dataCase!!) {
             ImageElement.DataCase.FILE_NAME -> {
                 val fileMd5 = sourceImage.image.fileName.replace(regex = "[{}\\-]".toRegex(), replacement = "")
@@ -638,7 +638,7 @@ object NtMsgConvertor {
         face.faceText = ""
         face.faceType = 5
         face.packId = null
-        face.pokeType = sourcePoke.poke.type
+        face.pokeType = sourcePoke.poke.pokeType
         face.spokeSummary = ""
         face.doubleHit = 0
         face.vaspokeId = sourcePoke.poke.id

xposed/src/main/java/qq/service/msg/ReqMessageConvertor.kt

@@ -73,7 +73,7 @@ private object ReqMsgConvertor {
         if (face.faceType == 5) {
             elem.setPoke(PokeElement.newBuilder().apply {
                 this.id = face.vaspokeId
-                this.type = face.pokeType
+                this.pokeType = face.pokeType
                 this.strength = face.pokeStrength
             })
         } else {
@@ -174,7 +174,7 @@ private object ReqMsgConvertor {
 
                 else -> throw UnsupportedOperationException("Not supported chat type: ${contact.chatType}")
             }
-            this.type =
+            this.fileType =
                 if (image.isFlashPic == true) ImageElement.ImageType.FLASH else if (image.original) ImageElement.ImageType.ORIGIN else ImageElement.ImageType.COMMON
             this.subType = image.picSubType
         })

xposed/src/main/java/qq/service/msg/ReqMultiConvertor.kt

@@ -183,7 +183,7 @@ suspend fun List<Element>.toRichText(contact: Contact): Result<Pair<String, Rich
                     summary.append("[回复消息]")
                 }
                 Element.ElementType.IMAGE -> {
-                    val type = it.image.type
+                    val type = it.image.fileType
                     val isOriginal = type == ImageElement.ImageType.ORIGIN
                     val file = when(it.image.dataCase!!) {
                         ImageElement.DataCase.FILE_NAME -> {
@@ -391,7 +391,7 @@ suspend fun List<Element>.toRichText(contact: Contact): Result<Pair<String, Rich
                         commonElem = CommonElem(
                             serviceType = 2,
                             elem = PokeExtra(
-                                type = it.poke.type,
+                                type = it.poke.pokeType,
                                 field7 = 0,
                                 field8 = 0
                             ).toByteArray(),