Extends ChatProcessor explicitly

This commit is contained in:
taizan-hokuto
2019-12-20 21:33:32 +09:00
parent 289841a000
commit 3c1f079d5f
4 changed files with 9 additions and 7 deletions

View File

@@ -10,14 +10,14 @@ class ChatProcessor:
Parameter Parameter
---------- ----------
chat_components: [LIST:component] chat_components: List[component]
component : dict { component : dict {
"video_id" : str "video_id" : str
動画ID 動画ID
"timeout" : int "timeout" : int
次のチャットの再読み込みまでの時間(秒) 次のチャットの再読み込みまでの時間(秒)
"chatdata" : list<object> "chatdata" : List[dict]
チャットデータactionsのリスト チャットデータのリスト
} }
''' '''
pass pass

View File

@@ -4,11 +4,12 @@ from .renderer.textmessage import LiveChatTextMessageRenderer
from .renderer.paidmessage import LiveChatPaidMessageRenderer from .renderer.paidmessage import LiveChatPaidMessageRenderer
from .renderer.paidsticker import LiveChatPaidStickerRenderer from .renderer.paidsticker import LiveChatPaidStickerRenderer
from .renderer.legacypaid import LiveChatLegacyPaidMessageRenderer from .renderer.legacypaid import LiveChatLegacyPaidMessageRenderer
from .. chat_processor import ChatProcessor
from ... import mylogger from ... import mylogger
from ... import config from ... import config
logger = mylogger.get_logger(__name__,mode=config.LOGGER_MODE) logger = mylogger.get_logger(__name__,mode=config.LOGGER_MODE)
class CompatibleProcessor: class CompatibleProcessor(ChatProcessor):
def process(self, chat_components: list): def process(self, chat_components: list):

View File

@@ -4,6 +4,7 @@ from .renderer.textmessage import LiveChatTextMessageRenderer
from .renderer.paidmessage import LiveChatPaidMessageRenderer from .renderer.paidmessage import LiveChatPaidMessageRenderer
from .renderer.paidsticker import LiveChatPaidStickerRenderer from .renderer.paidsticker import LiveChatPaidStickerRenderer
from .renderer.legacypaid import LiveChatLegacyPaidMessageRenderer from .renderer.legacypaid import LiveChatLegacyPaidMessageRenderer
from .. chat_processor import ChatProcessor
from ... import config from ... import config
from ... import mylogger from ... import mylogger
logger = mylogger.get_logger(__name__,mode=config.LOGGER_MODE) logger = mylogger.get_logger(__name__,mode=config.LOGGER_MODE)
@@ -25,7 +26,7 @@ class Chatdata:
return return
await asyncio.sleep(self.interval/len(self.items)) await asyncio.sleep(self.interval/len(self.items))
class DefaultProcessor: class DefaultProcessor(ChatProcessor):
def process(self, chat_components: list): def process(self, chat_components: list):
chatlist = [] chatlist = []

View File

@@ -4,7 +4,7 @@ speedmeter.py
Calculate speed of chat. Calculate speed of chat.
""" """
import calendar, datetime, pytz import calendar, datetime, pytz
from .chat_processor import ChatProcessor
class RingQueue: class RingQueue:
""" """
リング型キュー リング型キュー
@@ -77,7 +77,7 @@ class RingQueue:
def item_count(self): def item_count(self):
return len(self.items) return len(self.items)
class SpeedCalculator(RingQueue): class SpeedCalculator(ChatProcessor, RingQueue):
""" """
チャットの勢いを計算するクラス チャットの勢いを計算するクラス
Parameter Parameter