feat: 消息调整

liveMan.py

@@ -334,7 +334,7 @@ class DouyinLiveWebFetcher:
         asyncio.run(send_message(f"【点赞msg】{user_name} 点了{count}个赞"))
 
     
-    async def _parseMemberMsg(self, payload):
+    def _parseMemberMsg(self, payload):
         '''进入直播间消息'''
         message = MemberMessage().parse(payload)
         user_name = message.user.nick_name
@@ -358,7 +358,7 @@ class DouyinLiveWebFetcher:
         current = message.total
         total = message.total_pv_for_anchor
         print(f"【统计msg】当前观看人数: {current}, 累计观看人数: {total}")
-        asyncio.run(send_message(f"【统计msg】当前观看人数: {current}, 累计观看人数: {total}"))
+        # asyncio.run(send_message(f"【统计msg】当前观看人数: {current}, 累计观看人数: {total}"))
 
     
     def _parseFansclubMsg(self, payload):
@@ -385,22 +385,21 @@ class DouyinLiveWebFetcher:
         common = message.common
         room_id = common.room_id
         print(f"【直播间msg】直播间id:{room_id}")
-        asyncio.run(send_message(f"【直播间msg】直播间id:{room_id}"))
+        # asyncio.run(send_message(f"【直播间msg】直播间id:{room_id}"))
 
     
     def _parseRoomStatsMsg(self, payload):
         message = RoomStatsMessage().parse(payload)
         display_long = message.display_long
         print(f"【直播间统计msg】{display_long}")
-        asyncio.run(send_message(f"【直播间统计msg】{display_long}"))
+        # asyncio.run(send_message(f"【直播间统计msg】{display_long}"))
 
     
     def _parseRankMsg(self, payload):
         message = RoomRankMessage().parse(payload)
         ranks_list = message.ranks_list
         print(f"【直播间排行榜msg】{ranks_list}")
-        asyncio.run(send_message(f"【直播间排行榜msg】{ranks_list}"))
-
+        # asyncio.run(send_message(f"【直播间排行榜msg】{ranks_list}"))
     
     def _parseControlMsg(self, payload):
         '''直播间状态消息'''
@@ -408,12 +407,12 @@ class DouyinLiveWebFetcher:
         
         if message.status == 3:
             print("直播间已结束")
-            asyncio.run(send_message(f"直播间已结束"))
+            # asyncio.run(send_message(f"直播间已结束"))
             self.stop()
     
     def _parseRoomStreamAdaptationMsg(self, payload):
         message = RoomStreamAdaptationMessage().parse(payload)
         adaptationType = message.adaptation_type
         print(f'直播间adaptation: {adaptationType}')
-        asyncio.run(send_message(f'直播间adaptation: {adaptationType}'))
+        # asyncio.run(send_message(f'直播间adaptation: {adaptationType}'))
 

main.py

@@ -6,7 +6,7 @@ import asyncio
 from ws_server import start_ws_server
 
 if __name__ == '__main__':
-    live_id = '139226983757'
+    live_id = '174880838400'
     room = DouyinLiveWebFetcher(live_id)
     room.get_room_status()
     room.start()