feat(event): implement guild-request event

chrononeko · Aug 23, 2024 · d4f322d · d4f322d
1 parent 660c7d5
commit d4f322d
Show file tree

Hide file tree

Showing 5 changed files with 157 additions and 3 deletions.
diff --git a/packages/engine-chronocat-api/src/definitions/groupService.ts b/packages/engine-chronocat-api/src/definitions/groupService.ts
@@ -139,6 +139,17 @@ export const quitGroup = define<
   ]
 >('ns-ntApi-2', 'nodeIKernelGroupService/quitGroup')
 
+export const getSingleScreenNotifies = define<
+  unknown,
+  [
+    {
+      doubt: boolean
+      startSeq: string // '1716209619000000'
+      number: number // 16
+    },
+  ]
+>('ns-ntApi-2', 'nodeIKernelGroupService/getSingleScreenNotifies')
+
 export const operateSysNotify = define<
   unknown,
   [

diff --git a/packages/engine-chronocat-event/src/globalVars.ts b/packages/engine-chronocat-event/src/globalVars.ts
@@ -2,6 +2,7 @@ import type { Group, Profile } from '@chronocat/red'
 
 export const requestMethodMap: Record<string, string> = {}
 export const emittedBuddyReqList: string[] = []
+export const emittedGroupReqList: string[] = []
 
 export const sendQueue: string[] = []
 

diff --git a/packages/engine-chronocat-event/src/handler.ts b/packages/engine-chronocat-event/src/handler.ts
@@ -5,6 +5,7 @@ import type {
   OnBuddyListChange,
   OnBuddyReqChange,
   OnGroupListUpdate,
+  OnGroupSingleScreenNotifies,
   OnMemberInfoChange,
   OnMemberListChange,
   OnMsgInfoListUpdate,
@@ -22,13 +23,15 @@ import type { ChronocatContext } from '@chronocat/shell'
 import type { IpcManData } from 'ipcman'
 import {
   emittedBuddyReqList,
+  emittedGroupReqList,
   friendMap,
   groupMap,
   requestMethodMap,
   sendQueue,
 } from './globalVars'
 import {
   FriendRequestDispatchMessage,
+  GuildRequestDispatchMessage,
   MessageCreatedDispatchMessage,
   MessageDeletedDispatchMessage,
 } from './messages'
@@ -208,6 +211,30 @@ const dispatcher = async (
       return
     }
 
+    case 'nodeIKernelGroupListener/onGroupNotifiesUnreadCountUpdated': {
+      // const {} = payload as OnGroupNotifiesUnreadCountUpdated
+
+      return
+    }
+
+    case 'nodeIKernelGroupListener/onGroupSingleScreenNotifies': {
+      const { notifies } = payload as OnGroupSingleScreenNotifies
+
+      for (const notify of notifies) {
+        const uin = ctx.chronocat.uix.getUin(notify.user1.uid)
+        if (!uin) return
+
+        const key = `${notify.group.groupCode}:${uin}:${notify.seq}`
+        if (emittedGroupReqList.includes(key)) return
+
+        emittedGroupReqList.push(key)
+
+        ctx.chronocat.emit(new GuildRequestDispatchMessage(notify, uin))
+      }
+
+      return
+    }
+
     case 'onBuddyListChange':
     case 'nodeIKernelBuddyListener/onBuddyListChange': {
       const { data } = payload as OnBuddyListChange
@@ -225,8 +252,6 @@ const dispatcher = async (
     }
 
     case 'nodeIKernelBuddyListener/onBuddyReqChange': {
-      if (channel !== 'IPC_DOWN_2') return
-
       const { buddyReqs } = payload as OnBuddyReqChange
 
       buddyReqs.forEach((x) => {

diff --git a/packages/engine-chronocat-event/src/messages.ts b/packages/engine-chronocat-event/src/messages.ts
@@ -1,4 +1,4 @@
-import type { BuddyReq, RedMessage } from '@chronocat/red'
+import type { BuddyReq, GroupNotify, RedMessage } from '@chronocat/red'
 import type {
   ChronocatContext,
   ChronocatLogCurrentConfig,
@@ -38,6 +38,46 @@ export class MessageDeletedDispatchMessage implements SatoriDispatchMessage {
       .map((e) => ((e.type = 'message-deleted'), e))
 }
 
+export class GuildRequestDispatchMessage implements SatoriDispatchMessage {
+  constructor(
+    private notify: GroupNotify,
+    private uin: string,
+  ) {}
+
+  type = 'satori' as const
+
+  toSatori = async (
+    ctx: ChronocatContext,
+    _config: O.Intersect<
+      ChronocatLogCurrentConfig,
+      ChronocatSatoriEventsConfig
+    >,
+  ) => {
+    const event: Event = {
+      id: undefined as unknown as number,
+      type: 'guild-request',
+
+      platform: ctx.chronocat.platform,
+      self_id: undefined as unknown as string,
+      timestamp: new Date().getTime(),
+
+      guild: {
+        id: this.notify.group.groupCode,
+        name: this.notify.group.groupName,
+        avatar: `https://p.qlogo.cn/gh/${this.notify.group.groupCode}/${this.notify.group.groupCode}/640`,
+      },
+
+      user: {
+        id: `${this.uin}`,
+        name: this.notify.user1.nickName,
+        avatar: `http://thirdqq.qlogo.cn/headimg_dl?dst_uin=${this.uin}&spec=640`,
+      },
+    }
+
+    return [event]
+  }
+}
+
 export class FriendRequestDispatchMessage implements SatoriDispatchMessage {
   constructor(
     private buddyReq: BuddyReq,

diff --git a/packages/red/src/redIpcEntity.ts b/packages/red/src/redIpcEntity.ts
@@ -180,3 +180,80 @@ export interface MsgsIncludeSelf {
 export interface OnOpenParamChange {
   data: Contact[]
 }
+
+export interface OnGroupNotifiesUnreadCountUpdated {
+  /**
+   * 是否有过滤消息
+   */
+  doubt: boolean
+
+  /**
+   * 最旧未读消息 ID
+   */
+  oldestUnreadSeq: string // '1716209619000000'
+
+  /**
+   *
+   * 未读消息数
+   */
+  unreadCount: number
+}
+
+export interface OnGroupSingleScreenNotifies {
+  /**
+   * 是否是过滤消息列表
+   */
+  doubt: false
+
+  /**
+   * 分页 ID
+   */
+  nextStartSeq: '0'
+
+  notifies: GroupNotify[]
+}
+
+export interface GroupNotify {
+  seq: string // '1716209619000000'
+
+  type: number // 7
+
+  status: number // 1
+
+  group: {
+    groupCode: string
+    groupName: string
+  }
+
+  user1: {
+    uid: string
+    nickName: string
+  }
+
+  user2: {
+    uid: string
+    nickName: string
+  }
+
+  actionUser: {
+    uid: string
+    nickName: string
+  }
+
+  actionTime: string // '0'
+
+  invitationExt: {
+    srcType: number // 0
+    groupCode: string // '0'
+    waitStatus: number // 0
+  }
+
+  /**
+   * 验证消息
+   */
+  postscript: string
+
+  repeatSeqs: []
+
+  warningTips: string // '该账号存在风险，请谨慎操作'
+}