feat: 用户点赞直播间消息

link #20

Author: ddiu8081

README.md

@@ -39,7 +39,7 @@ const instance = startListen(652581, handler)
 instance.close()
 ```
 
-> 需传入房间的长id。短id需转为长id才能接收到消息。(#19 )
+> 需传入房间的长id。短id需转为长id才能接收到消息。(https://github.com/ddiu8081/blive-message-listener/issues/19)
 
 ## Handlers & Type Definitions
 
@@ -308,20 +308,20 @@ export interface RankCountChangeMsg {
 
 ##### handler.onUserAction
 
-用户进入、关注、分享直播间
+用户进入、关注、分享、点赞直播间
 
 - 舰长进入直播间时，有几率会触发两次
 - 舰长进入直播间时，uname 超长可能会省略号截断
 
 ```ts
 export type Handler = {
-  /** 用户进入、关注、分享直播间 */
+  /** 用户进入、关注、分享、点赞直播间 */
   onUserAction: (msg: Message<UserActionMsg>) => void
 }
 
-type msgType = 'INTERACT_WORD' | 'ENTRY_EFFECT'
+type msgType = 'INTERACT_WORD' | 'ENTRY_EFFECT' | 'LIKE_INFO_V3_CLICK'
 
-type UserAction = 'enter' | 'follow' | 'share' | 'unknown'
+type UserAction = 'enter' | 'follow' | 'share' | 'like' | 'unknown'
 
 export interface UserActionMsg {
   user: User

src/listener/index.ts

@@ -4,7 +4,7 @@ import {
   PREPARING, type LiveStopMsgHandler,
   DANMU_MSG, type DanmuMsgHandler,
   GUARD_BUY, type GuardBuyHandler,
-  INTERACT_WORD, ENTRY_EFFECT, type UserActionMsgHandler,
+  INTERACT_WORD, ENTRY_EFFECT, LIKE_INFO_V3_CLICK, type UserActionMsgHandler,
   LIKE_INFO_V3_UPDATE, type LikedChangeMsgHandler,
   ONLINE_RANK_COUNT, type RankCountChangeMsgHandler,
   ROOM_CHANGE, type RoomInfoChangeHandler,
@@ -119,7 +119,7 @@ export const listenAll = (instance: KeepLiveTCP | KeepLiveWS, roomId: number, ha
     })
   }
 
-  // INTERACT_WORD, ENTRY_EFFECT
+  // INTERACT_WORD, ENTRY_EFFECT, LIKE_INFO_V3_CLICK
   if (handler[INTERACT_WORD.handlerName] || handler[ENTRY_EFFECT.handlerName] || rawHandlerNames.has(INTERACT_WORD.eventName) || rawHandlerNames.has(ENTRY_EFFECT.eventName)) {
     rawHandlerNames.delete(INTERACT_WORD.eventName)
     rawHandlerNames.delete(ENTRY_EFFECT.eventName)
@@ -133,6 +133,11 @@ export const listenAll = (instance: KeepLiveTCP | KeepLiveWS, roomId: number, ha
       const parsedData = ENTRY_EFFECT.parser(data.data, roomId)
       handler[ENTRY_EFFECT.handlerName]?.(normalizeDanmu(ENTRY_EFFECT.eventName, parsedData, data.data))
     })
+    instance.on(LIKE_INFO_V3_CLICK.eventName, (data: WSMessage<any>) => {
+      isHandleRaw && rawHandler[LIKE_INFO_V3_CLICK.eventName]?.(data.data)
+      const parsedData = LIKE_INFO_V3_CLICK.parser(data.data, roomId)
+      handler[LIKE_INFO_V3_CLICK.handlerName]?.(normalizeDanmu(LIKE_INFO_V3_CLICK.eventName, parsedData, data.data))
+    })
   }
 
   // LIKE_INFO_V3_UPDATE

src/parser/INTERACT_WORD_ENTRY_EFFECT.ts

