send chat for new followers

USER_INFO.py

@@ -0,0 +1,3 @@
+SESSDATA = ''
+bili_jct = ''
+buvid3 = ''

app.py

@@ -11,12 +11,19 @@ import aiohttp
 
 import blivedm
 import blivedm.models.web as web_models
+from blivedm.clients.ws_base import BulletChat
+
+import USER_INFO
 
 # 直播间ID的取值看直播间URL
 TEST_ROOM_ID = 9792252
 
 # 这里填一个已登录账号的cookie的SESSDATA字段的值。不填也可以连接，但是收到弹幕的用户名会打码，UID会变成0
-SESSDATA = ''
+cookies = http.cookies.SimpleCookie()
+cookies['SESSDATA'] = USER_INFO.SESSDATA
+cookies['SESSDATA']['domain'] = 'bilibili.com'
+cookies['bili_jct'] = USER_INFO.bili_jct
+cookies['buvid3'] = USER_INFO.buvid3
 
 session: Optional[aiohttp.ClientSession] = None
 
@@ -29,12 +36,7 @@ async def dm_monitor():
     finally:
         await session.close()
 
-
 def init_session():
-    cookies = http.cookies.SimpleCookie()
-    cookies['SESSDATA'] = SESSDATA
-    cookies['SESSDATA']['domain'] = 'bilibili.com'
-
     global session
     session = aiohttp.ClientSession()
     session.cookie_jar.update_cookies(cookies)
@@ -42,6 +44,8 @@ def init_session():
 
 async def run_single_client():
     room_id = TEST_ROOM_ID
+
+    global client
     client = blivedm.BLiveClient(room_id, session=session)
     handler = MyHandler()
     client.set_handler(handler)
@@ -63,7 +67,7 @@ class MyHandler(blivedm.BaseHandler):
         uname = command['data']['uname']
         msg_type = command['data']['msg_type']
         if msg_type == 2:
-            dmplayer.Pend(f'谢谢{uname}的关注喵', "bubu.wav")
+            asyncio.create_task(client.send_bulletchat(BulletChat(msg=f'谢谢{uname}的关注喵')))
 
     _CMD_CALLBACK_DICT['INTERACT_WORD'] = __interact_word_callback