q792602257/Douyin_Web_Live
Archived
0
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

粉丝团消息处理

Browse Source
This commit is contained in:
Jerry Yan 2022-06-06 12:36:53 +08:00
parent 710da42341
commit d57287507a
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
output/manager.py
View File

@ -3,6 +3,7 @@ import threading
from typing import TYPE_CHECKING from typing import TYPE_CHECKING
from config.helper import config from config.helper import config
from messages.fansclub import FansclubMessage
from proxy.queues import MESSAGE_QUEUE from proxy.queues import MESSAGE_QUEUE
from messages.chat import ChatMessage from messages.chat import ChatMessage
from messages.control import ControlMessage from messages.control import ControlMessage
@ -93,6 +94,11 @@ class OutputManager():
control_message.set_payload(message.payload) control_message.set_payload(message.payload)
for writer in self._writer: for writer in self._writer:
writer.control_output(control_message) writer.control_output(control_message)
elif message.method == 'WebcastFansclubMessage':
fansclub_message = FansclubMessage()
fansclub_message.set_payload(message.payload)
for writer in self._writer:
writer.fansclub_output(fansclub_message)
else: else:
for writer in self._writer: for writer in self._writer:
writer.other_output(message.method, message.payload) writer.other_output(message.method, message.payload)