feat: 开播/关播消息

README.md

@@ -152,6 +152,44 @@ export type Handler = {
 }
 ```
 
+### handler.onLiveStart
+
+直播开始消息
+
+```ts
+export type Handler = {
+  /** 直播开始消息 */
+  onLiveStart: (msg: Message<LiveStartMsg>) => void
+}
+
+type msgType = 'LIVE'
+
+export interface LiveStartMsg {
+  /** 开播平台 */
+  live_platform: string
+  /** 房间号 */
+  room_id: number
+}
+```
+
+### handler.onLiveEnd
+
+直播结束消息
+
+```ts
+export type Handler = {
+  /** 直播结束消息 */
+  onLiveEnd: (msg: Message<LiveEndMsg>) => void
+}
+
+type msgType = 'PREPARING'
+
+export interface LiveEndMsg {
+  /** 房间号 */
+  room_id: number
+}
+```
+
 ### handler.onIncomeDanmu
 
 收到普通弹幕消息

src/listener/index.ts

@@ -1,5 +1,7 @@
 import {
   HEARTBEAT, type AttentionChangeMsgHandler,
+  LIVE, type LiveStartMsgHandler, 
+  PREPARING, type LiveStopMsgHandler,
   DANMU_MSG, type DanmuMsgHandler,
   GUARD_BUY, type GuardBuyHandler,
   INTERACT_WORD, ENTRY_EFFECT, type NewComerMsgHandler,
@@ -22,6 +24,8 @@ export type MsgHandler = Partial<
     onStartListen: () => void,
   }
   & AttentionChangeMsgHandler
+  & LiveStartMsgHandler
+  & LiveStopMsgHandler
   & DanmuMsgHandler
   & GuardBuyHandler
   & NewComerMsgHandler
@@ -71,6 +75,22 @@ export const listenAll = (instance: KeepLiveTCP | KeepLiveWS, roomId: number, ha
     })
   }
 
+  // LIVE
+  if (handler[LIVE.handlerName]) {
+    instance.on(LIVE.eventName, (data: WSMessage<any>) => {
+      const parsedData = LIVE.parser(data.data)
+      handler[LIVE.handlerName]?.(normalizeDanmu(LIVE.eventName, parsedData))
+    })
+  }
+
+  // PREPARING
+  if (handler[PREPARING.handlerName]) {
+    instance.on(PREPARING.eventName, (data: WSMessage<any>) => {
+      const parsedData = PREPARING.parser(data.data)
+      handler[PREPARING.handlerName]?.(normalizeDanmu(PREPARING.eventName, parsedData))
+    })
+  }
+
   // DANMU_MSG
   if (handler[DANMU_MSG.handlerName]) {
     instance.on(DANMU_MSG.eventName, (data: WSMessage<any>) => {

src/parser/LIVE.ts

@@ -0,0 +1,26 @@
+import type { Message } from '../types/app'
+
+export interface LiveStartMsg {
+  /** 开播平台 */
+  live_platform: string
+  /** 房间号 */
+  room_id: number
+}
+
+const parser = (data: any): LiveStartMsg => {
+  return {
+    live_platform: data.live_platform,
+    room_id: data.roomid,
+  }
+}
+
+export const LIVE = {
+  parser,
+  eventName: 'LIVE' as const,
+  handlerName: 'onLiveStart' as const,
+}
+
+export type Handler = {
+  /** 直播开始消息 */
+  onLiveStart: (msg: Message<LiveStartMsg>) => void
+}

src/parser/PREPARING.ts

@@ -0,0 +1,23 @@
+import type { Message } from '../types/app'
+
+export interface LiveEndMsg {
+  /** 房间号 */
+  room_id: number
+}
+
+const parser = (data: any): LiveEndMsg => {
+  return {
+    room_id: parseInt(data.roomid),
+  }
+}
+
+export const PREPARING = {
+  parser,
+  eventName: 'PREPARING' as const,
+  handlerName: 'onLiveEnd' as const,
+}
+
+export type Handler = {
+  /** 直播结束消息 */
+  onLiveEnd: (msg: Message<LiveEndMsg>) => void
+}

src/parser/index.ts

@@ -1,4 +1,6 @@
 export { HEARTBEAT, Handler as AttentionChangeMsgHandler, AttentionChangeMsg } from './HEARTBEAT'
+export { LIVE, Handler as LiveStartMsgHandler, LiveStartMsg } from './LIVE'
+export { PREPARING, Handler as LiveStopMsgHandler, LiveStopMsg } from './PREPARING'
 export { DANMU_MSG, Handler as DanmuMsgHandler, DanmuMsg } from './DANMU_MSG'
 export { GUARD_BUY, Handler as GuardBuyHandler, GuardBuyMsg } from './GUARD_BUY'
 export { INTERACT_WORD, ENTRY_EFFECT, Handler as NewComerMsgHandler, NewComerMsg } from './INTERACT_WORD_ENTRY_EFFECT'