@@ -1,7 +1,7 @@
 import { intToColorHex } from '../utils/color'
 import type { Message, User } from '../types/app'
 
-type UserAction = 'enter' | 'follow' | 'share' | 'unknown'
+type UserAction = 'enter' | 'follow' | 'share' | 'like' | 'unknown'
 
 export interface UserActionMsg {
   user: User
@@ -72,10 +72,41 @@ const parserGuard = (data: any, roomId: number): UserActionMsg => {
   }
 }
 
+const parserLike = (data: any, roomId: number): UserActionMsg => {
+  const rawData = data.data
+  return {
+    user: {
+      uid: rawData.uid,
+      uname: rawData.uname,
+      badge: rawData.fans_medal?.target_id ? {
+        active: rawData.fans_medal?.is_lighted,
+        name: rawData.fans_medal?.medal_name,
+        level: rawData.fans_medal?.medal_level,
+        color: intToColorHex(rawData.fans_medal?.medal_color),
+        gradient: [
+          intToColorHex(rawData.fans_medal?.medal_color_start),
+          intToColorHex(rawData.fans_medal?.medal_color_start),
+          intToColorHex(rawData.fans_medal?.medal_color_end),
+        ],
+        anchor: {
+          uid: rawData.fans_medal?.target_id,
+          uname: '',
+          room_id: rawData.fans_medal?.anchor_roomid, // 返回为 0
+          is_same_room: rawData.fans_medal?.anchor_roomid === roomId,
+        }
+      } : undefined,
+    },
+    action: 'like',
+    timestamp: Date.now(),
+  }
+}
+
 const parser = (data: any, roomId: number): UserActionMsg => {
   const msgType = data.cmd
   if (msgType === 'ENTRY_EFFECT') {
     return parserGuard(data, roomId)
+  } else if (msgType === 'LIKE_INFO_V3_CLICK') {
+    return parserLike(data, roomId)
   } else {
     // INTERACT_WORD
     return parserNormal(data, roomId)
@@ -94,7 +125,13 @@ export const ENTRY_EFFECT = {
   handlerName: 'onUserAction' as const,
 }
 
+export const LIKE_INFO_V3_CLICK = {
+  parser,
+  eventName: 'LIKE_INFO_V3_CLICK' as const,
+  handlerName: 'onUserAction' as const,
+}
+
 export type Handler = {
-  /** 用户进入、关注、分享直播间 */
+  /** 用户进入、关注、分享、点赞直播间 */
   onUserAction: (msg: Message<UserActionMsg>) => void
 }

src/parser/index.ts

@@ -3,7 +3,7 @@ export { LIVE, type Handler as LiveStartMsgHandler, type LiveStartMsg } from './
 export { PREPARING, type Handler as LiveStopMsgHandler, type LiveEndMsg } from './PREPARING'
 export { DANMU_MSG, type Handler as DanmuMsgHandler, type DanmuMsg } from './DANMU_MSG'
 export { GUARD_BUY, type Handler as GuardBuyHandler, type GuardBuyMsg } from './GUARD_BUY'
-export { INTERACT_WORD, ENTRY_EFFECT, type Handler as UserActionMsgHandler, type UserActionMsg } from './INTERACT_WORD_ENTRY_EFFECT'
+export { INTERACT_WORD, ENTRY_EFFECT, LIKE_INFO_V3_CLICK, type Handler as UserActionMsgHandler, type UserActionMsg } from './INTERACT_WORD_ENTRY_EFFECT'
 export { LIKE_INFO_V3_UPDATE, type Handler as LikedChangeMsgHandler, type LikedChangeMsg } from './LIKE_INFO_V3_UPDATE'
 export { ONLINE_RANK_COUNT, type Handler as RankCountChangeMsgHandler, type RankCountChangeMsg } from './ONLINE_RANK_COUNT'
 export { ROOM_CHANGE, type Handler as RoomInfoChangeHandler, type RoomInfoChangeMsg } from './ROOM_CHANGE'